Package com.adaptris.google.cloud.pubsub.flowcontrol

Class FlowControlProvider

java.lang.Object

com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider

All Implemented Interfaces:

ComponentLifecycle

Direct Known Subclasses:

DefaultFlowControlProvider

public abstract class FlowControlProvider
extends Object
implements ComponentLifecycle

Constructor Summary

Constructors

Constructor	Description
FlowControlProvider()

Method Summary

Modifier and Type	Method	Description
abstract void	apply(com.google.cloud.pubsub.v1.Subscriber.Builder subscriberBuilder)
void	close()
void	init()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

FlowControlProvider

public FlowControlProvider()

Method Details

apply

public abstract void apply(com.google.cloud.pubsub.v1.Subscriber.Builder subscriberBuilder)

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