public interface MessageInstance
Modifier and Type | Interface and Description |
---|---|
static class |
MessageInstance.AvailableState |
static class |
MessageInstance.ConsumerAcquiredState<C extends ConsumerImpl> |
static class |
MessageInstance.DeletedState |
static class |
MessageInstance.DequeuedState |
static class |
MessageInstance.EntryState |
static class |
MessageInstance.LockedAcquiredState<C extends ConsumerImpl> |
static class |
MessageInstance.NonConsumerAcquiredState |
static class |
MessageInstance.State |
Modifier and Type | Field and Description |
---|---|
static MessageInstance.EntryState |
AVAILABLE_STATE |
static MessageInstance.EntryState |
DELETED_STATE |
static MessageInstance.EntryState |
DEQUEUED_STATE |
static MessageInstance.EntryState |
NON_CONSUMER_ACQUIRED_STATE |
static final MessageInstance.EntryState AVAILABLE_STATE
static final MessageInstance.EntryState DELETED_STATE
static final MessageInstance.EntryState DEQUEUED_STATE
static final MessageInstance.EntryState NON_CONSUMER_ACQUIRED_STATE
int getDeliveryCount()
void incrementDeliveryCount()
void decrementDeliveryCount()
void addStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)
boolean removeStateChangeListener(StateChangeListener<? super MessageInstance,MessageInstance.State> listener)
boolean acquiredByConsumer()
boolean isAcquiredBy(ConsumerImpl consumer)
boolean removeAcquisitionFromConsumer(ConsumerImpl consumer)
void setRedelivered()
boolean isRedelivered()
ConsumerImpl getDeliveredConsumer()
void reject()
boolean isRejectedBy(ConsumerImpl consumer)
boolean getDeliveredToConsumer()
boolean expired()
boolean acquire(ConsumerImpl sub)
boolean lockAcquisition(ConsumerImpl consumer)
boolean unlockAcquisition()
int getMaximumDeliveryCount()
int routeToAlternate(Action<? super MessageInstance> action, ServerTransaction txn)
Filterable asFilterable()
ConsumerImpl getAcquiringConsumer()
MessageEnqueueRecord getEnqueueRecord()
boolean isAvailable()
boolean acquire()
boolean isAcquired()
void release()
void release(ConsumerImpl release)
boolean resend()
void delete()
boolean isDeleted()
ServerMessage getMessage()
InstanceProperties getInstanceProperties()
TransactionLogResource getOwningResource()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.