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(java.lang.String topicName, java.lang.Class<D> topicType)<D> Publisher<D>createPublisher(java.lang.String topicName, java.lang.Class<D> topicType, boolean latched)Type = null subscribes to any type.default <D> Subscriber<D>createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType)default <D> Subscriber<D>createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize)default <D> Subscriber<D>createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize, int maxExecutionTime)<D> Subscriber<D>createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize, int maxExecutionTime, boolean isReliable)Type = null subscribes to any type.MasterClientgetMasterClient()ParameterClientgetParameterClient()voidshutdown()
-
Method Details
-
createPublisher
<D> Publisher<D> createPublisher(java.lang.String topicName, java.lang.Class<D> topicType, boolean latched)Type = null subscribes to any type. -
createSubscriber
<D> Subscriber<D> createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize, int maxExecutionTime, boolean isReliable)Type = null subscribes to any type. -
getParameterClient
ParameterClient getParameterClient() -
getMasterClient
MasterClient getMasterClient() -
shutdown
void shutdown() -
createPublisher
-
createSubscriber
default <D> Subscriber<D> createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType) -
createSubscriber
default <D> Subscriber<D> createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize) -
createSubscriber
default <D> Subscriber<D> createSubscriber(java.lang.String topicName, java.lang.Class<D> topicType, int queueSize, int maxExecutionTime)
-