Package com.google.cloud.spring.pubsub.core

Class PubSubConfiguration.Publisher

java.lang.Object

com.google.cloud.spring.pubsub.core.PubSubConfiguration.Publisher

Enclosing class:

PubSubConfiguration

public static class PubSubConfiguration.Publisher
extends Object

Publisher settings.

Constructor Summary

Constructors

Constructor	Description
Publisher()

Method Summary

Modifier and Type	Method	Description
PubSubConfiguration.Batching	getBatching()
Boolean	getEnableMessageOrdering()
String	getEndpoint()
Boolean	getExecutorAcceptTasksAfterContextClose()
long	getExecutorAwaitTerminationMillis()
int	getExecutorThreads()
Boolean	getExecutorWaitForTasksToCompleteOnShutdown()
PubSubConfiguration.Retry	getRetry()
void	setEnableMessageOrdering(Boolean enableMessageOrdering)
void	setEndpoint(String endpoint)
void	setExecutorAcceptTasksAfterContextClose(Boolean executorAcceptTasksAfterContextClose)
void	setExecutorAwaitTerminationMillis(long executorAwaitTerminationMillis)
void	setExecutorThreads(int executorThreads)
void	setExecutorWaitForTasksToCompleteOnShutdown(Boolean executorWaitForTasksToCompleteOnShutdown)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Publisher

public Publisher()

Method Details

getBatching

public PubSubConfiguration.Batching getBatching()

getRetry

public PubSubConfiguration.Retry getRetry()

getExecutorThreads

public int getExecutorThreads()

setExecutorThreads

public void setExecutorThreads(int executorThreads)

getExecutorAcceptTasksAfterContextClose

public Boolean getExecutorAcceptTasksAfterContextClose()

setExecutorAcceptTasksAfterContextClose

public void setExecutorAcceptTasksAfterContextClose(Boolean executorAcceptTasksAfterContextClose)

getExecutorWaitForTasksToCompleteOnShutdown

public Boolean getExecutorWaitForTasksToCompleteOnShutdown()

setExecutorWaitForTasksToCompleteOnShutdown

public void setExecutorWaitForTasksToCompleteOnShutdown(Boolean executorWaitForTasksToCompleteOnShutdown)

getExecutorAwaitTerminationMillis

public long getExecutorAwaitTerminationMillis()

setExecutorAwaitTerminationMillis

public void setExecutorAwaitTerminationMillis(long executorAwaitTerminationMillis)

getEnableMessageOrdering

public Boolean getEnableMessageOrdering()

setEnableMessageOrdering

public void setEnableMessageOrdering(Boolean enableMessageOrdering)

getEndpoint

public String getEndpoint()

setEndpoint

public void setEndpoint(String endpoint)