|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Filter | |
org.activemq.filter | Filter implementations for wildcards & JMS selectors |
org.activemq.selector | JMS Selector parser |
org.activemq.service | The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager |
org.activemq.service.boundedvm | |
org.activemq.service.impl | Default implementations of the services |
Uses of Filter in org.activemq.filter |
Classes in org.activemq.filter that implement Filter | |
class |
AndFilter
Represents a logical AND operation on two filters |
class |
CompositeDestinationFilter
A DestinationFilter used for composite destinations |
class |
DestinationFilter
Represents a filter which only operates on Destinations |
class |
ExpressionFilter
Represents a filter using an expression |
class |
NoLocalFilter
Checks that messages are not filtered by NoLocal |
class |
NotFilter
Represents a logical not operation on another filter |
class |
OrFilter
Represents a logical OR operation on two filters |
class |
PrefixDestinationFilter
Matches messages which match a prefix like "A.B.>" |
class |
SimpleDestinationFilter
Matches messages sent to an exact destination |
class |
WildcardDestinationFilter
Matches messages which contain wildcards like "A.B.*.*" |
Methods in org.activemq.filter that return Filter | |
Filter |
FilterFactory.createFilter(Destination destination,
String selector)
|
Filter |
FilterFactoryImpl.createFilter(Destination destination,
String selector)
|
Filter |
OrFilter.getLeft()
|
Filter |
OrFilter.getRight()
|
Filter |
AndFilter.getLeft()
|
Filter |
AndFilter.getRight()
|
Constructors in org.activemq.filter with parameters of type Filter | |
OrFilter(Filter left,
Filter right)
|
|
NotFilter(Filter filter)
|
|
AndFilter(Filter left,
Filter right)
|
Uses of Filter in org.activemq.selector |
Methods in org.activemq.selector that return Filter | |
Filter |
SelectorParser.parse(String sql)
|
Filter |
SelectorParser.JmsSelector()
|
Uses of Filter in org.activemq.service |
Methods in org.activemq.service with parameters of type Filter | |
Subscription |
SubscriptionContainer.makeSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
Creates a subscription (which could be a previous subscription reconecting) and adds it to this container |
Uses of Filter in org.activemq.service.boundedvm |
Fields in org.activemq.service.boundedvm declared as Filter | |
protected Filter |
DurableSubscription.filter
|
protected Filter |
TransientSubscription.filter
|
Methods in org.activemq.service.boundedvm that return Filter | |
protected Filter |
DurableQueueBoundedMessageManager.createFilter(ConsumerInfo info)
Create filter for a Consumer |
protected Filter |
TransientQueueBoundedMessageManager.createFilter(ConsumerInfo info)
Create filter for a Consumer |
protected Filter |
TransientTopicBoundedMessageManager.createFilter(ConsumerInfo info)
Create filter for a Consumer |
Filter |
DurableSubscription.getFilter()
|
Filter |
TransientSubscription.getFilter()
|
Methods in org.activemq.service.boundedvm with parameters of type Filter | |
TransientQueueSubscription |
TransientQueueBoundedMessageContainer.addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
Add a consumer to dispatch messages to |
TransientTopicSubscription |
TransientTopicBoundedMessageContainer.addConsumer(Filter filter,
ConsumerInfo info)
Add a consumer to dispatch messages to |
void |
DurableSubscription.setFilter(Filter filter)
|
DurableQueueSubscription |
DurableQueueBoundedMessageContainer.addConsumer(Filter filter,
ConsumerInfo info,
BrokerClient client)
Add a consumer to dispatch messages to |
void |
TransientSubscription.setFilter(Filter filter)
|
Constructors in org.activemq.service.boundedvm with parameters of type Filter | |
DurableQueueSubscription(BrokerClient client,
MemoryBoundedQueue dispatchedQueue,
MemoryBoundedQueue ackQueue,
Filter filter,
ConsumerInfo info)
Construct the DurableQueueSubscription |
|
DurableSubscription(Filter filter,
ConsumerInfo info,
BrokerClient client)
Construct the DurableSubscription |
|
TransientQueueSubscription(BrokerClient client,
MemoryBoundedQueue dispatchedQueue,
MemoryBoundedQueue ackQueue,
Filter filter,
ConsumerInfo info)
Construct the TransientQueueSubscription |
|
TransientTopicSubscription(Filter filter,
ConsumerInfo info,
BrokerClient client)
Construct the TransientTopicSubscription |
|
TransientSubscription(Filter filter,
ConsumerInfo info,
BrokerClient client)
Construct the TransientSubscription |
Uses of Filter in org.activemq.service.impl |
Methods in org.activemq.service.impl that return Filter | |
Filter |
SubscriptionImpl.getFilter()
|
protected Filter |
DurableQueueMessageContainerManager.createFilter(ConsumerInfo info)
Create filter for a Consumer |
protected Filter |
DurableTopicMessageContainerManager.createFilter(ConsumerInfo info)
Create filter for a Consumer |
Methods in org.activemq.service.impl with parameters of type Filter | |
Subscription |
SubscriptionContainerImpl.makeSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
|
protected Subscription |
SubscriptionContainerImpl.createSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
|
void |
SubscriptionImpl.setFilter(Filter filter)
|
protected Subscription |
DurableTopicSubscriptionContainerImpl.createSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter)
|
Constructors in org.activemq.service.impl with parameters of type Filter | |
SubscriptionImpl(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
Create a Subscription object that holds messages to be dispatched to a Consumer |
|
DurableTopicSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |