CoreMessageReceiver Class

Definition

public class CoreMessageReceiver extends ClientEntity
Inheritance
java.lang.Object
CoreMessageReceiver

Inherited Members

Methods

abandonMessageAsync(byte[] deliveryTag, Map<String, Object> propertiesToModify)
abandonMessageAsync(UUID lockToken, Map<String, Object> propertiesToModify)
completeMessageAsync(byte[] deliveryTag)
completeMessageAsync(UUID lockToken)
create(final MessagingFactory factory, final String name, final String recvPath, final int prefetchCount, final SettleModePair settleModePair)
create(final MessagingFactory factory, final String name, final String recvPath, final String sessionId, final boolean isBrowsableSession, final int prefetchCount, final SettleModePair settleModePair)
deadLetterMessageAsync(byte[] deliveryTag, String deadLetterReason, String deadLetterErrorDescription, Map<String, Object> propertiesToModify)
deadLetterMessageAsync(UUID lockToken, String deadLetterReason, String deadLetterErrorDescription, Map<String, Object> propertiesToModify)
deferMessageAsync(byte[] deliveryTag, Map<String, Object> propertiesToModify)
deferMessageAsync(UUID lockToken, Map<String, Object> propertiesToModify)
getContext()
getPrefetchCount()
getSessionId()
getSessionLockedUntilUtc()
getSessionStateAsync()
onClose()
onClose(ErrorCondition condition)
onError(ErrorCondition error)
onError(Exception exception)
onOpenComplete(Exception exception)
onReceiveComplete(Delivery delivery)
peekMessagesAsync(long fromSequenceNumber, int messageCount, String sessionId)
receiveAsync(final int maxMessageCount, Duration timeout)
receiveDeferredMessageBatchAsync(Long[] sequenceNumbers)
renewMessageLocksAsync(UUID[] lockTokens)
renewSessionLocksAsync()
setPrefetchCount(final int value)
setSessionStateAsync(byte[] sessionState)
updateDispositionAsync(UUID[] lockTokens, String dispositionStatus, String deadLetterReason, String deadLetterErrorDescription, Map<String, Object> propertiesToModify)