|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageId | |
---|---|
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
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.kahadaptor | kaha implementation of message persistence for the broker |
org.apache.activemq.store.memory | VM based implementation of message persistence |
org.apache.activemq.store.rapid |
Uses of MessageId in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return MessageId | |
---|---|
MessageId |
MessageReference.getMessageId()
|
MessageId |
IndirectMessageReference.getMessageId()
|
Methods in org.apache.activemq.broker.region with parameters of type MessageId | |
---|---|
Message |
Topic.loadMessage(MessageId messageId)
|
Uses of MessageId in org.apache.activemq.command |
---|
Fields in org.apache.activemq.command declared as MessageId | |
---|---|
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 | |
---|---|
MessageId |
MessageId.copy()
|
MessageId |
MessageAck.getFirstMessageId()
|
MessageId |
MessageAck.getLastMessageId()
|
MessageId |
JournalTopicAck.getMessageId()
|
MessageId |
Message.getMessageId()
|
MessageId |
MessageDispatchNotification.getMessageId()
|
Methods in org.apache.activemq.command with parameters of type MessageId | |
---|---|
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 |
MessageAck.setMessageID(MessageId messageID)
A helper method to allow a single message ID to be acknowledged |
Uses of MessageId in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store that return MessageId | |
---|---|
MessageId |
ProxyTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
TopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the next messageId to deliver to a subscriber after the MessageId provided |
MessageId |
ProxyTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
TopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the previous messageId to deliver to a subscriber before the MessageId provided |
Methods in org.apache.activemq.store with parameters of type MessageId | |
---|---|
void |
ProxyTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
TopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint |
void |
ProxyTopicMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
ProxyMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
MessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
Adds a message reference to the message store |
Message |
ProxyTopicMessageStore.getMessage(MessageId identity)
|
Message |
ProxyMessageStore.getMessage(MessageId identity)
|
Message |
MessageStore.getMessage(MessageId identity)
Looks up a message using either the String messageID or the messageNumber. |
java.lang.String |
ProxyTopicMessageStore.getMessageReference(MessageId identity)
|
java.lang.String |
ProxyMessageStore.getMessageReference(MessageId identity)
|
java.lang.String |
MessageStore.getMessageReference(MessageId identity)
Looks up a message using either the String messageID or the messageNumber. |
MessageId |
ProxyTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
TopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the next messageId to deliver to a subscriber after the MessageId provided |
MessageId |
ProxyTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
TopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the previous messageId to deliver to a subscriber before the MessageId provided |
void |
ProxyTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
TopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
For an active subscription - retrieve messages from the store for the subscriber after the lastMessageId messageId |
void |
ProxyTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
void |
TopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId nextToDispatch)
A hint to the Store to reset any batching state for a durable subsriber |
Uses of MessageId in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc that return MessageId | |
---|---|
MessageId |
JDBCTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
JDBCTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Methods in org.apache.activemq.store.jdbc with parameters of type MessageId | |
---|---|
void |
JDBCTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
JDBCMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
JDBCAdapter.doAddMessage(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration)
|
void |
JDBCAdapter.doAddMessageReference(TransactionContext c,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
long |
JDBCAdapter.getBrokerSequenceId(TransactionContext c,
MessageId messageID)
|
Message |
JDBCMessageStore.getMessage(MessageId messageId)
|
java.lang.String |
JDBCMessageStore.getMessageReference(MessageId messageId)
|
MessageId |
JDBCTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
JDBCTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
void |
JDBCTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
JDBCTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Uses of MessageId in org.apache.activemq.store.jdbc.adapter |
---|
Methods in org.apache.activemq.store.jdbc.adapter with parameters of type MessageId | |
---|---|
void |
DefaultJDBCAdapter.doAddMessage(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration)
|
void |
DefaultJDBCAdapter.doAddMessageReference(TransactionContext c,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
long |
DefaultJDBCAdapter.getBrokerSequenceId(TransactionContext c,
MessageId messageID)
|
Uses of MessageId in org.apache.activemq.store.journal |
---|
Fields in org.apache.activemq.store.journal declared as MessageId | |
---|---|
MessageId |
QuickJournalMessageData.messageId
|
Methods in org.apache.activemq.store.journal that return MessageId | |
---|---|
MessageId |
QuickJournalMessageData.getMessageId()
|
MessageId |
JournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
QuickJournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
JournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
QuickJournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Methods in org.apache.activemq.store.journal with parameters of type MessageId | |
---|---|
void |
JournalTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
QuickJournalTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
JournalMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
QuickJournalMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
Message |
JournalMessageStore.getMessage(MessageId identity)
|
Message |
QuickJournalMessageStore.getMessage(MessageId identity)
|
java.lang.String |
JournalMessageStore.getMessageReference(MessageId identity)
|
java.lang.String |
QuickJournalMessageStore.getMessageReference(MessageId identity)
|
MessageId |
JournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
QuickJournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
JournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
QuickJournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
void |
JournalTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
QuickJournalTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
JournalTopicMessageStore.replayAcknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscritionName,
MessageId messageId)
|
void |
QuickJournalTopicMessageStore.replayAcknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscritionName,
MessageId messageId)
|
void |
JournalTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId nextToDispatch)
|
void |
QuickJournalTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId nextId)
|
Uses of MessageId in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor that return MessageId | |
---|---|
MessageId |
KahaTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
KahaTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type MessageId | |
---|---|
void |
KahaTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
KahaMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
KahaTopicMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
Message |
KahaMessageStore.getMessage(MessageId identity)
|
Message |
KahaTopicMessageStore.getMessage(MessageId identity)
|
java.lang.String |
KahaMessageStore.getMessageReference(MessageId identity)
|
java.lang.String |
KahaTopicMessageStore.getMessageReference(MessageId identity)
|
MessageId |
KahaTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
KahaTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
void |
KahaTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
KahaMessageStore.removeMessage(MessageId msgId)
|
void |
KahaTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId nextToDispatch)
|
Uses of MessageId in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory that return MessageId | |
---|---|
MessageId |
MemoryTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
MemoryTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Methods in org.apache.activemq.store.memory with parameters of type MessageId | |
---|---|
void |
MemoryTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
MemoryMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
Message |
MemoryMessageStore.getMessage(MessageId identity)
|
java.lang.String |
MemoryMessageStore.getMessageReference(MessageId identity)
|
MessageId |
MemoryTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
MessageId |
MemoryTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
void |
MemoryTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
MemoryMessageStore.removeMessage(MessageId msgId)
|
void |
MemoryTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
|
Uses of MessageId in org.apache.activemq.store.rapid |
---|
Fields in org.apache.activemq.store.rapid declared as MessageId | |
---|---|
MessageId |
RapidMessageReference.messageId
|
Methods in org.apache.activemq.store.rapid that return MessageId | |
---|---|
MessageId |
RapidMessageReference.getMessageId()
|
MessageId |
RapidTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
MessageId |
RapidTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
Methods in org.apache.activemq.store.rapid with parameters of type MessageId | |
---|---|
void |
RapidTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
RapidMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
Message |
RapidMessageStore.getMessage(MessageId id)
|
java.lang.String |
RapidMessageStore.getMessageReference(MessageId identity)
|
MessageId |
RapidTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
MessageId |
RapidTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
void |
RapidTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
|
void |
RapidTopicMessageStore.replayAcknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscritionName,
MessageId messageId)
|
void |
RapidTopicMessageStore.resetBatching(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId nextId)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |