Class AssigningSubscriber (1.13.2)

Version latest

• 1.13.2 (latest)
• 1.13.0
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class AssigningSubscriber extends ProxyService implements Subscriber

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AssigningSubscriber

Implements

Subscriber

Inherited Members

AbstractApiService.addListener(ApiService.Listener,Executor)

AbstractApiService.awaitRunning()

AbstractApiService.awaitRunning(long,TimeUnit)

AbstractApiService.awaitTerminated()

AbstractApiService.awaitTerminated(long,TimeUnit)

AbstractApiService.failureCause()

AbstractApiService.isRunning()

AbstractApiService.notifyFailed(Throwable)

AbstractApiService.notifyStarted()

AbstractApiService.notifyStopped()

AbstractApiService.startAsync()

AbstractApiService.state()

AbstractApiService.stopAsync()

ProxyService.<T>addServices(Collection<T>)

ProxyService.addServices(ApiService)

ProxyService.doStart()

ProxyService.doStop()

ProxyService.handlePermanentError(CheckedApiException)

ProxyService.onPermanentError(CheckedApiException)

ProxyService.start()

ProxyService.stop()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)

public AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)

Parameters
Name	Description
subscriberFactory	PartitionSubscriberFactory
reassignmentHandler	ReassignmentHandler
assignerFactory	AssignerFactory

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)

Parameter
Name	Description
error	CheckedApiException

Overrides

ProxyService.handlePermanentError(CheckedApiException error)

stop()

protected synchronized void stop()

Overrides

ProxyService.stop()