Package com.adaptris.google.cloud.pubsub

Class GoogleCloudPubSubPullConsumer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.google.cloud.pubsub.ConsumeConfig

com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator, StateManagedComponent, com.google.cloud.pubsub.v1.MessageReceiver

@ComponentProfile(summary="Receive a message to Google pubsub",
                  tag="consumer,gcloud,messaging",
                  metadata={"gcloud_topic","gcloud_projectName","gcloud_subscriptionName","gcloud_publishTime"},
                  recommended=GoogleCloudPubSubConnection.class)
public class GoogleCloudPubSubPullConsumer
extends ConsumeConfig
implements com.google.cloud.pubsub.v1.MessageReceiver

In the adapter configuration file this class is aliased as google-cloud-pubsub-pull-consumer 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
GoogleCloudPubSubPullConsumer()

Method Summary

Modifier and Type	Method	Description
void	close()
void	init()
void	receiveMessage(com.google.pubsub.v1.PubsubMessage pubsubMessage, com.google.cloud.pubsub.v1.AckReplyConsumer consumer)
void	start()
void	stop()

Methods inherited from class com.adaptris.google.cloud.pubsub.ConsumeConfig

getAckDeadline, getAckDeadlineSeconds, getAutoAcknowledge, getCreateSubscription, getSubscriptionName, getTopic, getTopicName, newThreadName, prepare, setAckDeadline, setAutoAcknowledge, setCreateSubscription, setSubscriptionName, setTopic

Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp

changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createName, 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.AdaptrisMessageConsumer

consumeLocationKey

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isTrackingEndpoint

Constructor Detail

GoogleCloudPubSubPullConsumer

public GoogleCloudPubSubPullConsumer()

Method Detail

init

public void init()
          throws CoreException

Specified by:

init in interface ComponentLifecycle

Throws:

CoreException

start

public void start()
           throws CoreException

Specified by:

start in interface ComponentLifecycle

Throws:

CoreException

stop

public void stop()

Specified by:

stop in interface ComponentLifecycle

close

public void close()

Specified by:

close in interface ComponentLifecycle

receiveMessage

public void receiveMessage(com.google.pubsub.v1.PubsubMessage pubsubMessage,
                           com.google.cloud.pubsub.v1.AckReplyConsumer consumer)

Specified by:

receiveMessage in interface com.google.cloud.pubsub.v1.MessageReceiver