Package | Description |
---|---|
org.apache.activemq.artemis.core.server.federation | |
org.apache.activemq.artemis.core.server.plugin |
Modifier and Type | Class and Description |
---|---|
class |
FederatedQueueConsumerImpl |
Modifier and Type | Field and Description |
---|---|
protected Map<FederatedConsumerKey,FederatedQueueConsumer> |
FederatedAbstract.remoteQueueConsumers |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerFederationPlugin.afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
After a federated queue consumer is closed
|
default void |
ActiveMQServerFederationPlugin.afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer)
After a federated queue consumer is created
|
default void |
ActiveMQServerFederationPlugin.afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer,
Message message)
After a federated queue consumer handles a message
|
default void |
ActiveMQServerFederationPlugin.beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
Before a federated queue consumer is closed
|
default void |
ActiveMQServerFederationPlugin.beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer,
Message message)
Before a federated queue consumer handles a message
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.