Class QueueConfigurationOptionsProxy

java.lang.Object
org.apache.camel.component.azure.storage.queue.QueueConfigurationOptionsProxy

public class QueueConfigurationOptionsProxy extends Object
A proxy class for QueueConfiguration and QueueExchangeHeaders. Ideally this is responsible to obtain the correct configurations options either from configs or exchange headers
  • Constructor Details

    • QueueConfigurationOptionsProxy

      public QueueConfigurationOptionsProxy(QueueConfiguration configuration)
  • Method Details

    • getTimeout

      public Duration getTimeout(org.apache.camel.Exchange exchange)
    • getVisibilityTimeout

      public Duration getVisibilityTimeout(org.apache.camel.Exchange exchange)
    • getTimeToLive

      public Duration getTimeToLive(org.apache.camel.Exchange exchange)
    • getMaxMessages

      public Integer getMaxMessages(org.apache.camel.Exchange exchange)
    • getQueueName

      public String getQueueName(org.apache.camel.Exchange exchange)
    • getMetadata

      public Map<String,String> getMetadata(org.apache.camel.Exchange exchange)
    • getMessageId

      public String getMessageId(org.apache.camel.Exchange exchange)
    • getPopReceipt

      public String getPopReceipt(org.apache.camel.Exchange exchange)
    • getQueuesSegmentOptions

      public com.azure.storage.queue.models.QueuesSegmentOptions getQueuesSegmentOptions(org.apache.camel.Exchange exchange)
    • isCreateQueue

      public boolean isCreateQueue(org.apache.camel.Exchange exchange)
    • getQueueOperation

      public QueueOperationDefinition getQueueOperation(org.apache.camel.Exchange exchange)
    • getConfiguration

      public QueueConfiguration getConfiguration()