Package com.amazon.sns.messaging.lib.core

Class AmazonSnsTemplate<E>

java.lang.Object
com.amazon.sns.messaging.lib.core.AmazonSnsTemplate<E>
public class AmazonSnsTemplate<E> extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected com.amazon.sns.messaging.lib.core.AbstractAmazonSnsProducer<com.amazonaws.services.sns.model.PublishBatchRequest,com.amazonaws.services.sns.model.PublishBatchResult,E>
    amazonSnsProducer
     
    protected final ConcurrentMap<String,com.amazon.sns.messaging.lib.core.ListenableFutureRegistry>
    pendingRequests
     
    protected BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>>
    topicRequests
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty)
     
    AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
     
    AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>> topicRequests)
     
    AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>> topicRequests, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<Void>
    await()
     
    com.amazon.sns.messaging.lib.core.ListenableFuture<com.amazon.sns.messaging.lib.model.ResponseSuccessEntry,com.amazon.sns.messaging.lib.model.ResponseFailEntry>
    send(com.amazon.sns.messaging.lib.model.RequestEntry<E> arg0)
     
    void
    shutdown()
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • pendingRequests

      protected final ConcurrentMap<String,com.amazon.sns.messaging.lib.core.ListenableFutureRegistry> pendingRequests

    • topicRequests

      protected BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>> topicRequests

    • amazonSnsProducer

      protected com.amazon.sns.messaging.lib.core.AbstractAmazonSnsProducer<com.amazonaws.services.sns.model.PublishBatchRequest,com.amazonaws.services.sns.model.PublishBatchResult,E> amazonSnsProducer

  • Constructor Details

    • AmazonSnsTemplate

      public AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>> topicRequests, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

    • AmazonSnsTemplate

      public AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, BlockingQueue<com.amazon.sns.messaging.lib.model.RequestEntry<E>> topicRequests)

    • AmazonSnsTemplate

      public AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

    • AmazonSnsTemplate

      public AmazonSnsTemplate(com.amazonaws.services.sns.AmazonSNS amazonSNS, com.amazon.sns.messaging.lib.model.TopicProperty topicProperty)

  • Method Details

    • send

      public com.amazon.sns.messaging.lib.core.ListenableFuture<com.amazon.sns.messaging.lib.model.ResponseSuccessEntry,com.amazon.sns.messaging.lib.model.ResponseFailEntry> send(com.amazon.sns.messaging.lib.model.RequestEntry<E> arg0)

    • shutdown

      public void shutdown()

    • await

      public CompletableFuture<Void> await()