Package com.adaptris.google.cloud.pubsub

Class ConsumeConfig

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.google.cloud.pubsub.ConsumeConfig

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageConsumer, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator, StateManagedComponent

Direct Known Subclasses:

GoogleCloudPubSubPullConsumer

public abstract class ConsumeConfig
extends AdaptrisMessageConsumerImp

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
ConsumeConfig()

Method Summary

Modifier and Type	Method	Description
TimeInterval	getAckDeadline()
int	getAckDeadlineSeconds()
java.lang.Boolean	getAutoAcknowledge()
java.lang.Boolean	getCreateSubscription()
java.lang.String	getSubscriptionName()
java.lang.String	getTopic()	The pubsub topic name.
java.lang.String	getTopicName()
protected java.lang.String	newThreadName()
void	prepare()
void	setAckDeadline(TimeInterval ackDeadline)
void	setAutoAcknowledge(java.lang.Boolean autoAcknowledge)
void	setCreateSubscription(java.lang.Boolean createSubscription)
void	setSubscriptionName(java.lang.String subscriptionName)
void	setTopic(java.lang.String topic)	The pubsub topic name.

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.ComponentLifecycle

close, init, start, stop

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isTrackingEndpoint

Constructor Detail

ConsumeConfig

public ConsumeConfig()

Method Detail

prepare

public void prepare()
             throws CoreException

Throws:

CoreException

getTopicName

public java.lang.String getTopicName()

getAckDeadlineSeconds

public int getAckDeadlineSeconds()

newThreadName

protected java.lang.String newThreadName()

Overrides:

newThreadName in class AdaptrisMessageConsumerImp

getSubscriptionName

public java.lang.String getSubscriptionName()

setSubscriptionName

public void setSubscriptionName(java.lang.String subscriptionName)

getAckDeadline

public TimeInterval getAckDeadline()

setAckDeadline

public void setAckDeadline(TimeInterval ackDeadline)

getCreateSubscription

public java.lang.Boolean getCreateSubscription()

setCreateSubscription

public void setCreateSubscription(java.lang.Boolean createSubscription)

getAutoAcknowledge

public java.lang.Boolean getAutoAcknowledge()

setAutoAcknowledge

public void setAutoAcknowledge(java.lang.Boolean autoAcknowledge)

getTopic

public java.lang.String getTopic()

The pubsub topic name.

setTopic

public void setTopic(java.lang.String topic)

The pubsub topic name.