Modifier and Type | Method and Description |
---|---|
boolean |
PagingStore.page(ServerMessage message,
RoutingContext ctx) |
boolean |
PagingStore.page(ServerMessage message,
RoutingContext ctx,
RouteContextList listCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
PagingStoreImpl.page(ServerMessage message,
RoutingContext ctx) |
boolean |
PagingStoreImpl.page(ServerMessage message,
RoutingContext ctx,
RouteContextList listCtx) |
protected boolean |
PagingStoreImpl.page(ServerMessage message,
RoutingContext ctx,
RouteContextList listCtx,
boolean sync) |
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) |
void |
Bindings.route(ServerMessage message,
RoutingContext context) |
void |
Binding.route(ServerMessage message,
RoutingContext context) |
void |
PostOffice.route(ServerMessage message,
RoutingContext context,
boolean direct) |
void |
PostOffice.route(ServerMessage message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
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) |
void |
LocalQueueBinding.route(ServerMessage message,
RoutingContext context) |
void |
DivertBinding.route(ServerMessage message,
RoutingContext context) |
void |
BindingsImpl.route(ServerMessage message,
RoutingContext context) |
void |
PostOfficeImpl.route(ServerMessage message,
RoutingContext context,
boolean direct) |
void |
PostOfficeImpl.route(ServerMessage message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates) |
Modifier and Type | Method and Description |
---|---|
void |
Bindable.route(ServerMessage message,
RoutingContext context) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteQueueBindingImpl.route(ServerMessage message,
RoutingContext context) |
Modifier and Type | Class and Description |
---|---|
class |
RoutingContextImpl
A RoutingContextImpl
|
Modifier and Type | Method and Description |
---|---|
void |
QueueImpl.route(ServerMessage message,
RoutingContext context) |
void |
DivertImpl.route(ServerMessage message,
RoutingContext context) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.