public class JmsPollingConsumer
extends org.apache.camel.impl.PollingConsumerSupport
implements org.apache.camel.ServicePoolAware
PollingConsumer
.Constructor and Description |
---|
JmsPollingConsumer(JmsEndpoint endpoint) |
JmsPollingConsumer(JmsEndpoint endpoint,
org.springframework.jms.core.JmsOperations template) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
JmsEndpoint |
getEndpoint() |
org.apache.camel.Exchange |
receive() |
org.apache.camel.Exchange |
receive(long timeout) |
org.apache.camel.Exchange |
receiveNoWait() |
protected void |
setReceiveTimeout(long timeout) |
getExceptionHandler, handleException, setExceptionHandler, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JmsPollingConsumer(JmsEndpoint endpoint, org.springframework.jms.core.JmsOperations template)
public JmsPollingConsumer(JmsEndpoint endpoint)
public JmsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.PollingConsumerSupport
public org.apache.camel.Exchange receiveNoWait()
receiveNoWait
in interface org.apache.camel.PollingConsumer
public org.apache.camel.Exchange receive()
receive
in interface org.apache.camel.PollingConsumer
public org.apache.camel.Exchange receive(long timeout)
receive
in interface org.apache.camel.PollingConsumer
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
protected void setReceiveTimeout(long timeout)
Apache Camel