public abstract class DefaultTopicParticipant extends java.lang.Object implements TopicParticipant
TopicSystemState
.Constructor and Description |
---|
DefaultTopicParticipant(TopicDeclaration topicDeclaration) |
Modifier and Type | Method and Description |
---|---|
TopicDeclaration |
getTopicDeclaration() |
java.util.List<java.lang.String> |
getTopicDeclarationAsList() |
ConnectionHeader |
getTopicDeclarationHeader() |
java.lang.String |
getTopicMessageType() |
GraphName |
getTopicName() |
abstract void |
signalOnMasterRegistrationFailure()
Signal that the
TopicSystemState failed to register with the master. |
abstract void |
signalOnMasterRegistrationSuccess()
Signal that the
TopicSystemState successfully registered with the master. |
abstract void |
signalOnMasterUnregistrationFailure()
Signal that the
TopicSystemState failed to unregister with the master. |
abstract void |
signalOnMasterUnregistrationSuccess()
Signal that the
TopicSystemState successfully unregistered with the master. |
public DefaultTopicParticipant(TopicDeclaration topicDeclaration)
public TopicDeclaration getTopicDeclaration()
TopicDeclaration
of this TopicParticipant
public java.util.List<java.lang.String> getTopicDeclarationAsList()
public GraphName getTopicName()
getTopicName
in interface TopicParticipant
public java.lang.String getTopicMessageType()
getTopicMessageType
in interface TopicParticipant
public ConnectionHeader getTopicDeclarationHeader()
TopicSystemState
public abstract void signalOnMasterRegistrationSuccess()
TopicSystemState
successfully registered with the master.public abstract void signalOnMasterRegistrationFailure()
TopicSystemState
failed to register with the master.public abstract void signalOnMasterUnregistrationSuccess()
TopicSystemState
successfully unregistered with the master.public abstract void signalOnMasterUnregistrationFailure()
TopicSystemState
failed to unregister with the master.