Package com.adaptris.google.cloud.pubsub

Class GoogleCloudPubSubResponseProducer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.ProduceOnlyProducerImp

com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

@ComponentProfile(summary="Publish a ack/nack message to Google pubsub (when auto-acknowledge=false on the consumer)",
                  tag="producer,gcloud,messaging",
                  recommended=com.adaptris.core.NullConnection.class)
public class GoogleCloudPubSubResponseProducer
extends ProduceOnlyProducerImp

In the adapter configuration file this class is aliased as google-cloud-pubsub-response-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

Constructors

Constructor	Description
GoogleCloudPubSubResponseProducer()
GoogleCloudPubSubResponseProducer(ReplyProvider.AckReply reply)

Method Summary

Modifier and Type	Method	Description
protected void	doProduce(AdaptrisMessage msg, java.lang.String ignored)
java.lang.String	endpoint(AdaptrisMessage msg)
@NotNull @NonNull ReplyProvider	getReplyProvider()
void	prepare()
void	setReplyProvider(@NotNull @NonNull ReplyProvider replyProvider)

Methods 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

close, init, start, stop

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createQualifier, isTrackingEndpoint

Constructor Detail

GoogleCloudPubSubResponseProducer

public GoogleCloudPubSubResponseProducer()

GoogleCloudPubSubResponseProducer

public GoogleCloudPubSubResponseProducer(ReplyProvider.AckReply reply)

Method Detail

doProduce

protected void doProduce(AdaptrisMessage msg,
                         java.lang.String ignored)
                  throws ProduceException

Specified by:

doProduce in class ProduceOnlyProducerImp

Throws:

ProduceException

prepare

public void prepare()
             throws CoreException

Throws:

CoreException

endpoint

public java.lang.String endpoint(AdaptrisMessage msg)
                          throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

getReplyProvider

@NotNull
@NonNull
public @NotNull @NonNull ReplyProvider getReplyProvider()

setReplyProvider

public void setReplyProvider(@NotNull @NonNull
                             @NotNull @NonNull ReplyProvider replyProvider)