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) |
Constructor and Description |
---|
PageSubscriptionImpl(PageCursorProvider cursorProvider,
PagingStore pageStore,
StorageManager store,
Executor executor,
Filter filter,
long cursorId,
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 |
Divert.getFilter() |
Filter |
Consumer.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.expireReferences(Filter filter)
Expire all the references in the queue which matches the filter
|
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress) |
int |
Queue.moveReferences(Filter filter,
SimpleString toAddress,
boolean rejectDuplicates) |
int |
Queue.sendMessagesToDeadLetterAddress(Filter filter) |
Modifier and Type | Method and Description |
---|---|
Filter |
RemoteQueueBindingImpl.getFilter() |
Filter |
Redistributor.getFilter() |
Filter |
BridgeImpl.getFilter() |
Modifier and Type | Method and Description |
---|---|
Set<Filter> |
RemoteQueueBindingImpl.getFilters() |
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.expireReferences(Filter filter) |
int |
QueueImpl.moveReferences(Filter filter,
SimpleString toAddress) |
int |
QueueImpl.moveReferences(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) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.