|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.PollingConsumerSupport org.apache.camel.component.jt400.Jt400DataQueueConsumer
public class Jt400DataQueueConsumer
PollingConsumer
that polls a data queue for data
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.PollingConsumerSupport |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
protected |
Jt400DataQueueConsumer(Jt400DataQueueEndpoint endpoint)
Creates a new consumer instance |
Method Summary | |
---|---|
protected void |
doStart()
|
protected void |
doStop()
|
org.apache.camel.Exchange |
receive()
|
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 Jt400DataQueueEndpoint.Format.binary ,
the data queue entry's data will be received/sent as a
byte[] . |
org.apache.camel.Exchange |
receiveNoWait()
|
Methods inherited from class org.apache.camel.impl.PollingConsumerSupport |
---|
getEndpoint, getExceptionHandler, handleException, setExceptionHandler, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
protected Jt400DataQueueConsumer(Jt400DataQueueEndpoint endpoint)
Method Detail |
---|
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
public org.apache.camel.Exchange receive()
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 Jt400DataQueueEndpoint.Format.binary
,
the data queue entry's data will be received/sent as a
byte[]
. If the endpoint's format is set to
Jt400DataQueueEndpoint.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.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |