|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.DestinationFilter
org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor
org.apache.activemq.broker.region.virtual.SelectorAwareVirtualTopicInterceptor
public class SelectorAwareVirtualTopicInterceptor
Field Summary |
---|
Fields inherited from interface org.apache.activemq.broker.region.Destination |
---|
DEFAULT_BLOCKED_PRODUCER_WARNING_INTERVAL, DEFAULT_DEAD_LETTER_STRATEGY |
Constructor Summary | |
---|---|
SelectorAwareVirtualTopicInterceptor(Destination next,
java.lang.String prefix,
java.lang.String postfix)
|
Method Summary | |
---|---|
protected void |
send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Respect the selectors of the subscriptions to ensure only matched messages are dispatched to the virtual queues, hence there is no build up of unmatched messages on these destinations |
Methods inherited from class org.apache.activemq.broker.region.virtual.VirtualTopicInterceptor |
---|
getQueueConsumersWildcard, send |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SelectorAwareVirtualTopicInterceptor(Destination next, java.lang.String prefix, java.lang.String postfix)
Method Detail |
---|
protected void send(ProducerBrokerExchange context, Message message, ActiveMQDestination destination) throws java.lang.Exception
send
in class DestinationFilter
context
- broker contextmessage
- message to senddestination
- possibly wildcard destination to send the message to
java.lang.Exception
- on error
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |