Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.broker.region | |
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
Modifier and Type | Method and Description |
---|---|
boolean |
ActiveMQMessageAuditNoSync.isDuplicate(MessageId id)
Checks if this messageId has been seen before
|
boolean |
ActiveMQMessageAudit.isDuplicate(MessageId id) |
boolean |
ActiveMQMessageAuditNoSync.isInOrder(MessageId id)
Check the MessageId is in order
|
boolean |
ActiveMQMessageAudit.isInOrder(MessageId id) |
void |
ActiveMQMessageAuditNoSync.rollback(MessageId id)
mark this message as being received
|
void |
ActiveMQMessageAudit.rollback(MessageId id) |
Modifier and Type | Method and Description |
---|---|
MessageId |
MessageReference.getMessageId() |
Modifier and Type | Field and Description |
---|---|
protected MessageId |
MessageAck.firstMessageId |
protected MessageId |
MessageAck.lastMessageId |
protected MessageId |
Message.messageId |
protected MessageId |
MessageDispatchNotification.messageId |
Modifier and Type | Method and Description |
---|---|
MessageId |
MessageId.copy() |
MessageId |
MessageAck.getFirstMessageId() |
MessageId |
MessageAck.getLastMessageId() |
MessageId |
Message.getMessageId() |
MessageId |
MessageDispatchNotification.getMessageId() |
MessageId |
MessagePull.getMessageId()
An optional message ID which could be used by a broker to decide which messages are pulled
on demand from a queue for a consumer
|
MessageId |
JournalTopicAck.getMessageId() |
Modifier and Type | Method and Description |
---|---|
int |
MessageId.compareTo(MessageId other) |
void |
MessageAck.setFirstMessageId(MessageId firstMessageId) |
void |
MessageAck.setLastMessageId(MessageId lastMessageId) |
void |
Message.setMessageId(MessageId messageId) |
void |
MessageDispatchNotification.setMessageId(MessageId messageId) |
void |
MessagePull.setMessageId(MessageId messageId) |
void |
JournalTopicAck.setMessageId(MessageId messageId) |
void |
MessageAck.setMessageID(MessageId messageID)
A helper method to allow a single message ID to be acknowledged
|
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.