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
  • Constructor Details

    • AWSServiceClient

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

    • 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