Modifier and Type | Method and Description |
---|---|
Pair<RoutingContext,ServerMessage> |
PostOffice.redistribute(ServerMessage message,
Queue originatingQueue,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
void |
PostOffice.processRoute(ServerMessage message,
RoutingContext context,
boolean direct) |
boolean |
Bindings.redistribute(ServerMessage message,
Queue originatingQueue,
RoutingContext context) |
RoutingStatus |
PostOffice.route(ServerMessage message,
QueueCreator queueCreator,
RoutingContext context,
boolean direct) |
RoutingStatus |
PostOffice.route(ServerMessage message,
QueueCreator queueCreator,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
Bindings.route(ServerMessage message,
RoutingContext context) |
void |
Binding.route(ServerMessage message,
RoutingContext context) |
void |
Binding.routeWithAck(ServerMessage message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
Pair<RoutingContext,ServerMessage> |
PostOfficeImpl.redistribute(ServerMessage 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(ServerMessage message,
RoutingContext context,
boolean direct) |
boolean |
BindingsImpl.redistribute(ServerMessage message,
Queue originatingQueue,
RoutingContext context) |
RoutingStatus |
PostOfficeImpl.route(ServerMessage message,
QueueCreator queueCreator,
RoutingContext context,
boolean direct) |
RoutingStatus |
PostOfficeImpl.route(ServerMessage message,
QueueCreator queueCreator,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
void |
LocalQueueBinding.route(ServerMessage message,
RoutingContext context) |
void |
DivertBinding.route(ServerMessage message,
RoutingContext context) |
void |
BindingsImpl.route(ServerMessage message,
RoutingContext context) |
void |
LocalQueueBinding.routeWithAck(ServerMessage message,
RoutingContext context) |
void |
DivertBinding.routeWithAck(ServerMessage message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
void |
Bindable.route(ServerMessage message,
RoutingContext context) |
void |
Bindable.routeWithAck(ServerMessage message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteQueueBindingImpl.route(ServerMessage message,
RoutingContext context) |
void |
RemoteQueueBindingImpl.routeWithAck(ServerMessage 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 |
DivertImpl.route(ServerMessage message,
RoutingContext context) |
void |
QueueImpl.route(ServerMessage message,
RoutingContext context) |
void |
DivertImpl.routeWithAck(ServerMessage message,
RoutingContext context) |
void |
QueueImpl.routeWithAck(ServerMessage message,
RoutingContext context) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.