Modifier and Type | Class and Description |
---|---|
class |
FilterImpl
This class implements a HornetQ filter
|
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 |
Queue.getFilter() |
Filter |
Consumer.getFilter() |
Filter |
Divert.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,
boolean durable,
boolean temporary) |
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.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 |
ServerConsumerImpl.getFilter() |
Filter |
QueueImpl.getFilter() |
Filter |
DivertImpl.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,
boolean durable,
boolean temporary) |
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.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,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
boolean durable,
boolean temporary,
ScheduledExecutorService scheduledExecutor,
PostOffice postOffice,
StorageManager storageManager,
HierarchicalRepository<AddressSettings> addressSettingsRepository,
Executor executor) |
QueueImpl(long id,
SimpleString address,
SimpleString name,
Filter filter,
PageSubscription pageSubscription,
boolean durable,
boolean temporary,
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) |
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) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.