Uses of Interface
org.apache.activemq.artemis.core.filter.Filter
Packages that use Filter
Package
Description
-
Uses of Filter in org.apache.activemq.artemis.core.filter
Methods in org.apache.activemq.artemis.core.filter with parameters of type FilterModifier and TypeMethodDescriptionstatic booleanFilterUtils.isTopicIdentification(Filter filter) static SimpleStringFilter.toFilterString(Filter filter) -
Uses of Filter in org.apache.activemq.artemis.core.filter.impl
Classes in org.apache.activemq.artemis.core.filter.impl that implement FilterModifier and TypeClassDescriptionclassThis class implements an ActiveMQ Artemis filterMethods in org.apache.activemq.artemis.core.filter.impl that return FilterModifier and TypeMethodDescriptionstatic FilterFilterImpl.createFilter(String filterStr) Returns null iffilterStris null or an empty String and a valid filter else.static FilterFilterImpl.createFilter(SimpleString filterStr) Returns null iffilterStris null or an empty String and a valid filter else. -
Uses of Filter in org.apache.activemq.artemis.core.paging.cursor
Methods in org.apache.activemq.artemis.core.paging.cursor with parameters of type FilterModifier and TypeMethodDescriptionPageCursorProvider.createSubscription(long queueId, Filter filter, boolean durable) -
Uses of Filter in org.apache.activemq.artemis.core.paging.cursor.impl
Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type FilterModifier and TypeMethodDescriptionPageCursorProviderImpl.createSubscription(long cursorID, Filter filter, boolean persistent) -
Uses of Filter in org.apache.activemq.artemis.core.postoffice
Methods in org.apache.activemq.artemis.core.postoffice that return FilterMethods in org.apache.activemq.artemis.core.postoffice with parameters of type FilterModifier and TypeMethodDescriptionPostOffice.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged) Deprecated.PostOffice.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged, Long ringSize) Deprecated. -
Uses of Filter in org.apache.activemq.artemis.core.postoffice.impl
Methods in org.apache.activemq.artemis.core.postoffice.impl that return FilterMethods in org.apache.activemq.artemis.core.postoffice.impl with parameters of type FilterModifier and TypeMethodDescriptionPostOfficeImpl.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged) Deprecated.PostOfficeImpl.updateQueue(SimpleString name, RoutingType routingType, Filter filter, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, SimpleString user, Boolean configurationManaged, Long ringSize) Deprecated. -
Uses of Filter in org.apache.activemq.artemis.core.server
Methods in org.apache.activemq.artemis.core.server that return FilterModifier and TypeMethodDescriptionQueueConfig.filter()Deprecated.Consumer.getFilter()Divert.getFilter()Queue.getFilter()Methods in org.apache.activemq.artemis.core.server with parameters of type FilterModifier and TypeMethodDescriptionintQueue.changeReferencesPriority(Filter filter, byte newPriority) QueueFactory.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter) default intQueue.deleteMatchingReferences(int flushLImit, Filter filter) intQueue.deleteMatchingReferences(int flushLImit, Filter filter, AckReason ackReason) intQueue.deleteMatchingReferences(Filter filter) intQueue.expireReferences(Filter filter) Expire all the references in the queue which matches the filterDeprecated.intQueue.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, int messageCount, Binding binding) intQueue.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, Binding binding) intQueue.moveReferences(Filter filter, SimpleString toAddress, Binding binding) intQueue.retryMessages(Filter filter) default intQueue.retryMessages(Filter filter, Integer expectedHits) intQueue.sendMessagesToDeadLetterAddress(Filter filter) voidvoid -
Uses of Filter in org.apache.activemq.artemis.core.server.cluster
Methods in org.apache.activemq.artemis.core.server.cluster with parameters of type Filter -
Uses of Filter in org.apache.activemq.artemis.core.server.cluster.impl
Methods in org.apache.activemq.artemis.core.server.cluster.impl that return FilterModifier and TypeMethodDescriptionBridgeImpl.getFilter()Redistributor.getFilter()RemoteQueueBindingImpl.getFilter()Methods in org.apache.activemq.artemis.core.server.cluster.impl that return types with arguments of type FilterMethods in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type FilterConstructors in org.apache.activemq.artemis.core.server.cluster.impl with parameters of type FilterModifierConstructorDescriptionClusterConnectionBridge(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, TransformerConfiguration transformer, boolean useDuplicateDetection, String user, String password, ActiveMQServer server, SimpleString managementAddress, SimpleString managementNotificationAddress, MessageFlowRecord flowRecord, TransportConfiguration connector, String storeAndForwardPrefix, StorageManager storageManager, String clientId) -
Uses of Filter in org.apache.activemq.artemis.core.server.impl
Methods in org.apache.activemq.artemis.core.server.impl that return FilterModifier and TypeMethodDescriptionDivertImpl.getFilter()QueueImpl.getFilter()ServerConsumerImpl.getFilter()Methods in org.apache.activemq.artemis.core.server.impl with parameters of type FilterModifier and TypeMethodDescriptionintQueueImpl.changeReferencesPriority(Filter filter, byte newPriority) QueueFactoryImpl.createQueueWith(QueueConfiguration config, PagingManager pagingManager, Filter filter) intQueueImpl.deleteMatchingReferences(int flushLimit, Filter filter1, AckReason ackReason) intQueueImpl.deleteMatchingReferences(Filter filter) intQueueImpl.expireReferences(Filter filter) static PageSubscriptionQueueFactoryImpl.getPageSubscription(QueueConfiguration queueConfiguration, PagingManager pagingManager, Filter filter) intQueueImpl.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, int messageCount, Binding binding) intQueueImpl.moveReferences(int flushLimit, Filter filter, SimpleString toAddress, boolean rejectDuplicates, Binding binding) intQueueImpl.moveReferences(Filter filter, SimpleString toAddress, Binding binding) intQueueImpl.rerouteMessages(SimpleString queueName, Filter filter) intQueueImpl.retryMessages(Filter filter) intQueueImpl.retryMessages(Filter filter, Integer expectedHits) intQueueImpl.sendMessagesToDeadLetterAddress(Filter filter) voidvoidConstructors in org.apache.activemq.artemis.core.server.impl with parameters of type FilterModifierConstructorDescriptionDivertImpl(SimpleString uniqueName, SimpleString address, SimpleString forwardAddress, SimpleString routingName, boolean exclusive, Filter filter, Transformer transformer, PostOffice postOffice, StorageManager storageManager, ComponentConfigurationRoutingType routingType) LastValueQueue(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) QueueImpl(QueueConfiguration queueConfiguration, Filter filter, PagingStore pagingStore, PageSubscription pageSubscription, ScheduledExecutorService scheduledExecutor, PostOffice postOffice, StorageManager storageManager, HierarchicalRepository<AddressSettings> addressSettingsRepository, ArtemisExecutor executor, ActiveMQServer server, QueueFactory factory) 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) 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, int priority, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService, boolean supportLargeMessage, Integer credits, ActiveMQServer server)