org.apache.servicemix.eip.patterns
Class AsyncBridge

java.lang.Object
  org.apache.servicemix.common.endpoints.AbstractEndpoint
      org.apache.servicemix.common.endpoints.SimpleEndpoint
          org.apache.servicemix.common.endpoints.ProviderEndpoint
              org.apache.servicemix.eip.EIPEndpoint
                  org.apache.servicemix.eip.patterns.AsyncBridge

All Implemented Interfaces:

org.apache.servicemix.common.Endpoint

public class AsyncBridge
extends EIPEndpoint

Author:

gnodet

Field Summary

static String

CORRID

Fields inherited from class org.apache.servicemix.eip.EIPEndpoint

lockManager, store, storeFactory, timerManager, wsdlExchangeTarget, wsdlResource

Fields inherited from class org.apache.servicemix.common.endpoints.AbstractEndpoint

definition, description, endpoint, interfaceName, logger, service, serviceUnit

Constructor Summary

AsyncBridge()

Method Summary

org.apache.servicemix.expression.Expression	getRequestCorrId()
org.apache.servicemix.expression.Expression	getResponseCorrId()
String	getResponseCorrIdProperty()
ExchangeTarget	getTarget()
long	getTimeout()
protected Date	getTimeout(javax.jbi.messaging.MessageExchange exchange)
boolean	isUseRobustInOnly()
protected void	onTimeout(String correlationId)
void	process(javax.jbi.messaging.MessageExchange exchange)
protected void	processAsync(javax.jbi.messaging.MessageExchange exchange)
protected void	processSync(javax.jbi.messaging.MessageExchange exchange)
void	setRequestCorrId(org.apache.servicemix.expression.Expression requestCorrId)
void	setResponseCorrId(org.apache.servicemix.expression.Expression responseCorrId)
void	setResponseCorrIdProperty(String responseCorrIdProperty)
void	setTarget(ExchangeTarget target)
void	setTimeout(long timeout)
void	setUseRobustInOnly(boolean useRobustInOnly)
void	start()

Methods inherited from class org.apache.servicemix.eip.EIPEndpoint

chooseFirstEndpointWithDescriptor, copyAttachments, copyProperties, getDefinition, getDefinitionFromDescription, getDefinitionFromWsdlExchangeTarget, getDefinitionFromWsdlResource, getDescription, getDescriptionForExchangeTarget, getEndpointsForExchangeTarget, getLockManager, getStore, getStoreFactory, getTimerManager, getWsdlExchangeTarget, getWsdlResource, setLockManager, setStore, setStoreFactory, setTimerManager, setWsdlExchangeTarget, setWsdlResource, stop

Methods inherited from class org.apache.servicemix.common.endpoints.ProviderEndpoint

activate, deactivate, getRole, processInOnly, processInOut

Methods inherited from class org.apache.servicemix.common.endpoints.SimpleEndpoint

done, fail, getChannel, getContext, getExchangeFactory, send, sendSync

Methods inherited from class org.apache.servicemix.common.endpoints.AbstractEndpoint

getEndpoint, getInterfaceName, getKey, getService, getServiceUnit, isExchangeOkay, prepareExchange, setDefinition, setDescription, setEndpoint, setInterfaceName, setService, setServiceUnit, toString, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CORRID

public static final String CORRID

See Also:

Constant Field Values

Constructor Detail

AsyncBridge

public AsyncBridge()

Method Detail

getTimeout

public long getTimeout()

Returns:

the timeout

setTimeout

public void setTimeout(long timeout)

Parameters:

timeout - the timeout to set

getTarget

public ExchangeTarget getTarget()

Returns:

the target

setTarget

public void setTarget(ExchangeTarget target)

Parameters:

target - the target to set

getRequestCorrId

public org.apache.servicemix.expression.Expression getRequestCorrId()

Returns:

the requestCorrId

setRequestCorrId

public void setRequestCorrId(org.apache.servicemix.expression.Expression requestCorrId)

Parameters:

requestCorrId - the requestCorrId to set

getResponseCorrIdProperty

public String getResponseCorrIdProperty()

Returns:

the responseCorrIdProperty

setResponseCorrIdProperty

public void setResponseCorrIdProperty(String responseCorrIdProperty)

Parameters:

responseCorrIdProperty - the responseCorrIdProperty to set

getResponseCorrId

public org.apache.servicemix.expression.Expression getResponseCorrId()

Returns:

the responseCorrId

setResponseCorrId

public void setResponseCorrId(org.apache.servicemix.expression.Expression responseCorrId)

Parameters:

responseCorrId - the responseCorrId to set

isUseRobustInOnly

public boolean isUseRobustInOnly()

Returns:

the useRobustInOnly

setUseRobustInOnly

public void setUseRobustInOnly(boolean useRobustInOnly)

Parameters:

useRobustInOnly - the useRobustInOnly to set

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.servicemix.common.Endpoint

Overrides:

start in class EIPEndpoint

Throws:

Exception

processSync

protected void processSync(javax.jbi.messaging.MessageExchange exchange)
                    throws Exception

Specified by:

processSync in class EIPEndpoint

Throws:

Exception

processAsync

protected void processAsync(javax.jbi.messaging.MessageExchange exchange)
                     throws Exception

Specified by:

processAsync in class EIPEndpoint

Throws:

Exception

process

public void process(javax.jbi.messaging.MessageExchange exchange)
             throws Exception

Specified by:

process in interface org.apache.servicemix.common.Endpoint

Overrides:

process in class EIPEndpoint

Throws:

Exception

onTimeout

protected void onTimeout(String correlationId)

getTimeout

protected Date getTimeout(javax.jbi.messaging.MessageExchange exchange)