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

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.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
 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)
           
 

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

Methods in org.apache.activemq.broker.region that return MessageId
 MessageId IndirectMessageReference.getMessageId()
           
 MessageId MessageReference.getMessageId()
           
 

Methods in org.apache.activemq.broker.region with parameters of type MessageId
 boolean QueueBrowserSubscription.isDuplicate(MessageId 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 MessageDispatchNotification.messageId
           
protected  MessageId Message.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 MessageDispatchNotification.getMessageId()
           
 MessageId Message.getMessageId()
           
 MessageId JournalTopicAck.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 MessageDispatchNotification.setMessageId(MessageId messageId)
           
 void Message.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
 

Uses of MessageId in org.apache.activemq.store
 

Methods in org.apache.activemq.store with parameters of type MessageId
 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
 void ProxyTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 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 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.
 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 ProxyTopicMessageStore.setBatch(MessageId messageId)
           
 void ProxyMessageStore.setBatch(MessageId messageId)
           
 void MessageStore.setBatch(MessageId messageId)
          allow caching cursors to set the current batch offset when cache is exhausted
 void AbstractMessageStore.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, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void JdbcMemoryTransactionStore.acknowledge(TopicMessageStore topicMessageStore, 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)
           
 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)
           
 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)
           
protected  void JDBCTopicMessageStore.onAdd(MessageId messageId, long sequenceId, byte priority)
           
protected  void JDBCMessageStore.onAdd(MessageId messageId, long sequenceId, byte priority)
           
 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, XATransactionId xid)
          A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
 void BlobJDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority, XATransactionId xid)
           
 void DefaultJDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, long expirationTime, String messageRef)
           
 byte[] DefaultJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
           
 byte[] BlobJDBCAdapter.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, 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
 Message TempKahaDBStore.KahaDBMessageStore.getMessage(MessageId identity)
           
 Message KahaDBStore.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 TempKahaDBStore.KahaDBMessageStore.setBatch(MessageId identity)
           
 void KahaDBStore.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  Map<MessageId,Message> MemoryMessageStore.messageTable
           
 

Methods in org.apache.activemq.store.memory with parameters of type MessageId
 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
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
protected  LinkedHashMap<MessageId,MessageDispatch> StompSubscription.dispatchedMessage
           
 



Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.