Class QueueClientWrapper
- java.lang.Object
-
- org.apache.camel.component.azure.storage.queue.client.QueueClientWrapper
-
public class QueueClientWrapper extends Object
-
-
Constructor Summary
Constructors Constructor Description QueueClientWrapper(com.azure.storage.queue.QueueClient client)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.azure.core.http.rest.Response<Void>
clearMessages(Duration timeout)
com.azure.core.http.rest.Response<Void>
create(Map<String,String> metadata, Duration timeout)
com.azure.core.http.rest.Response<Void>
delete(Duration timeout)
com.azure.core.http.rest.Response<Void>
deleteMessage(String messageId, String popReceipt, Duration timeout)
List<com.azure.storage.queue.models.PeekedMessageItem>
peekMessages(Integer maxMessages, Duration timeout)
List<com.azure.storage.queue.models.QueueMessageItem>
receiveMessages(Integer maxMessages, Duration visibilityTimeout, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.queue.models.SendMessageResult>
sendMessage(String messageText, Duration visibilityTimeout, Duration timeToLive, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.queue.models.UpdateMessageResult>
updateMessage(String messageId, String popReceipt, String messageText, Duration visibilityTimeout, Duration timeout)
-
-
-
Method Detail
-
create
public com.azure.core.http.rest.Response<Void> create(Map<String,String> metadata, Duration timeout)
-
sendMessage
public com.azure.core.http.rest.Response<com.azure.storage.queue.models.SendMessageResult> sendMessage(String messageText, Duration visibilityTimeout, Duration timeToLive, Duration timeout)
-
deleteMessage
public com.azure.core.http.rest.Response<Void> deleteMessage(String messageId, String popReceipt, Duration timeout)
-
receiveMessages
public List<com.azure.storage.queue.models.QueueMessageItem> receiveMessages(Integer maxMessages, Duration visibilityTimeout, Duration timeout)
-
peekMessages
public List<com.azure.storage.queue.models.PeekedMessageItem> peekMessages(Integer maxMessages, Duration timeout)
-
-