Uses of Class
org.apache.activemq.command.MessageId

Packages that use MessageId

Package	Description
org.apache.activemq	The core JMS client API implementation classes.
org.apache.activemq.broker.region	Region abstraction and implementations in the Broker.
org.apache.activemq.broker.region.cursors	Cursors used to page persistent messages into the broker from the store
org.apache.activemq.command	Command objects used via the Command Pattern to communicate among nodes
org.apache.activemq.network	Support for federated networks of brokers.
org.apache.activemq.store	The APIs which need to be implemented for persistent message stores for durable messaging
org.apache.activemq.store.jdbc	Message persistence implemented using JDBC
org.apache.activemq.store.jdbc.adapter	Implements database/driver apapters to compensate for the wide differences in the BLOB handing of JDBC drivers.
org.apache.activemq.store.journal	Message persistence using a high performance transaction log via the Journal interface.
org.apache.activemq.store.kahadb
org.apache.activemq.store.memory	VM based implementation of message persistence
org.apache.activemq.transport.stomp	An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc.

Uses of MessageId in org.apache.activemq

Methods in org.apache.activemq with parameters of type MessageId

Modifier and Type	Method	Description
boolean	ActiveMQMessageAudit.isDuplicate(MessageId id)
boolean	ActiveMQMessageAuditNoSync.isDuplicate(MessageId id)	Checks if this messageId has been seen before
boolean	ActiveMQMessageAudit.isInOrder(MessageId id)
boolean	ActiveMQMessageAuditNoSync.isInOrder(MessageId id)	Check the MessageId is in order
void	ActiveMQMessageAudit.rollback(MessageId id)
void	ActiveMQMessageAuditNoSync.rollback(MessageId id)	mark this message as being received

Uses of MessageId in org.apache.activemq.broker.region

Methods in org.apache.activemq.broker.region that return MessageId

Modifier and Type	Method	Description
MessageId	IndirectMessageReference.getMessageId()
MessageId	MessageReference.getMessageId()
MessageId	NullMessageReference.getMessageId()

Methods in org.apache.activemq.broker.region with parameters of type MessageId

Modifier and Type	Method	Description
boolean	QueueBrowserSubscription.isDuplicate(MessageId messageId)
Message	Topic.loadMessage(MessageId messageId)
void	Queue.rollbackPendingCursorAdditions(MessageId messageId)

Uses of MessageId in org.apache.activemq.broker.region.cursors

Methods in org.apache.activemq.broker.region.cursors with parameters of type MessageId

Modifier and Type	Method	Description
MessageReference	OrderedPendingList.get(MessageId messageId)
MessageReference	PendingList.get(MessageId messageId)
MessageReference	PrioritizedPendingList.get(MessageId messageId)
MessageReference	QueueDispatchPendingList.get(MessageId messageId)
boolean	AbstractPendingMessageCursor.isDuplicate(MessageId messageId)
boolean	AbstractPendingMessageCursor.recordUniqueId(MessageId messageId)	records a message id and checks if it is a duplicate
void	AbstractPendingMessageCursor.rollback(MessageId id)
void	PendingMessageCursor.rollback(MessageId id)	remove from auditing the message id
void	StoreQueueCursor.rollback(MessageId id)
protected void	AbstractStoreCursor.setBatch(MessageId messageId)

Constructor parameters in org.apache.activemq.broker.region.cursors with type arguments of type MessageId

Constructor	Description
PendingMessageHelper(Map<MessageId,PendingNode> map, SizeStatisticImpl messageSize)

Uses of MessageId in org.apache.activemq.command

Fields in org.apache.activemq.command declared as MessageId

Modifier and Type	Field	Description
protected MessageId	MessageAck.firstMessageId
protected MessageId	MessageAck.lastMessageId
protected MessageId	Message.messageId
protected MessageId	MessageDispatchNotification.messageId

Methods in org.apache.activemq.command that return MessageId

Modifier and Type	Method	Description
MessageId	MessageId.copy()
MessageId	MessageAck.getFirstMessageId()
MessageId	MessageAck.getLastMessageId()
MessageId	JournalTopicAck.getMessageId()
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

Methods in org.apache.activemq.command with parameters of type MessageId

Modifier and Type	Method	Description
int	MessageId.compareTo(MessageId other)
void	MessageAck.setFirstMessageId(MessageId firstMessageId)
void	MessageAck.setLastMessageId(MessageId lastMessageId)
void	JournalTopicAck.setMessageId(MessageId messageId)
void	Message.setMessageId(MessageId messageId)
void	MessageDispatchNotification.setMessageId(MessageId messageId)
void	MessagePull.setMessageId(MessageId messageId)
void	MessageAck.setMessageID(MessageId messageID)	A helper method to allow a single message ID to be acknowledged

Uses of MessageId in org.apache.activemq.network

Methods in org.apache.activemq.network with parameters of type MessageId

Modifier and Type	Method	Description
protected long	DemandForwardingBridgeSupport.getStoredSequenceIdForMessage(MessageId messageId)

Uses of MessageId in org.apache.activemq.store

Methods in org.apache.activemq.store with parameters of type MessageId

