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

Class PubSubConfiguration.FlowControl

java.lang.Object

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

Enclosing class:

PubSubConfiguration

public static class PubSubConfiguration.FlowControl
extends Object

flow control settings.

Constructor Summary

Constructors

Constructor	Description
FlowControl()

Method Summary

Modifier and Type	Method	Description
com.google.api.gax.batching.FlowController.LimitExceededBehavior	getLimitExceededBehavior()
Long	getMaxOutstandingElementCount()
Long	getMaxOutstandingRequestBytes()
void	setLimitExceededBehavior(com.google.api.gax.batching.FlowController.LimitExceededBehavior limitExceededBehavior)
void	setMaxOutstandingElementCount(Long maxOutstandingElementCount)
void	setMaxOutstandingRequestBytes(Long maxOutstandingRequestBytes)

Methods inherited from class java.lang.Object

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

Constructor Details

FlowControl

public FlowControl()

Method Details

getMaxOutstandingElementCount

public Long getMaxOutstandingElementCount()

setMaxOutstandingElementCount

public void setMaxOutstandingElementCount(Long maxOutstandingElementCount)

getMaxOutstandingRequestBytes

public Long getMaxOutstandingRequestBytes()

setMaxOutstandingRequestBytes

public void setMaxOutstandingRequestBytes(Long maxOutstandingRequestBytes)

getLimitExceededBehavior

public com.google.api.gax.batching.FlowController.LimitExceededBehavior getLimitExceededBehavior()

setLimitExceededBehavior

public void setLimitExceededBehavior(com.google.api.gax.batching.FlowController.LimitExceededBehavior limitExceededBehavior)