| org.apache.servicemix.components.util.ComponentSupport
 org.apache.servicemix.client.DefaultServiceMixClient
All known Subclasses: org.apache.servicemix.client.RemoteServiceMixClient,
| Constructor Summary | |
| protected | DefaultServiceMixClient()
| | public | DefaultServiceMixClient(JBIContainer container)
Provides the JBI container used for message dispatch. | | public | DefaultServiceMixClient(JBIContainer container, ActivationSpec activationSpec)
Provides the JBI container and the activation specification, which can be used to register this
client at a specific endpoint so that default container routing rules can be configured via dependency injection
and the client endpoint metadata can be configured to allow services to talk to this client. |
| Method Summary | |
| public void | close()
| | protected void | configureEndpoint(MessageExchange exchange, EndpointResolver resolver)
| | public Destination | createDestination(String uri)
| | public InOnly | createInOnlyExchange()
| | public InOnly | createInOnlyExchange(EndpointResolver resolver)
| | public InOptionalOut | createInOptionalOutExchange()
| | public InOptionalOut | createInOptionalOutExchange(EndpointResolver resolver)
| | public InOut | createInOutExchange()
| | public InOut | createInOutExchange(EndpointResolver resolver)
| | public EndpointResolver | createResolverForExternalInterface(QName interfaceName)
| | public EndpointResolver | createResolverForExternalInterface(QName service, String endpoint)
| | public EndpointResolver | createResolverForExternalService(QName service)
| | public EndpointResolver | createResolverForService(QName service)
| | public EndpointResolver | createResolverInterface(QName interfaceName)
| | public RobustInOnly | createRobustInOnlyExchange()
| | public RobustInOnly | createRobustInOnlyExchange(EndpointResolver resolver)
| | public void | done(MessageExchange exchange)
| | public void | fail(MessageExchange exchange, Fault fault)
| | public void | fail(MessageExchange exchange, Exception error)
| | public ComponentContext | getContext()
| | public DeliveryChannel | getDeliveryChannel()
| | public MessageExchangeFactory | getExchangeFactory()
| | public EndpointFilter | getFilter()
| | public PojoMarshaler | getMarshaler()
| | protected void | populateExchangeProperties(MessageExchange exchange, Map properties)
| | protected void | populateMessage(MessageExchange exchange, Map exchangeProperties, Map inMessageProperties, Object content)
| | protected void | populateMessageProperties(NormalizedMessage message, Map properties)
| | public MessageExchange | receive()
| | public MessageExchange | receive(long timeout)
| | public Object | request(Map inMessageProperties, Object content)
| | public Object | request(EndpointResolver resolver, Map exchangeProperties, Map inMessageProperties, Object content)
| | public ServiceEndpoint | resolveEndpointReference(String uri)
| | public void | send(MessageExchange exchange)
| | public void | send(Message message)
| | public void | send(Map inMessageProperties, Object content)
| | public void | send(EndpointResolver resolver, Map exchangeProperties, Map inMessageProperties, Object content)
| | public boolean | sendSync(MessageExchange exchange)
| | public boolean | sendSync(MessageExchange exchange, long timeout)
| | public boolean | sendSync(Map inMessageProperties, Object content)
| | public boolean | sendSync(EndpointResolver resolver, Map exchangeProperties, Map inMessageProperties, Object content)
| | public void | setFilter(EndpointFilter filter)
| | public void | setMarshaler(PojoMarshaler marshaler)
Sets the marshaler used to convert objects which are not already JAXP
Source instances
into the normalized message content. |
| DefaultServiceMixClient | | protected DefaultServiceMixClient()(Code) | | |
| DefaultServiceMixClient | | public DefaultServiceMixClient(JBIContainer container) throws JBIException(Code) | | Provides the JBI container used for message dispatch.
|
| DefaultServiceMixClient | | public DefaultServiceMixClient(JBIContainer container, ActivationSpec activationSpec) throws JBIException(Code) | | Provides the JBI container and the activation specification, which can be used to register this
client at a specific endpoint so that default container routing rules can be configured via dependency injection
and the client endpoint metadata can be configured to allow services to talk to this client.
|
| resolveEndpointReference | | public ServiceEndpoint resolveEndpointReference(String uri)(Code) | | Resolves a WS-Addressing endpoint reference String into a JBI
ServiceEndpoint reference so that message exchanges can be directed to an endpoint
|
| setFilter | | public void setFilter(EndpointFilter filter)(Code) | | Sets the filter used to exclude possible endpoints based on their capabilities
Parameters:
filter - |
| setMarshaler | | public void setMarshaler(PojoMarshaler marshaler)(Code) | | Sets the marshaler used to convert objects which are not already JAXP
Source instances
into the normalized message content.
Parameters:
marshaler - |
| Methods inherited from org.apache.servicemix.components.util.ComponentSupport | public InOut creatInOutExchange(QName service, QName interfaceName, QName operation, MessageExchange srcExchange) throws MessagingException(Code)(Java Doc)
protected ComponentLifeCycle createComponentLifeCycle()(Code)(Java Doc)
public InOnly createInOnlyExchange(QName service, QName interfaceName, QName operation) throws MessagingException(Code)(Java Doc)
public InOnly createInOnlyExchange(QName service, QName interfaceName, QName operation, MessageExchange beforeExchange) throws MessagingException(Code)(Java Doc)
public InOnly createInOnlyExchange(MessageExchange srcExchange) throws MessagingException(Code)(Java Doc)
public InOptionalOut createInOptionalOutExchange(MessageExchange srcExchange) throws MessagingException(Code)(Java Doc)
public InOut createInOutExchange(QName service, QName interfaceName, QName operation) throws MessagingException(Code)(Java Doc)
public InOut createInOutExchange(MessageExchange srcExchange) throws MessagingException(Code)(Java Doc)
public RobustInOnly createRobustInOnlyExchange(MessageExchange srcExchange) throws MessagingException(Code)(Java Doc)
protected ServiceUnitManager createServiceUnitManager()(Code)(Java Doc)
protected void forwardToExchange(MessageExchange exchange, InOnly outExchange, NormalizedMessage in, QName operationName) throws MessagingException(Code)(Java Doc)
protected void forwardToExchange(MessageExchange exchange, InOnly outExchange, NormalizedMessage in) throws MessagingException(Code)(Java Doc)
protected NormalizedMessage getInMessage(MessageExchange exchange) throws NoInMessageAvailableException(Code)(Java Doc)
public ComponentLifeCycle getLifeCycle()(Code)(Java Doc)
public MessageTransformer getMessageTransformer()(Code)(Java Doc)
public Document getServiceDescription(ServiceEndpoint endpoint)(Code)(Java Doc)
public ServiceUnitManager getServiceUnitManager()(Code)(Java Doc)
protected synchronized void initializeServiceUnitManager()(Code)(Java Doc)
public void invoke(MessageExchange exchange, NormalizedMessage in, QName service, QName interfaceName, QName operation) throws MessagingException(Code)(Java Doc)
public boolean isExchangeWithConsumerOkay(ServiceEndpoint endpoint, MessageExchange exchange)(Code)(Java Doc)
public boolean isExchangeWithProviderOkay(ServiceEndpoint endpoint, MessageExchange exchange)(Code)(Java Doc)
public void propagateCorrelationId(MessageExchange source, MessageExchange dest)(Code)(Java Doc)
public ServiceEndpoint resolveEndpointReference(DocumentFragment fragment)(Code)(Java Doc)
public void setMessageTransformer(MessageTransformer transformer)(Code)(Java Doc)
|
|
|