Class QueueConfigurationOptionsProxy
- java.lang.Object
-
- org.apache.camel.component.azure.storage.queue.QueueConfigurationOptionsProxy
-
public class QueueConfigurationOptionsProxy extends Object
A proxy class forQueueConfiguration
andQueueExchangeHeaders
. Ideally this is responsible to obtain the correct configurations options either from configs or exchange headers
-
-
Constructor Summary
Constructors Constructor Description QueueConfigurationOptionsProxy(QueueConfiguration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description QueueConfiguration
getConfiguration()
Integer
getMaxMessages(org.apache.camel.Exchange exchange)
String
getMessageId(org.apache.camel.Exchange exchange)
Map<String,String>
getMetadata(org.apache.camel.Exchange exchange)
String
getPopReceipt(org.apache.camel.Exchange exchange)
String
getQueueName(org.apache.camel.Exchange exchange)
QueueOperationDefinition
getQueueOperation(org.apache.camel.Exchange exchange)
com.azure.storage.queue.models.QueuesSegmentOptions
getQueuesSegmentOptions(org.apache.camel.Exchange exchange)
Duration
getTimeout(org.apache.camel.Exchange exchange)
Duration
getTimeToLive(org.apache.camel.Exchange exchange)
Duration
getVisibilityTimeout(org.apache.camel.Exchange exchange)
boolean
isCreateQueue(org.apache.camel.Exchange exchange)
-
-
-
Constructor Detail
-
QueueConfigurationOptionsProxy
public QueueConfigurationOptionsProxy(QueueConfiguration configuration)
-
-
Method Detail
-
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)
-
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()
-
-