Modifier and Type | Class and Description |
---|---|
class |
FilterImpl
This class implements an ActiveMQ Artemis filter
ActiveMQ Artemis filters have the same syntax as JMS 1.1 selectors, but the identifiers are different.
|
Modifier and Type | Method and Description |
---|---|
static Filter |
FilterImpl.createFilter(SimpleString filterStr) |
static Filter |
FilterImpl.createFilter(String filterStr) |
Modifier and Type | Method and Description |
---|---|
PageSubscription |
PageCursorProvider.createSubscription(long queueId,
Filter filter,
boolean durable) |
Modifier and Type | Method and Description |
---|---|
PageSubscription |
PageCursorProviderImpl.createSubscription(long cursorID,
Filter filter,
boolean persistent) |
Modifier and Type | Method and Description |
---|---|
Filter |
Binding.getFilter() |
Modifier and Type | Method and Description |
---|---|
Filter |
LocalQueueBinding.getFilter() |
Filter |
DivertBinding.getFilter() |
Modifier and Type | Method and Description |
---|---|
Filter |
Divert.getFilter() |
Filter |
Consumer.getFilter() |
Filter |
Queue.getFilter() |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
ScheduledDeliveryHandler.cancel(Filter filter) |
int |
Queue.changeReferencesPriority(Filter filter,
byte newPriority) |
Queue |
QueueFactory.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
int |
Queue.deleteMatchingReferences(Filter filter) |
int |
Queue.deleteMatchingReferences(int flushLImit,
Filter filter) |
int |
Queue.expireReferences(Filter filter)
Expire all the references in the queue which matches the filter
|
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress) |
int |
Queue.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
int |
Queue.retryMessages(Filter filter) |
int |
Queue.sendMessagesToDeadLetterAddress(Filter filter) |
Modifier and Type | Method and Description |
---|---|
Filter |
RemoteQueueBindingImpl.getFilter() |
Filter |
BridgeImpl.getFilter() |
Filter |
Redistributor.getFilter() |
Modifier and Type | Method and Description |
---|---|
Set<Filter> |
RemoteQueueBindingImpl.getFilters() |
Constructor and Description |
---|
BridgeImpl(ServerLocatorInternal serverLocator,
int initialConnectAttempts,
int reconnectAttempts,
int reconnectAttemptsSameNode,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
SimpleString name,
Queue queue,
Executor executor,
Filter filter,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
StorageManager storageManager) |
ClusterConnectionBridge(ClusterConnection clusterConnection,
ClusterManager clusterManager,
ServerLocatorInternal targetLocator,
ServerLocatorInternal discoveryLocator,
int initialConnectAttempts,
int reconnectAttempts,
long retryInterval,
double retryMultiplier,
long maxRetryInterval,
UUID nodeUUID,
long targetNodeEventUID,
String targetNodeID,
SimpleString name,
Queue queue,
Executor executor,
Filter filterString,
SimpleString forwardingAddress,
ScheduledExecutorService scheduledExecutor,
Transformer transformer,
boolean useDuplicateDetection,
String user,
String password,
StorageManager storageManager,
SimpleString managementAddress,
SimpleString managementNotificationAddress,
MessageFlowRecord flowRecord,
TransportConfiguration connector) |
Modifier and Type | Method and Description |
---|---|
Filter |
DivertImpl.getFilter() |
Filter |
ServerConsumerImpl.getFilter() |
Filter |
QueueImpl.getFilter() |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
ScheduledDeliveryHandlerImpl.cancel(Filter filter) |
int |
QueueImpl.changeReferencesPriority(Filter filter,
byte newPriority) |
Queue |
QueueFactoryImpl.createQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated) |
int |
QueueImpl.deleteMatchingReferences(Filter filter) |
int |
QueueImpl.deleteMatchingReferences(int flushLimit,
Filter filter1) |
int |
QueueImpl.expireReferences(Filter filter) |
int |
QueueImpl.moveReferences(Filter filter,
SimpleString toAddress) |
int |
QueueImpl.moveReferences(int flushLimit,
Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
int |
QueueImpl.retryMessages(Filter filter) |
int |
QueueImpl.sendMessagesToDeadLetterAddress(Filter filter) |
Constructor and Description |
---|
DivertImpl(SimpleString forwardAddress,
SimpleString uniqueName,
SimpleString routingName,
boolean exclusive,
Filter filter,
Transformer transformer,
PostOffice postOffice,
StorageManager storageManager) |
LastValueQueue(long persistenceID,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
SimpleString user,
boolean durable,
boolean temporary,
boolean autoCreated,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
ActiveMQServer server) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
boolean supportLargeMessage,
Integer credits,
ActiveMQServer server) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.