Class AssigningSubscriber (1.6.3)

Stay organized with collections Save and categorize content based on your preferences.
public class AssigningSubscriber extends ProxyService implements Subscriber

Inheritance

java.lang.Object > AbstractApiService > ProxyService > AssigningSubscriber

Implements

Subscriber

Constructors

AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)

public AssigningSubscriber(PartitionSubscriberFactory subscriberFactory, ReassignmentHandler reassignmentHandler, AssignerFactory assignerFactory)
Parameters
NameDescription
subscriberFactoryPartitionSubscriberFactory
reassignmentHandlerReassignmentHandler
assignerFactoryAssignerFactory

Methods

handlePermanentError(CheckedApiException error)

protected void handlePermanentError(CheckedApiException error)
Parameter
NameDescription
errorCheckedApiException
Overrides

stop()

protected synchronized void stop()
Overrides