public class Jt400DataQueueConsumer
extends org.apache.camel.impl.ScheduledPollConsumer
Consumer
that polls a data queue for dataConstructor and Description |
---|
Jt400DataQueueConsumer(Jt400Endpoint endpoint,
org.apache.camel.Processor processor)
Creates a new consumer instance
|
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
Jt400Endpoint |
getEndpoint() |
protected int |
poll() |
org.apache.camel.Exchange |
receive()
Deprecated.
|
org.apache.camel.Exchange |
receive(long timeout)
Receives an entry from a data queue and returns an
Exchange to
send this data If the endpoint's format is set to Jt400Configuration.Format.binary ,
the data queue entry's data will be received/sent as a
byte[] . |
org.apache.camel.Exchange |
receiveNoWait()
Deprecated.
|
afterPoll, beforePoll, doShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public Jt400DataQueueConsumer(Jt400Endpoint endpoint, org.apache.camel.Processor processor)
public Jt400Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
@Deprecated public org.apache.camel.Exchange receive()
@Deprecated public org.apache.camel.Exchange receiveNoWait()
public org.apache.camel.Exchange receive(long timeout)
Exchange
to
send this data If the endpoint's format is set to Jt400Configuration.Format.binary
,
the data queue entry's data will be received/sent as a
byte[]
. If the endpoint's format is set to
Jt400Configuration.Format.text
, the data queue entry's data will be received/sent as
a String
.
The following message headers may be set by the receiver
KeyedDataQueue
timeout
- time to wait when reading from data queue. A value of -1
indicates a blocking read.Apache Camel