Uses of Interface
org.apache.activemq.broker.region.MessageReference

Packages that use MessageReference
org.apache.activemq.broker The core classes for the ActiveMQ Message Broker and its connectors. 
org.apache.activemq.broker.region Region abstraction and implementations in the Broker. 
org.apache.activemq.broker.region.cursors   
org.apache.activemq.broker.region.policy The policies which can be associated with a particular destination or wildcard. 
org.apache.activemq.command Command objects used via the Command Pattern to communicate among nodes 
org.apache.activemq.filter Filter implementations for wildcards & JMS selectors 
org.apache.activemq.memory.buffer   
org.apache.activemq.memory.list   
 

Uses of MessageReference in org.apache.activemq.broker
 

Methods in org.apache.activemq.broker with parameters of type MessageReference
 boolean ConnectionContext.isAllowedToConsume(MessageReference n)
           
 

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

Subinterfaces of MessageReference in org.apache.activemq.broker.region
 interface QueueMessageReference
          Queue specific MessageReference.
 

Classes in org.apache.activemq.broker.region that implement MessageReference
 class IndirectMessageReference
          Keeps track of a message that is flowing through the Broker.
 

Methods in org.apache.activemq.broker.region with parameters of type MessageReference
protected  void DurableTopicSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
           
protected  void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
          Used during acknowledgment to remove the message.
protected  void QueueSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference n)
          In the queue case, mark the node as dropped and then a gc cycle will remove it from the queue.
protected  void QueueBrowserSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference n)
          Since we are a browser we don't really remove the message from the queue.
 void Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Queue.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Subscription.add(MessageReference node)
          Used to add messages that match the subscription.
 void TopicSubscription.add(MessageReference node)
           
 void DurableTopicSubscription.add(MessageReference node)
           
 void PrefetchSubscription.add(MessageReference node)
           
protected  void QueueSubscription.assignGroupToMe(MessageGroupMap messageGroupOwners, MessageReference n, String groupId)
          Assigns the message group to this subscription and set the flag on the message that it is the first message to be dispatched.
protected  boolean DurableTopicSubscription.canDispatch(MessageReference node)
           
protected abstract  boolean PrefetchSubscription.canDispatch(MessageReference node)
          Use when a matched message is about to be dispatched to the client.
protected  boolean QueueSubscription.canDispatch(MessageReference n)
           
protected  boolean QueueBrowserSubscription.canDispatch(MessageReference node)
           
protected  MessageDispatch DurableTopicSubscription.createMessageDispatch(MessageReference node, Message message)
           
protected  MessageDispatch PrefetchSubscription.createMessageDispatch(MessageReference node, Message message)
           
protected  boolean PrefetchSubscription.dispatch(MessageReference node)
           
protected  boolean QueueSubscription.dispatch(MessageReference node)
          Override so that the message ref count is > 0 only when the message is being dispatched to a client.
 boolean MessageReferenceFilter.evaluate(ConnectionContext context, MessageReference messageReference)
           
 boolean Destination.lock(MessageReference node, LockOwner lockOwner)
           
 boolean Queue.lock(MessageReference node, LockOwner lockOwner)
           
 boolean Topic.lock(MessageReference node, LockOwner sub)
           
 boolean DestinationFilter.lock(MessageReference node, LockOwner lockOwner)
           
 boolean Subscription.matches(MessageReference node, MessageEvaluationContext context)
          Is the subscription interested in the message?
 boolean AbstractSubscription.matches(MessageReference node, MessageEvaluationContext context)
           
 boolean QueueBrowserSubscription.matches(MessageReference node, MessageEvaluationContext context)
           
protected  void PrefetchSubscription.onDispatch(MessageReference node, Message message)
           
protected  void QueueSubscription.onDispatch(MessageReference node, Message message)
          OK Message was transmitted, we can now drop the reference count.
protected  void PrefetchSubscription.sendToDLQ(ConnectionContext context, MessageReference node)
           
protected  void QueueSubscription.sendToDLQ(ConnectionContext context, MessageReference node)
          Sending a message to the DQL will require us to increment the ref count so we can get at the content.
 

Uses of MessageReference in org.apache.activemq.broker.region.cursors
 

