public abstract class AbstractPubSubIPSensorSession extends AbstractIPSensorSession
Constructor and Description |
---|
AbstractPubSubIPSensorSession(AbstractSensor<?> sensor,
java.lang.String ID,
java.lang.String host,
int port,
int reconnectionInterval,
int maxConAttempts,
java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations) |
Modifier and Type | Method and Description |
---|---|
void |
subscribe(IPSessionEndpoint subscriber)
Subscribe to new messages.
|
void |
unsubscribe(IPSessionEndpoint subscriber)
Unsubscribe to messages
|
disconnect, getHost, getPort, toString
getCommandInstance, getStatus, killComand, submit, submit, submit, submitAndBlock, suspendCommand
connect, getCommands, getDTO, getID, getSensor, getTimeout, handleTimeout, killAllCommands, restoreCommands
public AbstractPubSubIPSensorSession(AbstractSensor<?> sensor, java.lang.String ID, java.lang.String host, int port, int reconnectionInterval, int maxConAttempts, java.util.Set<AbstractCommandConfiguration<?>> commandConfigurations)
sensor
- ID
- host
- port
- reconnectionInterval
- maxConAttempts
- commandConfigurations
- public void subscribe(IPSessionEndpoint subscriber)
subscriber
- public void unsubscribe(IPSessionEndpoint subscriber)
subscriber
-