|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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,
java.lang.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 |
AbstractPendingMessageCursor.next()
|
MessageReference |
VMPendingMessageCursor.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 |
AbstractPendingMessageCursor.addMessageFirst(MessageReference node)
|
void |
VMPendingMessageCursor.addMessageFirst(MessageReference node)
add message to await dispatch |
void |
FilePendingMessageCursor.addMessageFirst(MessageReference node)
add message to await dispatch |
void |
PendingMessageCursor.addMessageLast(MessageReference node)
add message to await dispatch |
void |
AbstractPendingMessageCursor.addMessageLast(MessageReference node)
|
void |
VMPendingMessageCursor.addMessageLast(MessageReference node)
add message to await dispatch |
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(java.util.LinkedList messages)
Find the message reference in the given list with oldest messages at the front and newer messages at the end |
MessageReference[] |
OldestMessageEvictionStrategy.evictMessages(java.util.LinkedList messages)
|
MessageReference[] |
OldestMessageWithLowestPriorityEvictionStrategy.evictMessages(java.util.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 |
QueryBasedSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference message)
|
boolean |
NoSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference node)
|
boolean |
LastImageSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference node)
|
boolean |
TimedSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference message)
|
boolean |
FixedCountSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference node)
|
boolean |
FixedSizedSubscriptionRecoveryPolicy.add(ConnectionContext context,
MessageReference message)
|
boolean |
DispatchPolicy.dispatch(ConnectionContext newParam,
MessageReference node,
MessageEvaluationContext msgContext,
java.util.List consumers)
Decides how to dispatch a selected message to a collection of consumers. |
boolean |
StrictOrderDispatchPolicy.dispatch(ConnectionContext newParam,
MessageReference node,
MessageEvaluationContext msgContext,
java.util.List consumers)
|
boolean |
RoundRobinDispatchPolicy.dispatch(ConnectionContext newParam,
MessageReference node,
MessageEvaluationContext msgContext,
java.util.List consumers)
|
boolean |
SimpleDispatchPolicy.dispatch(ConnectionContext context,
MessageReference node,
MessageEvaluationContext msgContext,
java.util.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 |
SimpleMessageList.add(MessageReference node)
|
void |
MessageList.add(MessageReference node)
|
void |
DestinationBasedMessageList.add(MessageReference node)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |