public class GooglePubsubProducer
extends org.apache.camel.impl.DefaultProducer
Constructor and Description |
---|
GooglePubsubProducer(GooglePubsubEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
process(org.apache.camel.Exchange exchange)
The incoming message is expected to be either
- a List of Exchanges (aggregated)
- an Exchange
|
static byte[] |
serialize(Object obj) |
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public GooglePubsubProducer(GooglePubsubEndpoint endpoint) throws Exception
Exception
public void process(org.apache.camel.Exchange exchange) throws Exception
Exception
public static byte[] serialize(Object obj) throws IOException
IOException
Apache Camel