public class MultipleEndpointObserver extends Object implements MessageObserver
Modifier and Type | Field and Description |
---|---|
protected List<Interceptor<? extends Message>> |
bindingInterceptors |
protected Bus |
bus |
static String |
ENDPOINTS |
protected List<Interceptor<? extends Message>> |
routingInterceptors |
Constructor and Description |
---|
MultipleEndpointObserver(Bus bus) |
Modifier and Type | Method and Description |
---|---|
protected PhaseInterceptorChain |
createChain() |
protected Message |
createMessage(Message message)
Give a chance for a Binding to customize their message
|
List<Interceptor<? extends Message>> |
getBindingInterceptors() |
Set<Endpoint> |
getEndpoints() |
List<Interceptor<? extends Message>> |
getRoutingInterceptors() |
void |
onMessage(Message message)
Called for an incoming message, i.e.
|
protected void |
setExchangeProperties(Exchange exchange,
Message m) |
public static final String ENDPOINTS
protected Bus bus
protected List<Interceptor<? extends Message>> bindingInterceptors
protected List<Interceptor<? extends Message>> routingInterceptors
public MultipleEndpointObserver(Bus bus)
public void onMessage(Message message)
MessageObserver
onMessage
in interface MessageObserver
protected Message createMessage(Message message)
protected PhaseInterceptorChain createChain()
public List<Interceptor<? extends Message>> getBindingInterceptors()
public List<Interceptor<? extends Message>> getRoutingInterceptors()
Copyright © 2017 JBoss by Red Hat. All rights reserved.