| 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 © 2022 JBoss by Red Hat. All rights reserved.