Modifier and Type | Method and Description |
---|---|
QueueBinding |
PostOffice.updateQueue(QueueConfiguration queueConfiguration) |
QueueBinding |
PostOffice.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
QueueBinding |
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)
Deprecated.
|
QueueBinding |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Bindings.updated(QueueBinding binding) |
Modifier and Type | Class and Description |
---|---|
class |
LocalQueueBinding |
Modifier and Type | Method and Description |
---|---|
QueueBinding |
PostOfficeImpl.updateQueue(QueueConfiguration queueConfiguration) |
QueueBinding |
PostOfficeImpl.updateQueue(QueueConfiguration queueConfiguration,
boolean forceUpdate) |
QueueBinding |
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)
Deprecated.
|
QueueBinding |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
BindingsImpl.updated(QueueBinding binding) |
Modifier and Type | Interface and Description |
---|---|
interface |
RemoteQueueBinding |
Modifier and Type | Class and Description |
---|---|
class |
RemoteQueueBindingImpl |
Constructor and Description |
---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerConsumerPlugin.beforeCreateConsumer(long consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
Before a consumer is created
|
default boolean |
ActiveMQServerFederationPlugin.federatedAddressConditionalCreateDivertConsumer(DivertBinding divertBinding,
QueueBinding queueBinding) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.beforeCreateConsumer(long consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
Before a consumer is created
|
void |
LoggingActiveMQServerPluginLogger.beforeCreateConsumer(String consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage) |
void |
LoggingActiveMQServerPluginLogger_$logger.beforeCreateConsumer(String consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.