Package com.microsoft.azure.servicebus.primitives

Class CoreMessageReceiver

java.lang.Object

com.microsoft.azure.servicebus.primitives.ClientEntity

com.microsoft.azure.servicebus.primitives.CoreMessageReceiver

All Implemented Interfaces:

IAmqpLink, IAmqpReceiver

public class CoreMessageReceiver
extends ClientEntity
implements IAmqpReceiver

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	abandonMessageAsync(byte[] deliveryTag, Map<String,Object> propertiesToModify, TransactionContext transaction)
CompletableFuture<Void>	abandonMessageAsync(UUID lockToken, Map<String,Object> propertiesToModify, TransactionContext transaction)
CompletableFuture<Void>	completeMessageAsync(byte[] deliveryTag, TransactionContext transaction)
CompletableFuture<Void>	completeMessageAsync(UUID lockToken, TransactionContext transaction)
static CompletableFuture<CoreMessageReceiver>	create(MessagingFactory factory, String name, String recvPath, int prefetchCount, SettleModePair settleModePair)	Deprecated.
static CompletableFuture<CoreMessageReceiver>	create(MessagingFactory factory, String name, String recvPath, int prefetchCount, SettleModePair settleModePair, MessagingEntityType entityType)
static CompletableFuture<CoreMessageReceiver>	create(MessagingFactory factory, String name, String recvPath, String sessionId, boolean isBrowsableSession, int prefetchCount, SettleModePair settleModePair)	Deprecated.
static CompletableFuture<CoreMessageReceiver>	create(MessagingFactory factory, String name, String recvPath, String sessionId, boolean isBrowsableSession, int prefetchCount, SettleModePair settleModePair, MessagingEntityType entityType)
CompletableFuture<Void>	deadLetterMessageAsync(byte[] deliveryTag, String deadLetterReason, String deadLetterErrorDescription, Map<String,Object> propertiesToModify, TransactionContext transaction)
CompletableFuture<Void>	deadLetterMessageAsync(UUID lockToken, String deadLetterReason, String deadLetterErrorDescription, Map<String,Object> propertiesToModify, TransactionContext transaction)
CompletableFuture<Void>	deferMessageAsync(byte[] deliveryTag, Map<String,Object> propertiesToModify, TransactionContext transaction)
CompletableFuture<Void>	deferMessageAsync(UUID lockToken, Map<String,Object> propertiesToModify, TransactionContext transaction)
com.microsoft.azure.servicebus.primitives.ErrorContext	getContext()
int	getPrefetchCount()
String	getSessionId()
Instant	getSessionLockedUntilUtc()
CompletableFuture<byte[]>	getSessionStateAsync()
protected CompletableFuture<Void>	onClose()
void	onClose(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)
void	onError(Exception exception)
void	onOpenComplete(Exception exception)
void	onReceiveComplete(org.apache.qpid.proton.engine.Delivery delivery)
CompletableFuture<Collection<org.apache.qpid.proton.message.Message>>	peekMessagesAsync(long fromSequenceNumber, int messageCount, String sessionId)
CompletableFuture<Collection<MessageWithDeliveryTag>>	receiveAsync(int maxMessageCount, Duration timeout)
CompletableFuture<Collection<MessageWithLockToken>>	receiveDeferredMessageBatchAsync(Long[] sequenceNumbers)
CompletableFuture<Collection<Instant>>	renewMessageLocksAsync(UUID[] lockTokens)
CompletableFuture<Void>	renewSessionLocksAsync()
void	setPrefetchCount(int value)
CompletableFuture<Void>	setSessionStateAsync(byte[] sessionState)
CompletableFuture<Void>	updateDispositionAsync(UUID[] lockTokens, String dispositionStatus, String deadLetterReason, String deadLetterErrorDescription, Map<String,Object> propertiesToModify, TransactionContext transaction)

Methods inherited from class com.microsoft.azure.servicebus.primitives.ClientEntity

close, closeAsync, finalize, getClientId, getIsClosed, getIsClosingOrClosed, setClosed, setClosing, throwIfClosed

Methods inherited from class java.lang.Object

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

Method Detail

create

@Deprecated
public static CompletableFuture<CoreMessageReceiver> create(MessagingFactory factory,
                                                            String name,
                                                            String recvPath,
                                                            int prefetchCount,
                                                            SettleModePair settleModePair)

Deprecated.

create

@Deprecated
public static CompletableFuture<CoreMessageReceiver> create(MessagingFactory factory,
                                                            String name,
                                                            String recvPath,
                                                            String sessionId,
                                                            boolean isBrowsableSession,
                                                            int prefetchCount,
                                                            SettleModePair settleModePair)

