public class Jt400DataQueueProducer
extends org.apache.camel.impl.DefaultProducer
Producer
to send data to an AS/400 data queue.Modifier | Constructor and Description |
---|---|
protected |
Jt400DataQueueProducer(Jt400Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
process(org.apache.camel.Exchange exchange)
Sends the
Exchange 's in body to the AS/400 data queue. |
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected Jt400DataQueueProducer(Jt400Endpoint endpoint)
public void process(org.apache.camel.Exchange exchange) throws Exception
Exchange
's in body to the AS/400 data queue. If the
endpoint's format is set to Jt400Configuration.Format.binary
, the data queue entry's
data will be sent as a byte[]
. If the endpoint's format is
set to Jt400Configuration.Format.text
, the data queue entry's data will be sent as a
String
.
If the endpoint is configured to publish to a KeyedDataQueue
,
then the Message
header KEY
must be set.Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
Apache Camel