Package com.github.jy2

Interface Subscriber<T>

public interface Subscriber<T>

Method Summary

Modifier and Type	Method	Description
default Object	addMessageListener(Consumer<T> consumer)
default Object	addMessageListener(Consumer<T> consumer, int queueSize)
default Object	addMessageListener(Consumer<T> consumer, int queueSize, int timeout)
default Object	addMessageListener(Consumer<T> consumer, int queueSize, int timeout, int maxExecutionTime)
default Object	addMessageListener(Consumer<T> consumer, int queueSize, int timeout, int maxExecutionTime, boolean logStoppedReceivingMessage)
Object	addMessageListener(Consumer<T> consumer, int queueLength, int timeout, int maxExecutionTime, boolean logStoppedReceivingMessage, Method method)
String	getRemoteJavaType()	WARNING: this will only work after message listener was added
String	getRemoteRosType()	WARNING: this will only work after message listener was added
boolean	isLatched()	WARNING: this will only work after message listener was added
void	removeAllMessageListeners()
void	removeMessageListener(Object handle)
void	shutdown()

Method Detail

addMessageListener

default Object addMessageListener(Consumer<T> consumer)

addMessageListener

default Object addMessageListener(Consumer<T> consumer,
                                  int queueSize)

addMessageListener

default Object addMessageListener(Consumer<T> consumer,
                                  int queueSize,
                                  int timeout)

addMessageListener

default Object addMessageListener(Consumer<T> consumer,
                                  int queueSize,
                                  int timeout,
                                  int maxExecutionTime)

addMessageListener

default Object addMessageListener(Consumer<T> consumer,
                                  int queueSize,
                                  int timeout,
                                  int maxExecutionTime,
                                  boolean logStoppedReceivingMessage)

addMessageListener

Object addMessageListener(Consumer<T> consumer,
                          int queueLength,
                          int timeout,
                          int maxExecutionTime,
                          boolean logStoppedReceivingMessage,
                          Method method)

removeMessageListener

void removeMessageListener(Object handle)

removeAllMessageListeners

void removeAllMessageListeners()

isLatched

boolean isLatched()

WARNING: this will only work after message listener was added

getRemoteJavaType

String getRemoteJavaType()

WARNING: this will only work after message listener was added

getRemoteRosType

String getRemoteRosType()

WARNING: this will only work after message listener was added

shutdown

void shutdown()