Modifier and Type	Method	Description
void	ProxyTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
void	TopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)	Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint
boolean	TopicReferenceStore.acknowledgeReference(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)	Removes the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint N.B.
boolean	ReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)	Adds a message reference to the message store
Message	MessageStore.getMessage(MessageId identity)	Looks up a message using either the String messageID or the messageNumber.
Message	ProxyMessageStore.getMessage(MessageId identity)
Message	ProxyTopicMessageStore.getMessage(MessageId identity)
ReferenceStore.ReferenceData	ReferenceStore.getMessageReference(MessageId identity)	Looks up a message using either the String messageID or the messageNumber.
boolean	MessageRecoveryListener.isDuplicate(MessageId ref)	check if ref is a duplicate but do not record the reference
boolean	MessageRecoveryListener.recoverMessageReference(MessageId ref)
void	AbstractMessageStore.setBatch(MessageId messageId)
void	MessageStore.setBatch(MessageId messageId)	allow caching cursors to set the current batch offset when cache is exhausted
void	ProxyMessageStore.setBatch(MessageId messageId)
void	ProxyTopicMessageStore.setBatch(MessageId messageId)
void	ReferenceStore.setBatch(MessageId startAfter)

Uses of MessageId in org.apache.activemq.store.jdbc

Methods in org.apache.activemq.store.jdbc with parameters of type MessageId

Modifier and Type	Method	Description
void	JdbcMemoryTransactionStore.acknowledge(TopicMessageStore topicMessageStore, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
void	JDBCTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
void	JDBCMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
void	JDBCPersistenceAdapter.commitAdd(ConnectionContext context, MessageId messageId, long preparedSequenceId, long newSequence)
void	JDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	JDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef)
byte[]	JDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
void	JDBCAdapter.doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data)
long[]	JDBCTopicMessageStore.getCachedStoreSequenceId(TransactionContext transactionContext, ActiveMQDestination destination, MessageId messageId)
Message	JDBCMessageStore.getMessage(MessageId messageId)
String	JDBCMessageStore.getMessageReference(MessageId messageId)
long[]	JDBCAdapter.getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)
void	JDBCMessageIdScanListener.messageId(MessageId id)
void	JDBCMessageStore.setBatch(MessageId messageId)

Uses of MessageId in org.apache.activemq.store.jdbc.adapter

Methods in org.apache.activemq.store.jdbc.adapter with parameters of type MessageId

Modifier and Type	Method	Description
void	BlobJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
void	DefaultJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)	A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
void	DefaultJDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, long expirationTime, String messageRef)
byte[]	BlobJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
byte[]	DefaultJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
void	DefaultJDBCAdapter.doUpdateMessage(TransactionContext c, ActiveMQDestination destination, MessageId id, byte[] data)
long[]	DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID)

Uses of MessageId in org.apache.activemq.store.journal

Methods in org.apache.activemq.store.journal with parameters of type MessageId

Modifier and Type	Method	Description
void	JournalTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck originalAck)
protected void	JournalTopicMessageStore.acknowledge(MessageId messageId, org.apache.activeio.journal.RecordLocation location, SubscriptionKey key)
void	JournalMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
Message	JournalMessageStore.getMessage(MessageId identity)
String	JournalMessageStore.getMessageReference(MessageId identity)
void	JournalTopicMessageStore.replayAcknowledge(ConnectionContext context, String clientId, String subscritionName, MessageId messageId)
void	JournalMessageStore.setBatch(MessageId messageId)

Uses of MessageId in org.apache.activemq.store.kahadb

Methods in org.apache.activemq.store.kahadb with parameters of type MessageId

Modifier and Type	Method	Description
Message	KahaDBStore.KahaDBMessageStore.getMessage(MessageId identity)
Message	TempKahaDBStore.KahaDBMessageStore.getMessage(MessageId identity)
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask	KahaDBStore.removeQueueTask(KahaDBStore.KahaDBMessageStore store, MessageId id)
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask	KahaDBStore.removeTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store, MessageId id)
void	KahaDBStore.KahaDBMessageStore.setBatch(MessageId identity)
void	TempKahaDBStore.KahaDBMessageStore.setBatch(MessageId identity)

Uses of MessageId in org.apache.activemq.store.memory

Fields in org.apache.activemq.store.memory declared as MessageId

Modifier and Type	Field	Description
protected MessageId	MemoryMessageStore.lastBatchId

Fields in org.apache.activemq.store.memory with type parameters of type MessageId

Modifier and Type	Field	Description
protected Map<MessageId,Message>	MemoryMessageStore.messageTable

Methods in org.apache.activemq.store.memory with parameters of type MessageId

Modifier and Type	Method	Description
void	MemoryTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
void	MemoryTransactionStore.acknowledge(TopicMessageStore destination, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
Message	MemoryMessageStore.getMessage(MessageId identity)
void	MemoryMessageStore.removeMessage(MessageId msgId)
void	MemoryMessageStore.setBatch(MessageId messageId)

Constructor parameters in org.apache.activemq.store.memory with type arguments of type MessageId

Constructor	Description
MemoryMessageStore(ActiveMQDestination destination, Map<MessageId,Message> messageTable)
MemoryTopicMessageStore(ActiveMQDestination destination, Map<MessageId,Message> messageTable, Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase)

Uses of MessageId in org.apache.activemq.transport.stomp

Fields in org.apache.activemq.transport.stomp with type parameters of type MessageId

Modifier and Type	Field	Description
protected Map<MessageId,StompAckEntry>	StompSubscription.dispatchedMessage

Methods in org.apache.activemq.transport.stomp that return MessageId

Modifier and Type	Method	Description
MessageId	StompAckEntry.getMessageId()