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

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 Message.getMessageId()
           
 MessageId MessageDispatchNotification.getMessageId()
           
 MessageId JournalTopicAck.getMessageId()
           
 

Methods in org.apache.activemq.command with parameters of type MessageId
 void MessageAck.setFirstMessageId(MessageId firstMessageId)
           
 void MessageAck.setLastMessageId(MessageId lastMessageId)
           
 void Message.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.store
 

Methods in org.apache.activemq.store that return MessageId
 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.getNextMessageIdToDeliver(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
 MessageId ProxyTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 

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)
          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)
           
 void MessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, java.lang.String messageRef)
          Adds a message reference to the message store
 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)
           
 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)
           
 java.lang.String MessageStore.getMessageReference(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)
           
 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.getNextMessageIdToDeliver(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
 MessageId ProxyTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 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.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 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
 void ProxyTopicMessageStore.resetBatching(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 

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 QuickJournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId JournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId QuickJournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId JournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 

Methods in org.apache.activemq.store.journal with parameters of type MessageId
 void QuickJournalTopicMessageStore.acknowledge(ConnectionContext context, java.lang.String clientId, java.lang.String subscriptionName, MessageId messageId)
           
 void JournalTopicMessageStore.acknowledge(ConnectionContext context, java.lang.String clientId, java.lang.String subscriptionName, MessageId messageId)
           
 void QuickJournalMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, java.lang.String messageRef)
           
 void JournalMessageStore.addMessageReference(ConnectionContext context, MessageId messageId, long expirationTime, java.lang.String messageRef)
           
 Message QuickJournalMessageStore.getMessage(MessageId identity)
           
 Message JournalMessageStore.getMessage(MessageId identity)
           
 java.lang.String QuickJournalMessageStore.getMessageReference(MessageId identity)
           
 java.lang.String JournalMessageStore.getMessageReference(MessageId identity)
           
 MessageId QuickJournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId JournalTopicMessageStore.getNextMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId QuickJournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 MessageId JournalTopicMessageStore.getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id)
           
 void QuickJournalTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void JournalTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void QuickJournalTopicMessageStore.replayAcknowledge(ConnectionContext context, java.lang.String clientId, java.lang.String subscritionName, MessageId messageId)
           
 void JournalTopicMessageStore.replayAcknowledge(ConnectionContext context, java.lang.String clientId, java.lang.String subscritionName, MessageId messageId)
           
 void QuickJournalTopicMessageStore.resetBatching(java.lang.String clientId, java.lang.String subscriptionName, MessageId nextId)
           
 void JournalTopicMessageStore.resetBatching(java.lang.String clientId, java.lang.String subscriptionName, MessageId nextToDispatch)
           
 

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)
           
 



Copyright © 2010 Apache Software Foundation. All Rights Reserved.