org.apache.cxf.transport
Class MultipleEndpointObserver

java.lang.Object
  extended by org.apache.cxf.transport.MultipleEndpointObserver
All Implemented Interfaces:
MessageObserver

public class MultipleEndpointObserver
extends java.lang.Object
implements MessageObserver

This MessageObserver creates an Interceptor chain which adds in the interceptors set on this class and the global Bus interceptors. At somepoint, it is expected that these interceptors will resolve the appropriate Endpoint/Binding combination and continue setting up the chain.


Field Summary
protected  java.util.List<Interceptor> bindingInterceptors
           
protected  Bus bus
           
static java.lang.String ENDPOINTS
           
protected  java.util.List<Interceptor> routingInterceptors
           
 
Constructor Summary
MultipleEndpointObserver(Bus bus)
           
 
Method Summary
protected  PhaseInterceptorChain createChain()
           
protected  Message createMessage(Message message)
          Give a chance for a Binding to customize their message
 java.util.List<Interceptor> getBindingInterceptors()
           
 java.util.Set<Endpoint> getEndpoints()
           
 java.util.List<Interceptor> getRoutingInterceptors()
           
 void onMessage(Message message)
          Called for an incoming message, i.e.
protected  void setExchangeProperties(Exchange exchange, Message m)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

ENDPOINTS

public static final java.lang.String ENDPOINTS
See Also:
Constant Field Values

bus

protected Bus bus

bindingInterceptors

protected java.util.List<Interceptor> bindingInterceptors

routingInterceptors

protected java.util.List<Interceptor> routingInterceptors
Constructor Detail

MultipleEndpointObserver

public MultipleEndpointObserver(Bus bus)
Method Detail

onMessage

public void onMessage(Message message)
Description copied from interface: MessageObserver
Called for an incoming message, i.e. where the content format(s) is/are source(s).

Specified by:
onMessage in interface MessageObserver

createMessage

protected Message createMessage(Message message)
Give a chance for a Binding to customize their message


createChain

protected PhaseInterceptorChain createChain()

setExchangeProperties

protected void setExchangeProperties(Exchange exchange,
                                     Message m)

getBindingInterceptors

public java.util.List<Interceptor> getBindingInterceptors()

getRoutingInterceptors

public java.util.List<Interceptor> getRoutingInterceptors()

getEndpoints

public java.util.Set<Endpoint> getEndpoints()


Apache CXF