Deprecated.

create

public static CompletableFuture<CoreMessageReceiver> create(MessagingFactory factory,
                                                            String name,
                                                            String recvPath,
                                                            int prefetchCount,
                                                            SettleModePair settleModePair,
                                                            MessagingEntityType entityType)

create

public static CompletableFuture<CoreMessageReceiver> create(MessagingFactory factory,
                                                            String name,
                                                            String recvPath,
                                                            String sessionId,
                                                            boolean isBrowsableSession,
                                                            int prefetchCount,
                                                            SettleModePair settleModePair,
                                                            MessagingEntityType entityType)

getPrefetchCount

public int getPrefetchCount()

getSessionId

public String getSessionId()

getSessionLockedUntilUtc

public Instant getSessionLockedUntilUtc()

setPrefetchCount

public void setPrefetchCount(int value)
                      throws ServiceBusException

Throws:

ServiceBusException

receiveAsync

public CompletableFuture<Collection<MessageWithDeliveryTag>> receiveAsync(int maxMessageCount,
                                                                          Duration timeout)

onOpenComplete

public void onOpenComplete(Exception exception)

Specified by:

onOpenComplete in interface IAmqpLink

Parameters:

exception - completionException=null if open is successful

onReceiveComplete

public void onReceiveComplete(org.apache.qpid.proton.engine.Delivery delivery)

Specified by:

onReceiveComplete in interface IAmqpReceiver

onError

public void onError(Exception exception)

Specified by:

onError in interface IAmqpLink

onClose

public void onClose(org.apache.qpid.proton.amqp.transport.ErrorCondition condition)

Specified by:

onClose in interface IAmqpLink

getContext

public com.microsoft.azure.servicebus.primitives.ErrorContext getContext()

onClose

protected CompletableFuture<Void> onClose()

Specified by:

onClose in class ClientEntity

completeMessageAsync

public CompletableFuture<Void> completeMessageAsync(byte[] deliveryTag,
                                                    TransactionContext transaction)

completeMessageAsync

public CompletableFuture<Void> completeMessageAsync(UUID lockToken,
                                                    TransactionContext transaction)

abandonMessageAsync

public CompletableFuture<Void> abandonMessageAsync(byte[] deliveryTag,
                                                   Map<String,Object> propertiesToModify,
                                                   TransactionContext transaction)

abandonMessageAsync

public CompletableFuture<Void> abandonMessageAsync(UUID lockToken,
                                                   Map<String,Object> propertiesToModify,
                                                   TransactionContext transaction)

deferMessageAsync

public CompletableFuture<Void> deferMessageAsync(byte[] deliveryTag,
                                                 Map<String,Object> propertiesToModify,
                                                 TransactionContext transaction)

deferMessageAsync

public CompletableFuture<Void> deferMessageAsync(UUID lockToken,
                                                 Map<String,Object> propertiesToModify,
                                                 TransactionContext transaction)

deadLetterMessageAsync

public CompletableFuture<Void> deadLetterMessageAsync(byte[] deliveryTag,
                                                      String deadLetterReason,
                                                      String deadLetterErrorDescription,
                                                      Map<String,Object> propertiesToModify,
                                                      TransactionContext transaction)

deadLetterMessageAsync

public CompletableFuture<Void> deadLetterMessageAsync(UUID lockToken,
                                                      String deadLetterReason,
                                                      String deadLetterErrorDescription,
                                                      Map<String,Object> propertiesToModify,
                                                      TransactionContext transaction)

renewMessageLocksAsync

public CompletableFuture<Collection<Instant>> renewMessageLocksAsync(UUID[] lockTokens)

receiveDeferredMessageBatchAsync

public CompletableFuture<Collection<MessageWithLockToken>> receiveDeferredMessageBatchAsync(Long[] sequenceNumbers)

updateDispositionAsync

public CompletableFuture<Void> updateDispositionAsync(UUID[] lockTokens,
                                                      String dispositionStatus,
                                                      String deadLetterReason,
                                                      String deadLetterErrorDescription,
                                                      Map<String,Object> propertiesToModify,
                                                      TransactionContext transaction)

renewSessionLocksAsync

public CompletableFuture<Void> renewSessionLocksAsync()

getSessionStateAsync

public CompletableFuture<byte[]> getSessionStateAsync()

setSessionStateAsync

public CompletableFuture<Void> setSessionStateAsync(byte[] sessionState)

peekMessagesAsync

public CompletableFuture<Collection<org.apache.qpid.proton.message.Message>> peekMessagesAsync(long fromSequenceNumber,
                                                                                               int messageCount,
                                                                                               String sessionId)