Methods in org.apache.activemq.broker.region.cursors that return MessageReference
 MessageReference PendingMessageCursor.next()
           
 MessageReference VMPendingMessageCursor.next()
           
 MessageReference AbstractPendingMessageCursor.next()
           
 MessageReference StoreDurableSubscriberCursor.next()
           
 MessageReference FilePendingMessageCursor.next()
           
 

Methods in org.apache.activemq.broker.region.cursors with parameters of type MessageReference
 void PendingMessageCursor.addMessageFirst(MessageReference node)
          add message to await dispatch
 void VMPendingMessageCursor.addMessageFirst(MessageReference node)
          add message to await dispatch
 void AbstractPendingMessageCursor.addMessageFirst(MessageReference node)
           
 void FilePendingMessageCursor.addMessageFirst(MessageReference node)
          add message to await dispatch
 void PendingMessageCursor.addMessageLast(MessageReference node)
          add message to await dispatch
 void VMPendingMessageCursor.addMessageLast(MessageReference node)
          add message to await dispatch
 void AbstractPendingMessageCursor.addMessageLast(MessageReference node)
           
 void StoreDurableSubscriberCursor.addMessageLast(MessageReference node)
           
 void FilePendingMessageCursor.addMessageLast(MessageReference node)
          add message to await dispatch
 

Uses of MessageReference in org.apache.activemq.broker.region.policy
 

Methods in org.apache.activemq.broker.region.policy that return MessageReference
 MessageReference[] MessageEvictionStrategy.evictMessages(LinkedList messages)
          Find the message reference in the given list with oldest messages at the front and newer messages at the end
 MessageReference[] OldestMessageWithLowestPriorityEvictionStrategy.evictMessages(LinkedList messages)
           
 MessageReference[] OldestMessageEvictionStrategy.evictMessages(LinkedList messages)
           
 

Methods in org.apache.activemq.broker.region.policy with parameters of type MessageReference
 boolean SubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
          A message was sent to the destination.
 boolean NoSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
 boolean FixedCountSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
 boolean TimedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean QueryBasedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean LastImageSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference node)
           
 boolean FixedSizedSubscriptionRecoveryPolicy.add(ConnectionContext context, MessageReference message)
           
 boolean DispatchPolicy.dispatch(ConnectionContext newParam, MessageReference node, MessageEvaluationContext msgContext, List consumers)
          Decides how to dispatch a selected message to a collection of consumers.
 boolean SimpleDispatchPolicy.dispatch(ConnectionContext context, MessageReference node, MessageEvaluationContext msgContext, List consumers)
           
 boolean StrictOrderDispatchPolicy.dispatch(ConnectionContext newParam, MessageReference node, MessageEvaluationContext msgContext, List consumers)
           
 boolean RoundRobinDispatchPolicy.dispatch(ConnectionContext newParam, MessageReference node, MessageEvaluationContext msgContext, List consumers)
           
 

Uses of MessageReference in org.apache.activemq.command
 

Classes in org.apache.activemq.command that implement MessageReference
 class ActiveMQBytesMessage
          A BytesMessage object is used to send a message containing a stream of uninterpreted bytes.
 class ActiveMQMapMessage
          A MapMessage object is used to send a set of name-value pairs.
 class ActiveMQMessage
           
 class ActiveMQObjectMessage
          An ObjectMessage object is used to send a message that contains a serializable object in the Java programming language ("Java object").
 class ActiveMQStreamMessage
          A StreamMessage object is used to send a stream of primitive types in the Java programming language.
 class ActiveMQTextMessage
           
 class Message
          Represents an ActiveMQ message
 

Uses of MessageReference in org.apache.activemq.filter
 

Methods in org.apache.activemq.filter with parameters of type MessageReference
 void MessageEvaluationContext.setMessageReference(MessageReference messageReference)
           
 

Uses of MessageReference in org.apache.activemq.memory.buffer
 

Methods in org.apache.activemq.memory.buffer with parameters of type MessageReference
 void MessageQueue.add(MessageReference messageRef)
           
 

Uses of MessageReference in org.apache.activemq.memory.list
 

Methods in org.apache.activemq.memory.list with parameters of type MessageReference
 void DestinationBasedMessageList.add(MessageReference node)
           
 void MessageList.add(MessageReference node)
           
 void SimpleMessageList.add(MessageReference node)
           
 



Copyright © 2011 Apache Software Foundation. All Rights Reserved.