Packages

class AmazonSQSClient extends AmazonSQSWrapper

Source
AmazonSQSClient.scala
Linear Supertypes
AmazonSQSWrapper, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AmazonSQSClient
  2. AmazonSQSWrapper
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AmazonSQSClient(client: AmazonSQSAsync, executorService: ExecutorService)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. def +(other: String): String
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to any2stringadd[AmazonSQSClient] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (AmazonSQSClient, B)
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to ArrowAssoc[AmazonSQSClient] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  6. def addPermission(queueUrl: String, label: String, accountActions: Map[String, String]): Future[AddPermissionResult]
    Definition Classes
    AmazonSQSWrapper
  7. def addPermission(addPermissionRequest: AddPermissionRequest): Future[AddPermissionResult]
    Definition Classes
    AmazonSQSWrapper
  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def changeMessageVisibility(queueUrl: String, receiptHandle: String, visibilityTimeout: Int): Future[ChangeMessageVisibilityResult]
    Definition Classes
    AmazonSQSWrapper
  10. def changeMessageVisibility(changeMessageVisibilityRequest: ChangeMessageVisibilityRequest): Future[ChangeMessageVisibilityResult]
    Definition Classes
    AmazonSQSWrapper
  11. def changeMessageVisibilityBatch(queueUrl: String, messageVisibilities: Seq[(String, String, Int)]): Future[ChangeMessageVisibilityBatchResult]
    Definition Classes
    AmazonSQSWrapper
  12. def changeMessageVisibilityBatch(changeMessageVisibilityBatchRequest: ChangeMessageVisibilityBatchRequest): Future[ChangeMessageVisibilityBatchResult]
    Definition Classes
    AmazonSQSWrapper
  13. val client: AmazonSQSAsync
    Definition Classes
    AmazonSQSClient → AmazonSQSWrapper
  14. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  15. def createQueue(queueName: String, attributes: Map[QueueAttributeName, Any] = Map.empty): Future[CreateQueueResult]
    Definition Classes
    AmazonSQSWrapper
  16. def createQueue(createQueueRequest: CreateQueueRequest): Future[CreateQueueResult]
    Definition Classes
    AmazonSQSWrapper
  17. val defaultMessageOpsConcurrency: Int
  18. def deleteMessage(queueUrl: String, receiptHandle: String): Future[DeleteMessageResult]
    Definition Classes
    AmazonSQSWrapper
  19. def deleteMessage(deleteMessageRequest: DeleteMessageRequest): Future[DeleteMessageResult]
    Definition Classes
    AmazonSQSWrapper
  20. def deleteMessageBatch(queueUrl: String, entries: Seq[(String, String)]): Future[DeleteMessageBatchResult]
    Definition Classes
    AmazonSQSWrapper
  21. def deleteMessageBatch(deleteMessageBatchRequest: DeleteMessageBatchRequest): Future[DeleteMessageBatchResult]
    Definition Classes
    AmazonSQSWrapper
  22. def deleteQueue(queueUrl: String): Future[DeleteQueueResult]
    Definition Classes
    AmazonSQSWrapper
  23. def deleteQueue(deleteQueueRequest: DeleteQueueRequest): Future[DeleteQueueResult]
    Definition Classes
    AmazonSQSWrapper
  24. implicit val ec: ExecutionContextExecutorService
    Definition Classes
    AmazonSQSClient → AmazonSQSWrapper
  25. def ensuring(cond: (AmazonSQSClient) ⇒ Boolean, msg: ⇒ Any): AmazonSQSClient
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to Ensuring[AmazonSQSClient] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  26. def ensuring(cond: (AmazonSQSClient) ⇒ Boolean): AmazonSQSClient
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to Ensuring[AmazonSQSClient] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  27. def ensuring(cond: Boolean, msg: ⇒ Any): AmazonSQSClient
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to Ensuring[AmazonSQSClient] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  28. def ensuring(cond: Boolean): AmazonSQSClient
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to Ensuring[AmazonSQSClient] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  29. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  31. val executorService: ExecutorService
  32. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  33. def formatted(fmtstr: String): String
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to StringFormat[AmazonSQSClient] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  34. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  35. def getQueueAttributes(queueUrl: String, attributeNames: Seq[String]): Future[Map[String, String]]
    Definition Classes
    AmazonSQSWrapper
  36. def getQueueAttributes(getQueueAttributesRequest: GetQueueAttributesRequest): Future[GetQueueAttributesResult]
    Definition Classes
    AmazonSQSWrapper
  37. def getQueueUrl(queueName: String): Future[String]
    Definition Classes
    AmazonSQSWrapper
  38. def getQueueUrl(getQueueUrlRequest: GetQueueUrlRequest): Future[GetQueueUrlResult]
    Definition Classes
    AmazonSQSWrapper
  39. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  40. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  41. def listQueues(queueNamePrefix: String = null): Future[Seq[String]]
    Definition Classes
    AmazonSQSWrapper
  42. def listQueues(listQueuesRequest: ListQueuesRequest): Future[ListQueuesResult]
    Definition Classes
    AmazonSQSWrapper
  43. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  44. final def notify(): Unit
    Definition Classes
    AnyRef
  45. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  46. def receiveMessage(queueUrl: String, maxNumberOfMessages: Int): Future[Seq[Message]]
    Definition Classes
    AmazonSQSWrapper
  47. def receiveMessage(queueUrl: String): Future[Message]
    Definition Classes
    AmazonSQSWrapper
  48. def receiveMessage(receiveMessageRequest: ReceiveMessageRequest): Future[ReceiveMessageResult]
    Definition Classes
    AmazonSQSWrapper
  49. def receiveMessageAsStream(queueUrl: String, messageAckingConcurrency: Int = defaultMessageOpsConcurrency, longPollingMaxWait: FiniteDuration = 20 seconds, autoAck: Boolean = false, messageAttributeNames: Seq[String] = Seq.empty): Source[Message, ActorRef]

    Receive messages from a SQS queue as a stream.

    Receive messages from a SQS queue as a stream.

    queueUrl

    SQS queue url

    longPollingMaxWait

    SQS long-polling parameter.

    autoAck

    If true, the SQS messages will be automatically ack once they are received. If false, you must call deleteMessage yourself when you want to ack the message.

    messageAttributeNames

    the message attribute names asked to be returned

  50. def receiveMessageAsStreamWithRetryExpBackoff(queueUrl: String, messageAckingConcurrency: Int = defaultMessageOpsConcurrency, maxRetryDuration: FiniteDuration = 540.seconds, retryMinInterval: FiniteDuration = 1.second, longPollingMaxWait: FiniteDuration = 20 seconds, autoAck: Boolean = false, messageAttributeNames: Seq[String] = Seq.empty): Source[Message, ActorRef]

    Receive messages from a SQS queue as a stream and if connection closes, retry using an exponential backoff reconnection strategy (2^retryNb * retryMinInterval).

    Receive messages from a SQS queue as a stream and if connection closes, retry using an exponential backoff reconnection strategy (2^retryNb * retryMinInterval).

    queueUrl

    SQS queue url

    maxRetryDuration

    maximum retry duration.

    retryMinInterval

    minimum delay before retrying.

    longPollingMaxWait

    SQS long-polling parameter.

    autoAck

    If true, the SQS messages will be automatically ack once they are received. If false, you must call deleteMessage yourself when you want to ack the message.

    messageAttributeNames

    the message attribute names asked to be returned

  51. def removePermission(queueUrl: String, label: String): Future[RemovePermissionResult]
    Definition Classes
    AmazonSQSWrapper
  52. def removePermission(removePermissionRequest: RemovePermissionRequest): Future[RemovePermissionResult]
    Definition Classes
    AmazonSQSWrapper
  53. def sendMessage(queueUrl: String, messageBody: String): Future[SendMessageResult]
    Definition Classes
    AmazonSQSWrapper
  54. def sendMessage(sendMessageRequest: SendMessageRequest): Future[SendMessageResult]
    Definition Classes
    AmazonSQSWrapper
  55. def sendMessageAsStream(messageSendingConcurrency: Int = defaultMessageOpsConcurrency): Flow[SendMessageRequest, SendMessageResult, NotUsed]

    Send SQS messages as a stream Important note: SQS does not ensure message ordering, so setting messageSendingConcurrency parameter equal to 1 does not guarantee total message ordering.

  56. def sendMessageBatch(queueUrl: String, entries: Seq[(String, String)]): Future[SendMessageBatchResult]
    Definition Classes
    AmazonSQSWrapper
  57. def sendMessageBatch(sendMessageBatchRequest: SendMessageBatchRequest): Future[SendMessageBatchResult]
    Definition Classes
    AmazonSQSWrapper
  58. def setQueueAttributes(queueUrl: String, attributes: Map[String, String]): Future[SetQueueAttributesResult]
    Definition Classes
    AmazonSQSWrapper
  59. def setQueueAttributes(setQueueAttributesRequest: SetQueueAttributesRequest): Future[SetQueueAttributesResult]
    Definition Classes
    AmazonSQSWrapper
  60. def shutdown(): Unit
    Definition Classes
    AmazonSQSWrapper
  61. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  62. def toString(): String
    Definition Classes
    AnyRef → Any
  63. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  64. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  65. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  66. def →[B](y: B): (AmazonSQSClient, B)
    Implicit
    This member is added by an implicit conversion from AmazonSQSClient to ArrowAssoc[AmazonSQSClient] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from AmazonSQSWrapper

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from AmazonSQSClient to any2stringadd[AmazonSQSClient]

Inherited by implicit conversion StringFormat from AmazonSQSClient to StringFormat[AmazonSQSClient]

Inherited by implicit conversion Ensuring from AmazonSQSClient to Ensuring[AmazonSQSClient]

Inherited by implicit conversion ArrowAssoc from AmazonSQSClient to ArrowAssoc[AmazonSQSClient]

Ungrouped