Modifier and Type | Method and Description |
---|---|
Pair<RoutingContext,Message> |
PostOffice.redistribute(Message message,
Queue originatingQueue,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
PostOffice.processRoute(Message message,
RoutingContext context,
boolean direct) |
boolean |
Bindings.redistribute(Message message,
Queue originatingQueue,
RoutingContext context) |
void |
Binding.route(Message message,
RoutingContext context) |
void |
Bindings.route(Message message,
RoutingContext context) |
RoutingStatus |
PostOffice.route(Message message,
RoutingContext context,
boolean direct) |
RoutingStatus |
PostOffice.route(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Binding binding) |
void |
Binding.routeWithAck(Message message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
Pair<RoutingContext,Message> |
PostOfficeImpl.redistribute(Message message,
Queue originatingQueue,
Transaction tx)
The redistribution can't process the route right away as we may be dealing with a large message which will need to be processed on a different thread
|
Modifier and Type | Method and Description |
---|---|
void |
PostOfficeImpl.processRoute(Message message,
RoutingContext context,
boolean direct) |
boolean |
BindingsImpl.redistribute(Message message,
Queue originatingQueue,
RoutingContext context) |
void |
BindingsImpl.route(Message message,
RoutingContext context) |
void |
DivertBinding.route(Message message,
RoutingContext context) |
void |
LocalQueueBinding.route(Message message,
RoutingContext context) |
RoutingStatus |
PostOfficeImpl.route(Message message,
RoutingContext context,
boolean direct) |
RoutingStatus |
PostOfficeImpl.route(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Binding bindingMove) |
void |
DivertBinding.routeWithAck(Message message,
RoutingContext context) |
void |
LocalQueueBinding.routeWithAck(Message message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
RoutingContext |
RoutingContext.clear() |
RoutingContext |
RoutingContext.setReusable(boolean reusable) |
RoutingContext |
RoutingContext.setReusable(boolean reusable,
int version) |
Modifier and Type | Method and Description |
---|---|
RoutingStatus |
ServerSession.doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
void |
Bindable.route(Message message,
RoutingContext context) |
void |
Bindable.routeWithAck(Message message,
RoutingContext context) |
RoutingStatus |
ServerSession.send(Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteQueueBindingImpl.route(Message message,
RoutingContext context) |
void |
RemoteQueueBindingImpl.routeWithAck(Message message,
RoutingContext context) |
Modifier and Type | Class and Description |
---|---|
class |
RoutingContextImpl |
Modifier and Type | Field and Description |
---|---|
protected RoutingContext |
ServerSessionImpl.routingContext |
Modifier and Type | Method and Description |
---|---|
RoutingContext |
RoutingContextImpl.clear() |
RoutingContext |
RoutingContextImpl.setReusable(boolean reusable) |
RoutingContext |
RoutingContextImpl.setReusable(boolean reusable,
int previousBindings) |
Modifier and Type | Method and Description |
---|---|
RoutingStatus |
ServerSessionImpl.doSend(Transaction tx,
Message msg,
SimpleString originalAddress,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
void |
DivertImpl.route(Message message,
RoutingContext context) |
void |
QueueImpl.route(Message message,
RoutingContext context) |
void |
DivertImpl.routeWithAck(Message message,
RoutingContext context) |
void |
QueueImpl.routeWithAck(Message message,
RoutingContext context) |
RoutingStatus |
ServerSessionImpl.send(Transaction tx,
Message messageParameter,
boolean direct,
boolean noAutoCreateQueue,
RoutingContext routingContext) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerMessagePlugin.afterMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
RoutingStatus result)
After a message is routed
|
default void |
ActiveMQServerMessagePlugin.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
|
default void |
ActiveMQServerMessagePlugin.onMessageRouteException(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Exception e)
When there was an error routing the message
|
Modifier and Type | Method and Description |
---|---|
void |
LoggingActiveMQServerPlugin.afterMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
RoutingStatus result)
After a message is routed
|
void |
LoggingActiveMQServerPluginLogger.afterMessageRouteDetails(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
LoggingActiveMQServerPlugin.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
|
void |
LoggingActiveMQServerPluginLogger.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
LoggingActiveMQServerPluginLogger.onMessageRouteErrorDetails(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
LoggingActiveMQServerPlugin.onMessageRouteException(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Exception e) |
Copyright © 2020 JBoss by Red Hat. All rights reserved.