Package com.github.jy2

Interface PubSubClient

All Known Subinterfaces:

PubSubDiClient

public interface PubSubClient

Method Summary

Modifier and Type	Method	Description
default <D> Publisher<D>	createPublisher(String topicName, Class<D> topicType)
<D> Publisher<D>	createPublisher(String topicName, Class<D> topicType, boolean latched)	Type = null subscribes to any type.
default <D> Subscriber<D>	createSubscriber(String topicName, Class<D> topicType)
default <D> Subscriber<D>	createSubscriber(String topicName, Class<D> topicType, int queueSize)
default <D> Subscriber<D>	createSubscriber(String topicName, Class<D> topicType, int queueSize, int maxExecutionTime)
<D> Subscriber<D>	createSubscriber(String topicName, Class<D> topicType, int queueSize, int maxExecutionTime, boolean isReliable)	Type = null subscribes to any type.
MasterClient	getMasterClient()
ParameterClient	getParameterClient()
SlaveClient	getSlaveClient(String name)
void	shutdown()

Method Detail

createPublisher

<D> Publisher<D> createPublisher(String topicName,
                                 Class<D> topicType,
                                 boolean latched)

Type = null subscribes to any type.

createSubscriber

<D> Subscriber<D> createSubscriber(String topicName,
                                   Class<D> topicType,
                                   int queueSize,
                                   int maxExecutionTime,
                                   boolean isReliable)

Type = null subscribes to any type.

getParameterClient

ParameterClient getParameterClient()

getMasterClient

MasterClient getMasterClient()

getSlaveClient

SlaveClient getSlaveClient(String name)

shutdown

void shutdown()

createPublisher

default <D> Publisher<D> createPublisher(String topicName,
                                         Class<D> topicType)

createSubscriber

default <D> Subscriber<D> createSubscriber(String topicName,
                                           Class<D> topicType)

createSubscriber

default <D> Subscriber<D> createSubscriber(String topicName,
                                           Class<D> topicType,
                                           int queueSize)

createSubscriber

default <D> Subscriber<D> createSubscriber(String topicName,
                                           Class<D> topicType,
                                           int queueSize,
                                           int maxExecutionTime)