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 |
Bindings.route(Message message,
RoutingContext context) |
void |
Binding.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 |
LocalQueueBinding.route(Message message,
RoutingContext context) |
void |
DivertBinding.route(Message message,
RoutingContext context) |
void |
BindingsImpl.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 |
LocalQueueBinding.routeWithAck(Message message,
RoutingContext context) |
void |
DivertBinding.routeWithAck(Message message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
void |
Bindable.route(Message message,
RoutingContext context) |
void |
Bindable.routeWithAck(Message message,
RoutingContext context) |
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 |
---|---|
void |
QueueImpl.route(Message message,
RoutingContext context) |
void |
DivertImpl.route(Message message,
RoutingContext context) |
void |
QueueImpl.routeWithAck(Message message,
RoutingContext context) |
void |
DivertImpl.routeWithAck(Message message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
ActiveMQServerPlugin.afterMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
RoutingStatus result)
After a message is routed
|
default void |
ActiveMQServerPlugin.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
|
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 |
LoggingActiveMQServerPluginLogger.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
LoggingActiveMQServerPlugin.beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.