org.apache.camel.component.seda
Class ListPollingConsumer
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.impl.PollingConsumerSupport
org.apache.camel.component.seda.ListPollingConsumer
- All Implemented Interfaces:
- Consumer, PollingConsumer, Service
public class ListPollingConsumer
- extends PollingConsumerSupport
- Version:
- $Revision: 36321 $
Method Summary |
protected void |
doStart()
|
protected void |
doStop()
|
Exchange |
receive()
Waits until a message is available and then returns it. |
Exchange |
receive(long timeout)
Attempts to receive a message exchange, waiting up to the given timeout
to expire if a message is not yet available |
Exchange |
receiveNoWait()
Attempts to receive a message exchange immediately without waiting and
returning null if a message exchange is not available yet. |
Methods inherited from class org.apache.camel.impl.ServiceSupport |
addChildService, getThreadName, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop |
ListPollingConsumer
public ListPollingConsumer(Endpoint endpoint,
List<Exchange> exchanges)
receive
public Exchange receive()
- Description copied from interface:
PollingConsumer
- Waits until a message is available and then returns it. Warning that this
method could block indefinitely if no messages are available.
- Returns:
- the message exchange received.
receiveNoWait
public Exchange receiveNoWait()
- Description copied from interface:
PollingConsumer
- Attempts to receive a message exchange immediately without waiting and
returning null if a message exchange is not available yet.
- Returns:
- the message exchange if one is immediately available otherwise
null
receive
public Exchange receive(long timeout)
- Description copied from interface:
PollingConsumer
- Attempts to receive a message exchange, waiting up to the given timeout
to expire if a message is not yet available
- Parameters:
timeout
- the amount of time in milliseconds to wait for a message
before timing out and returning null
- Returns:
- the message exchange if one iwas available within the timeout
period, or null if the timeout expired
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
Copyright © 2008 IONA Open Source Community. All Rights Reserved.