CoreMessageReceiver Class

定义

public class CoreMessageReceiver extends ClientEntity
继承
java.lang.Object
CoreMessageReceiver

继承成员

方法

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 int prefetchCount, final SettleModePair settleModePair, final MessagingEntityType entityType)
create(final MessagingFactory factory, final String name, final String recvPath, final String sessionId, final boolean isBrowsableSession, 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, final MessagingEntityType entityType)
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)

适用于