Class QueueExchangeHeaders
- java.lang.Object
-
- org.apache.camel.component.azure.storage.queue.QueueExchangeHeaders
-
public class QueueExchangeHeaders extends Object
-
-
Constructor Summary
Constructors Constructor Description QueueExchangeHeaders()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static QueueExchangeHeaders
createQueueExchangeHeadersFromQueueMessageItem(com.azure.storage.queue.models.QueueMessageItem item)
static QueueExchangeHeaders
createQueueExchangeHeadersFromSendMessageResult(com.azure.storage.queue.models.SendMessageResult result)
QueueExchangeHeaders
dequeueCount(long count)
QueueExchangeHeaders
expirationTime(OffsetDateTime expirationTime)
static Boolean
getCreateQueueFlagFromHeaders(org.apache.camel.Exchange exchange)
static Integer
getMaxMessagesFromHeaders(org.apache.camel.Exchange exchange)
static String
getMessageIdFromHeaders(org.apache.camel.Exchange exchange)
static Map<String,String>
getMetadataFromHeaders(org.apache.camel.Exchange exchange)
static String
getPopReceiptFromHeaders(org.apache.camel.Exchange exchange)
static String
getQueueNameFromHeaders(org.apache.camel.Exchange exchange)
static QueueOperationDefinition
getQueueOperationsDefinitionFromHeaders(org.apache.camel.Exchange exchange)
static com.azure.storage.queue.models.QueuesSegmentOptions
getQueuesSegmentOptionsFromHeaders(org.apache.camel.Exchange exchange)
static Duration
getTimeoutFromHeaders(org.apache.camel.Exchange exchange)
static Duration
getTimeToLiveFromHeaders(org.apache.camel.Exchange exchange)
static Duration
getVisibilityTimeout(org.apache.camel.Exchange exchange)
QueueExchangeHeaders
httpHeaders(com.azure.core.http.HttpHeaders httpHeaders)
QueueExchangeHeaders
insertionTime(OffsetDateTime insertionTime)
QueueExchangeHeaders
messageId(String id)
QueueExchangeHeaders
popReceipt(String pop)
QueueExchangeHeaders
timeNextVisible(OffsetDateTime timeNextVisible)
Map<String,Object>
toMap()
-
-
-
Method Detail
-
createQueueExchangeHeadersFromSendMessageResult
public static QueueExchangeHeaders createQueueExchangeHeadersFromSendMessageResult(com.azure.storage.queue.models.SendMessageResult result)
-
createQueueExchangeHeadersFromQueueMessageItem
public static QueueExchangeHeaders createQueueExchangeHeadersFromQueueMessageItem(com.azure.storage.queue.models.QueueMessageItem item)
-
getQueuesSegmentOptionsFromHeaders
public static com.azure.storage.queue.models.QueuesSegmentOptions getQueuesSegmentOptionsFromHeaders(org.apache.camel.Exchange exchange)
-
getTimeoutFromHeaders
public static Duration getTimeoutFromHeaders(org.apache.camel.Exchange exchange)
-
getMetadataFromHeaders
public static Map<String,String> getMetadataFromHeaders(org.apache.camel.Exchange exchange)
-
getTimeToLiveFromHeaders
public static Duration getTimeToLiveFromHeaders(org.apache.camel.Exchange exchange)
-
getVisibilityTimeout
public static Duration getVisibilityTimeout(org.apache.camel.Exchange exchange)
-
getCreateQueueFlagFromHeaders
public static Boolean getCreateQueueFlagFromHeaders(org.apache.camel.Exchange exchange)
-
getPopReceiptFromHeaders
public static String getPopReceiptFromHeaders(org.apache.camel.Exchange exchange)
-
getMessageIdFromHeaders
public static String getMessageIdFromHeaders(org.apache.camel.Exchange exchange)
-
getMaxMessagesFromHeaders
public static Integer getMaxMessagesFromHeaders(org.apache.camel.Exchange exchange)
-
getQueueOperationsDefinitionFromHeaders
public static QueueOperationDefinition getQueueOperationsDefinitionFromHeaders(org.apache.camel.Exchange exchange)
-
getQueueNameFromHeaders
public static String getQueueNameFromHeaders(org.apache.camel.Exchange exchange)
-
messageId
public QueueExchangeHeaders messageId(String id)
-
insertionTime
public QueueExchangeHeaders insertionTime(OffsetDateTime insertionTime)
-
expirationTime
public QueueExchangeHeaders expirationTime(OffsetDateTime expirationTime)
-
popReceipt
public QueueExchangeHeaders popReceipt(String pop)
-
timeNextVisible
public QueueExchangeHeaders timeNextVisible(OffsetDateTime timeNextVisible)
-
dequeueCount
public QueueExchangeHeaders dequeueCount(long count)
-
httpHeaders
public QueueExchangeHeaders httpHeaders(com.azure.core.http.HttpHeaders httpHeaders)
-
-