org.apache.servicemix.eip.support.resequence
Class SequenceReader

java.lang.Object
  org.apache.servicemix.eip.support.resequence.SequenceReader

All Implemented Interfaces:

Runnable

public class SequenceReader
extends Object
implements Runnable

Author:

Martin Krasser

Constructor Summary

SequenceReader(SequenceSender sender)

Method Summary

void	run()
void	setQueue(BlockingQueue<javax.jbi.messaging.MessageExchange> queue)
void	start(org.apache.servicemix.executors.Executor executor)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceReader

public SequenceReader(SequenceSender sender)

Method Detail

setQueue

public void setQueue(BlockingQueue<javax.jbi.messaging.MessageExchange> queue)

run

public void run()

Specified by:

run in interface Runnable

start

public void start(org.apache.servicemix.executors.Executor executor)

stop

public void stop()
          throws InterruptedException

Throws:

InterruptedException