Package | Description |
---|---|
org.hornetq.core.postoffice | |
org.hornetq.core.postoffice.impl | |
org.hornetq.core.server | |
org.hornetq.core.server.cluster.impl | |
org.hornetq.core.server.impl |
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 |
BindingsImpl.route(ServerMessage message,
RoutingContext context) |
void |
LocalQueueBinding.route(ServerMessage message,
RoutingContext context) |
void |
DivertBinding.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 © 2017 JBoss, a division of Red Hat. All Rights Reserved.