|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageId | |
---|---|
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.kaha | fast message persistence implementation |
org.apache.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.apache.activemq.store.amq | The default Store implementation for ActiveMQ |
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.kahadb | |
org.apache.activemq.store.memory | VM based implementation of message persistence |
Uses of MessageId in org.apache.activemq |
---|
Methods in org.apache.activemq with parameters of type MessageId | |
---|---|
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 |
---|
Fields in org.apache.activemq.broker.region with type parameters of type MessageId | |
---|---|
protected java.util.Map<MessageId,java.lang.Runnable> |
Queue.messagesWaitingForSpace
|
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.broker.region.cursors |
---|
Methods in org.apache.activemq.broker.region.cursors with parameters of type MessageId | |
---|---|
boolean |
AbstractPendingMessageCursor.isDuplicate(MessageId messageId)
|
boolean |
AbstractPendingMessageCursor.recordUniqueId(MessageId messageId)
records a message id and checks if it is a duplicate |
void |
PendingMessageCursor.rollback(MessageId id)
remove from auditing the message id |
void |
AbstractPendingMessageCursor.rollback(MessageId id)
|
protected void |
AbstractStoreCursor.setBatch(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 |
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()
|
MessageId |
Message.getMessageId()
|
MessageId |
MessageDispatchNotification.getMessageId()
|
Methods in org.apache.activemq.command with parameters of type MessageId | |
---|---|
int |
MessageId.compareTo(MessageId other)
|
void |
MessageAck.setFirstMessageId(MessageId firstMessageId)
|
void |
MessageAck.setLastMessageId(MessageId lastMessageId)
|
void |
MessagePull.setMessageId(MessageId messageId)
|
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.kaha |
---|
Methods in org.apache.activemq.kaha that return MessageId | |
---|---|
MessageId |
MessageIdMarshaller.readPayload(java.io.DataInput dataIn)
Read the entry from the RawContainer |
Methods in org.apache.activemq.kaha with parameters of type MessageId | |
---|---|
void |
MessageIdMarshaller.writePayload(MessageId object,
java.io.DataOutput dataOut)
Write the payload of this entry to the RawContainer |
Uses of MessageId in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store with parameters of type MessageId | |
---|---|
void |
TopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.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 |
void |
ProxyTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
boolean |
TopicReferenceStore.acknowledgeReference(ConnectionContext context,
java.lang.String clientId,
java.lang.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 |
ProxyTopicMessageStore.getMessage(MessageId identity)
|
Message |
ProxyMessageStore.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 |
ReferenceStore.setBatch(MessageId startAfter)
|
void |
MessageStore.setBatch(MessageId messageId)
allow caching cursors to set the current batch offset when cache is exhausted |
void |
AbstractMessageStore.setBatch(MessageId messageId)
|
void |
ProxyTopicMessageStore.setBatch(MessageId messageId)
|
void |
ProxyMessageStore.setBatch(MessageId messageId)
|
Uses of MessageId in org.apache.activemq.store.amq |
---|
Methods in org.apache.activemq.store.amq with parameters of type MessageId | |
---|---|
protected void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
MessageId messageId,
Location location,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck originalAck)
|
void |
AMQMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
protected Location |
AMQMessageStore.getLocation(MessageId messageId)
|
Message |
AMQMessageStore.getMessage(MessageId identity)
|
java.lang.String |
AMQMessageStore.getMessageReference(MessageId identity)
|
boolean |
AMQTopicMessageStore.replayAcknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscritionName,
MessageId messageId)
|
void |
AMQMessageStore.setBatch(MessageId messageId)
|
Uses of MessageId in org.apache.activemq.store.jdbc |
---|
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,
MessageAck ack)
|
void |
JDBCMessageStore.addMessageReference(ConnectionContext context,
MessageId messageId,
long expirationTime,
java.lang.String messageRef)
|
void |
JDBCAdapter.doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority)
|
void |
JDBCAdapter.doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageId,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
byte[] |
JDBCAdapter.doGetMessage(TransactionContext c,
MessageId id)
|
Message |
JDBCMessageStore.getMessage(MessageId messageId)
|
java.lang.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 | |
---|---|
void |
DefaultJDBCAdapter.doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority)
|
void |
DefaultJDBCAdapter.doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef)
|
byte[] |
DefaultJDBCAdapter.doGetMessage(TransactionContext c,
MessageId id)
|
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 | |
---|---|
void |
JournalTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.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,
java.lang.String messageRef)
|
Message |
JournalMessageStore.getMessage(MessageId identity)
|
java.lang.String |
JournalMessageStore.getMessageReference(MessageId identity)
|
void |
JournalTopicMessageStore.replayAcknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscritionName,
MessageId messageId)
|
void |
JournalMessageStore.setBatch(MessageId messageId)
|
Uses of MessageId in org.apache.activemq.store.kahadaptor |
---|
Fields in org.apache.activemq.store.kahadaptor with type parameters of type MessageId | |
---|---|
protected MapContainer<MessageId,ReferenceRecord> |
KahaReferenceStore.messageContainer
|
protected MapContainer<MessageId,Message> |
KahaMessageStore.messageContainer
|
Methods in org.apache.activemq.store.kahadaptor that return MessageId | |
---|---|
MessageId |
ConsumerMessageRef.getMessageId()
|
protected MessageId |
KahaTopicReferenceStore.getMessageId(java.lang.Object object)
|
protected MessageId |
KahaReferenceStore.getMessageId(java.lang.Object object)
|
protected MessageId |
KahaMessageStore.getMessageId(java.lang.Object object)
|
MessageId |
KahaMessageStore.getPreviousMessageIdToDeliver(MessageId id)
|
Methods in org.apache.activemq.store.kahadaptor that return types with arguments of type MessageId | |
---|---|
protected MapContainer<MessageId,Message> |
KahaPersistenceAdapter.getMapContainer(java.lang.Object id,
java.lang.String containerName)
|
protected MapContainer<MessageId,ReferenceRecord> |
KahaReferenceStoreAdapter.getMapReferenceContainer(java.lang.Object id,
java.lang.String containerName)
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type MessageId | |
---|---|
void |
KahaTopicReferenceStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
KahaTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
boolean |
KahaTopicReferenceStore.acknowledgeReference(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId)
|
boolean |
KahaTopicReferenceStore.addMessageReference(ConnectionContext context,
MessageId messageId,
ReferenceStore.ReferenceData data)
|
boolean |
KahaReferenceStore.addMessageReference(ConnectionContext context,
MessageId messageId,
ReferenceStore.ReferenceData data)
|
Message |
KahaTopicReferenceStore.getMessage(MessageId identity)
|
Message |
KahaReferenceStore.getMessage(MessageId identity)
|
Message |
KahaMessageStore.getMessage(MessageId identity)
|
ReferenceStore.ReferenceData |
KahaTopicReferenceStore.getMessageReference(MessageId identity)
|
ReferenceStore.ReferenceData |
KahaReferenceStore.getMessageReference(MessageId identity)
|
MessageId |
KahaMessageStore.getPreviousMessageIdToDeliver(MessageId id)
|
protected boolean |
KahaReferenceStore.isDuplicate(MessageId messageId)
|
ConsumerMessageRef |
TopicSubContainer.remove(MessageId id)
|
void |
KahaMessageStore.removeMessage(MessageId msgId)
|
void |
KahaReferenceStore.setBatch(MessageId startAfter)
|
void |
KahaMessageStore.setBatch(MessageId messageId)
|
void |
ConsumerMessageRef.setMessageId(MessageId messageId)
|
Constructor parameters in org.apache.activemq.store.kahadaptor with type arguments of type MessageId | |
---|---|
KahaMessageStore(MapContainer<MessageId,Message> container,
ActiveMQDestination destination)
|
|
KahaReferenceStore(KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> container,
ActiveMQDestination destination)
|
|
KahaTopicMessageStore(Store store,
MapContainer<MessageId,Message> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<java.lang.String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination)
|
|
KahaTopicReferenceStore(Store store,
KahaReferenceStoreAdapter adapter,
MapContainer<MessageId,ReferenceRecord> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<java.lang.String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination)
|
Uses of MessageId in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb with parameters of type MessageId | |
---|---|
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 | |
---|---|
protected MessageId |
MemoryMessageStore.lastBatchId
|
Fields in org.apache.activemq.store.memory with type parameters of type MessageId | |
---|---|
protected java.util.Map<MessageId,Message> |
MemoryMessageStore.messageTable
|
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,
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 | |
---|---|
MemoryMessageStore(ActiveMQDestination destination,
java.util.Map<MessageId,Message> messageTable)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination,
java.util.Map<MessageId,Message> messageTable,
java.util.Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |