Package com.avoka.fc.core.sysevent

Class AWSServiceClient

java.lang.Object

com.avoka.fc.core.sysevent.ServiceClient

com.avoka.fc.core.sysevent.AWSServiceClient

public class AWSServiceClient
extends ServiceClient

Provides AWS SQS service client for use with the System Event Publisher

Since:

20.05.0

Nested Class Summary

Nested classes/interfaces inherited from class com.avoka.fc.core.sysevent.ServiceClient

ServiceClient.ServiceClientType

Field Summary

Fields inherited from class com.avoka.fc.core.sysevent.ServiceClient

configHash, credentialsExpiry, queueUrlMap

Constructor Summary

Constructors

Constructor	Description
AWSServiceClient(com.amazonaws.services.sqs.AmazonSQS amazonSQS, Date credentialsExpiry, String configHash)

Method Summary

Modifier and Type	Method	Description
void	createQueue(String queueName)	Creates a queue in the cloud instance using the name queueName
String	getQueueUrlForQueueName(String queueName)	For a given queueName will return the URL
ServiceClient.ServiceClientType	getServiceClientType()	Will return the type of the Service Client instance, i.e.
boolean	isExistingQueue(String queueName)	For a given queueName will return true if it exists
void	sendMessage(String queueURL, String msg)	Will send a message 'msg' to the specified queueUrl

Methods inherited from class com.avoka.fc.core.sysevent.ServiceClient

getConfigHash, getCredentialsExpiryDate, getQueueUrlMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AWSServiceClient

public AWSServiceClient(com.amazonaws.services.sqs.AmazonSQS amazonSQS,
                        Date credentialsExpiry,
                        String configHash)

Method Detail

createQueue

public void createQueue(String queueName)

Description copied from class: ServiceClient

Creates a queue in the cloud instance using the name queueName

Specified by:

createQueue in class ServiceClient

Parameters:

queueName - to create

getQueueUrlForQueueName

public String getQueueUrlForQueueName(String queueName)

Description copied from class: ServiceClient

For a given queueName will return the URL

Specified by:

getQueueUrlForQueueName in class ServiceClient

Parameters:

queueName - for the url

Returns:

url if queueName found else null

getServiceClientType

public ServiceClient.ServiceClientType getServiceClientType()

Description copied from class: ServiceClient

Will return the type of the Service Client instance, i.e. (AWS, Azure, etc)

Specified by:

getServiceClientType in class ServiceClient

Returns:

serviceClientType of instance

isExistingQueue

public boolean isExistingQueue(String queueName)

Description copied from class: ServiceClient

For a given queueName will return true if it exists

Specified by:

isExistingQueue in class ServiceClient

Parameters:

queueName - to determine if exists

Returns:

true if it exists else false

sendMessage

public void sendMessage(String queueURL,
                        String msg)

Description copied from class: ServiceClient

Will send a message 'msg' to the specified queueUrl

Specified by:

sendMessage in class ServiceClient

Parameters:

queueURL - to receive the message

msg - to send