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
@NotNull TimeInterval	getAckDeadline()
int	getAckDeadlineSeconds()
@NotNull java.lang.Boolean	getAutoAcknowledge()
@NotNull java.lang.Boolean	getCreateSubscription()
@NotNull 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(@NotNull TimeInterval ackDeadline)
void	setAutoAcknowledge(@NotNull java.lang.Boolean autoAcknowledge)
void	setCreateSubscription(@NotNull java.lang.Boolean createSubscription)
void	setSubscriptionName(@NotNull 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

@NotNull
public @NotNull java.lang.String getSubscriptionName()

setSubscriptionName

public void setSubscriptionName(@NotNull
                                @NotNull java.lang.String subscriptionName)

getAckDeadline

@NotNull
public @NotNull TimeInterval getAckDeadline()

setAckDeadline

public void setAckDeadline(@NotNull
                           @NotNull TimeInterval ackDeadline)

getCreateSubscription

@NotNull
public @NotNull java.lang.Boolean getCreateSubscription()

setCreateSubscription

public void setCreateSubscription(@NotNull
                                  @NotNull java.lang.Boolean createSubscription)

getAutoAcknowledge

@NotNull
public @NotNull java.lang.Boolean getAutoAcknowledge()

setAutoAcknowledge

public void setAutoAcknowledge(@NotNull
                               @NotNull 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.