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.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)
          Checks if this messageId has been seen before
 boolean ActiveMQMessageAudit.isInOrder(MessageId id)
          Check the MessageId is in order
 void ActiveMQMessageAudit.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  Map<MessageId,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 Message.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 MessageDispatchNotification.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 Message.setMessageId(MessageId messageId)
           
 void MessagePull.setMessageId(MessageId messageId)
           
 void MessageDispatchNotification.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.kaha
 

Methods in org.apache.activemq.kaha that return MessageId
 MessageId MessageIdMarshaller.readPayload(DataInput dataIn)
          Read the entry from the RawContainer
 

Methods in org.apache.activemq.kaha with parameters of type MessageId
 void MessageIdMarshaller.writePayload(MessageId object, 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, String clientId, 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.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 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 MessageStore.setBatch(MessageId messageId)
          allow caching cursors to set the current batch offset when cache is exhausted
 void ReferenceStore.setBatch(MessageId startAfter)
           
 void AbstractMessageStore.setBatch(MessageId messageId)
           
 void ProxyMessageStore.setBatch(MessageId messageId)
           
 void ProxyTopicMessageStore.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, String clientId, String subscriptionName)
           
 void AMQTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 void AMQMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
           
protected  Location AMQMessageStore.getLocation(MessageId messageId)
           
 Message AMQMessageStore.getMessage(MessageId identity)
           
 String AMQMessageStore.getMessageReference(MessageId identity)
           
 boolean AMQTopicMessageStore.replayAcknowledge(ConnectionContext context, String clientId, 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, String clientId, String subscriptionName, MessageId messageId)
           
 void JDBCMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, String messageRef)
           
 void JDBCAdapter.doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration)
           
 void JDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageId, ActiveMQDestination destination, long expirationTime, String messageRef)
           
 byte[] JDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
           
 Message JDBCMessageStore.getMessage(MessageId messageId)
           
 String JDBCMessageStore.getMessageReference(MessageId messageId)
           
 long JDBCAdapter.getStoreSequenceId(TransactionContext c, 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)
           
 void DefaultJDBCAdapter.doAddMessageReference(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, long expirationTime, String messageRef)
           
 byte[] DefaultJDBCAdapter.doGetMessage(TransactionContext c, MessageId id)
           
 long DefaultJDBCAdapter.getStoreSequenceId(TransactionContext c, 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)
           
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.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 KahaReferenceStore.getMessageId(Object object)
           
protected  MessageId KahaMessageStore.getMessageId(Object object)
           
protected  MessageId KahaTopicReferenceStore.getMessageId(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(Object id, String containerName)
           
protected  MapContainer<MessageId,ReferenceRecord> KahaReferenceStoreAdapter.getMapReferenceContainer(Object id, String containerName)
           
 

Methods in org.apache.activemq.store.kahadaptor with parameters of type MessageId
 void KahaTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 void KahaTopicReferenceStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 boolean KahaTopicReferenceStore.acknowledgeReference(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId)
           
 boolean KahaReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)
           
 boolean KahaTopicReferenceStore.addMessageReference(ConnectionContext context, MessageId messageId, ReferenceStore.ReferenceData data)
           
 Message KahaReferenceStore.getMessage(MessageId identity)
           
 Message KahaMessageStore.getMessage(MessageId identity)
           
 Message KahaTopicReferenceStore.getMessage(MessageId identity)
           
 ReferenceStore.ReferenceData KahaReferenceStore.getMessageReference(MessageId identity)
           
 ReferenceStore.ReferenceData KahaTopicReferenceStore.getMessageReference(MessageId identity)
           
 MessageId KahaMessageStore.getPreviousMessageIdToDeliver(MessageId id)
           
protected  boolean KahaReferenceStore.isDuplicate(MessageId messageId)
           
 ConsumerMessageRef TopicSubContainer.remove(MessageId id)
           
 void KahaReferenceStore.removeMessage(MessageId msgId)
           
 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<String,SubscriptionInfo> subsContainer, ActiveMQDestination destination)
           
KahaTopicReferenceStore(Store store, KahaReferenceStoreAdapter adapter, MapContainer<MessageId,ReferenceRecord> messageContainer, ListContainer<TopicSubAck> ackContainer, MapContainer<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)
           
 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  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)
           
 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)
           
 



Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.