org.apache.servicemix.eip.patterns
Class Resequencer

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.support.resequence.ResequencerBase
                      org.apache.servicemix.eip.patterns.Resequencer

All Implemented Interfaces:

org.apache.servicemix.common.Endpoint, SequenceSender

public class Resequencer
extends ResequencerBase
implements SequenceSender

Author:

Martin Krasser

Field Summary

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

Resequencer()

Method Summary

protected void	processAsync(javax.jbi.messaging.MessageExchange exchange)
protected void	processSync(javax.jbi.messaging.MessageExchange exchange)
void	sendSync(List<javax.jbi.messaging.MessageExchange> exchanges) Synchronously sends a list of message exchanges in the order given by the argument list.
void	sendSync(javax.jbi.messaging.MessageExchange exchange) Synchronously sends a single message exchange.
void	setCapacity(int capacity)
void	setComparator(SequenceElementComparator<javax.jbi.messaging.MessageExchange> comparator)
void	setTimeout(long timeout)
void	start()
void	stop()

Methods inherited from class org.apache.servicemix.eip.support.resequence.ResequencerBase

createTargetExchange, getMessageCopier, getTarget, setTarget, validate, validateMessageExchange

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, process, setLockManager, setStore, setStoreFactory, setTimerManager, setWsdlExchangeTarget, setWsdlResource

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

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Resequencer

public Resequencer()

Method Detail

setCapacity

public void setCapacity(int capacity)

setTimeout

public void setTimeout(long timeout)

setComparator

public void setComparator(SequenceElementComparator<javax.jbi.messaging.MessageExchange> comparator)

start

public void start()
           throws Exception

Specified by:

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

Overrides:

start in class EIPEndpoint

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

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

Overrides:

stop in class EIPEndpoint

Throws:

Exception

sendSync

public void sendSync(javax.jbi.messaging.MessageExchange exchange)
              throws javax.jbi.messaging.MessagingException

Description copied from interface: SequenceSender

Synchronously sends a single message exchange.

Specified by:

sendSync in interface SequenceSender

Overrides:

sendSync in class org.apache.servicemix.common.endpoints.SimpleEndpoint

Parameters:

exchange - a message exchange.

Throws:

javax.jbi.messaging.MessagingException - if a system-level error occurs.

sendSync

public void sendSync(List<javax.jbi.messaging.MessageExchange> exchanges)
              throws javax.jbi.messaging.MessagingException

Description copied from interface: SequenceSender

Synchronously sends a list of message exchanges in the order given by the argument list.

Specified by:

sendSync in interface SequenceSender

Parameters:

exchanges - a list of message exchanges.

Throws:

javax.jbi.messaging.MessagingException - if a system-level error occurs.

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