public class DefaultPublisherListener<T> extends java.lang.Object implements PublisherListener<T>
PublisherListener
which provides empty defaults for all signals.Constructor and Description |
---|
DefaultPublisherListener() |
Modifier and Type | Method and Description |
---|---|
void |
onMasterRegistrationFailure(Publisher<T> publisher)
The registrant has failed to register with the master.
|
void |
onMasterRegistrationSuccess(Publisher<T> publisher)
The registrant has been registered with the master.
|
void |
onMasterUnregistrationFailure(Publisher<T> publisher)
The registrant has failed to unregister with the master.
|
void |
onMasterUnregistrationSuccess(Publisher<T> publisher)
The registrant has been unregistered with the master.
|
void |
onNewSubscriber(Publisher<T> publisher,
SubscriberIdentifier subscriberIdentifier)
A
Subscriber has connected to the Publisher . |
void |
onShutdown(Publisher<T> publisher)
The
Publisher has been shut down. |
public void onMasterRegistrationSuccess(Publisher<T> publisher)
RegistrantListener
onMasterRegistrationSuccess
in interface RegistrantListener<Publisher<T>>
publisher
- the registrant which has been registeredpublic void onMasterRegistrationFailure(Publisher<T> publisher)
RegistrantListener
This may be called multiple times per registrant since master registration will be retried until success.
onMasterRegistrationFailure
in interface RegistrantListener<Publisher<T>>
publisher
- the registrant which has been registeredpublic void onMasterUnregistrationSuccess(Publisher<T> publisher)
RegistrantListener
onMasterUnregistrationSuccess
in interface RegistrantListener<Publisher<T>>
publisher
- the registrant which has been unregisteredpublic void onMasterUnregistrationFailure(Publisher<T> publisher)
RegistrantListener
This may be called multiple times per registrant since master unregistration will be retried until success.
onMasterUnregistrationFailure
in interface RegistrantListener<Publisher<T>>
publisher
- the registrant which has been unregisteredpublic void onNewSubscriber(Publisher<T> publisher, SubscriberIdentifier subscriberIdentifier)
PublisherListener
Subscriber
has connected to the Publisher
.onNewSubscriber
in interface PublisherListener<T>
publisher
- the Publisher
that the Subscriber
connected tosubscriberIdentifier
- the SubscriberIdentifier
of the new Subscriber
public void onShutdown(Publisher<T> publisher)
PublisherListener
Publisher
has been shut down.onShutdown
in interface PublisherListener<T>
publisher
- the Publisher
that was shut down