Package com.adaptris.google.cloud.pubsub
Class GoogleCloudPubSubProducer
java.lang.Object
com.adaptris.core.AdaptrisMessageWorkerImp
com.adaptris.core.AdaptrisMessageProducerImp
com.adaptris.core.ProduceOnlyProducerImp
com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
@ComponentProfile(summary="Publish a message to Google pubsub",
tag="producer,gcloud,messaging",
recommended=GoogleCloudPubSubConnection.class)
public class GoogleCloudPubSubProducer
extends ProduceOnlyProducerImp
In the adapter configuration file this class is aliased as google-cloud-pubsub-producer which is the preferred alternative to the fully qualified classname when building your configuration.
-
Field Summary
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
protected void
doProduce
(AdaptrisMessage adaptrisMessage, String endpoint) endpoint
(AdaptrisMessage msg) getTopic()
The pubsub topicvoid
init()
void
prepare()
void
setCreateTopic
(Boolean createTopic) void
setMetadataFilter
(MetadataFilter metadataFilter) void
setPublisherCacheLimit
(Integer publisherCacheLimit) void
The pubsub topic<T extends GoogleCloudPubSubProducer>
TMethods inherited from class com.adaptris.core.ProduceOnlyProducerImp
produce, request, request
Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp
createName
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
Methods inherited from interface com.adaptris.core.ComponentLifecycle
start, stop
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createQualifier, isTrackingEndpoint
-
Constructor Details
-
GoogleCloudPubSubProducer
public GoogleCloudPubSubProducer()
-
-
Method Details
-
doProduce
- Specified by:
doProduce
in classProduceOnlyProducerImp
- Throws:
ProduceException
-
prepare
- Throws:
CoreException
-
init
- Throws:
CoreException
-
close
public void close() -
withTopic
-
endpoint
- Specified by:
endpoint
in classAdaptrisMessageProducerImp
- Throws:
ProduceException
-
getCreateTopic
-
setCreateTopic
-
getPublisherCacheLimit
-
setPublisherCacheLimit
-
getMetadataFilter
-
setMetadataFilter
-
getTopic
The pubsub topic -
setTopic
The pubsub topic
-