Class GooglePubsubProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.component.google.pubsub.GooglePubsubProducer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.EndpointAware
,org.apache.camel.IsSingleton
,org.apache.camel.Processor
,org.apache.camel.Producer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class GooglePubsubProducer extends org.apache.camel.support.DefaultProducer
Generic PubSub Producer
-
-
Field Summary
Fields Modifier and Type Field Description org.slf4j.Logger
logger
-
Constructor Summary
Constructors Constructor Description GooglePubsubProducer(GooglePubsubEndpoint endpoint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
process(org.apache.camel.Exchange exchange)
The incoming message is expected to be either - a List of Exchanges (aggregated) - an Exchange-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, doStart, doStop, getEndpoint, isSingleton, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
GooglePubsubProducer
public GooglePubsubProducer(GooglePubsubEndpoint endpoint) throws Exception
- Throws:
Exception
-
-