Inheritance diagram for org.ros.internal.node.topic.DefaultSubscriber< T >:

Public Member Functions
void	addMessageListener (MessageListener< T > messageListener, int limit)
void	addMessageListener (MessageListener< T > messageListener)
void	addPublisher (PublisherIdentifier publisherIdentifier, InetSocketAddress address)
void	addSubscriberListener (SubscriberListener< T > listener)
boolean	getLatchMode ()
Collection< String >	getSupportedProtocols ()
void	shutdown (long timeout, TimeUnit unit)
void	shutdown ()
void	signalOnMasterRegistrationFailure ()
void	signalOnMasterRegistrationSuccess ()
void	signalOnMasterUnregistrationFailure ()
void	signalOnMasterUnregistrationSuccess ()
void	signalOnNewPublisher (final PublisherIdentifier publisherIdentifier)
SubscriberDeclaration	toDeclaration ()
SubscriberIdentifier	toIdentifier ()
String	toString ()
void	updatePublishers (Collection< PublisherIdentifier > publisherIdentifiers)
Static Public Member Functions
static< S > DefaultSubscriber< S >	newDefault (NodeIdentifier nodeIdentifier, TopicDeclaration description, ScheduledExecutorService executorService, MessageDeserializer< S > deserializer)
Private Member Functions
	DefaultSubscriber (NodeIdentifier nodeIdentifier, TopicDeclaration topicDeclaration, MessageDeserializer< T > deserializer, ScheduledExecutorService executorService)
void	signalOnShutdown (long timeout, TimeUnit unit)
Private Attributes
final ScheduledExecutorService	executorService
final IncomingMessageQueue< T >	incomingMessageQueue
final Set< PublisherIdentifier >	knownPublishers
final Object	mutex
final NodeIdentifier	nodeIdentifier
final ListenerGroup < SubscriberListener< T > >	subscriberListeners
final TcpClientManager	tcpClientManager
Static Private Attributes
static final int	DEFAULT_SHUTDOWN_TIMEOUT = 5
static final TimeUnit	DEFAULT_SHUTDOWN_TIMEOUT_UNITS = TimeUnit.SECONDS
static final Log	log = LogFactory.getLog(DefaultPublisher.class)

Detailed Description

Default implementation of a Subscriber.

Author:: damonkohler@google.com (Damon Kohler)

Definition at line 48 of file DefaultSubscriber.java.

Constructor & Destructor Documentation

org.ros.internal.node.topic.DefaultSubscriber< T >.DefaultSubscriber	(	NodeIdentifier	nodeIdentifier,
		TopicDeclaration	topicDeclaration,
		MessageDeserializer< T >	deserializer,
		ScheduledExecutorService	executorService
	)		`[inline, private]`

Definition at line 78 of file DefaultSubscriber.java.

Member Function Documentation

void org.ros.internal.node.topic.DefaultSubscriber< T >.addMessageListener	(	MessageListener< T >	messageListener,
		int	limit
	)		`[inline]`

Definition at line 133 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.addMessageListener ( MessageListener< T > messageListener ) [inline]

Definition at line 138 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.addPublisher	(	PublisherIdentifier	publisherIdentifier,
		InetSocketAddress	address
	)		`[inline]`

Definition at line 143 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.addSubscriberListener ( SubscriberListener< T > listener ) [inline]

Definition at line 187 of file DefaultSubscriber.java.

boolean org.ros.internal.node.topic.DefaultSubscriber< T >.getLatchMode ( ) [inline]

Definition at line 128 of file DefaultSubscriber.java.

Collection<String> org.ros.internal.node.topic.DefaultSubscriber< T >.getSupportedProtocols ( ) [inline]

Definition at line 123 of file DefaultSubscriber.java.

static <S> DefaultSubscriber<S> org.ros.internal.node.topic.DefaultSubscriber< T >.newDefault	(	NodeIdentifier	nodeIdentifier,
		TopicDeclaration	description,
		ScheduledExecutorService	executorService,
		MessageDeserializer< S >	deserializer
	)		`[inline, static]`

Definition at line 72 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.shutdown	(	long	timeout,
		TimeUnit	unit
	)		`[inline]`

Definition at line 174 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.shutdown ( ) [inline]

Definition at line 182 of file DefaultSubscriber.java.

void org.ros.internal.node.topic.DefaultSubscriber< T >.signalOnMasterRegistrationFailure ( ) [inline, virtual]

Signal all SubscriberListeners that the Subscriber has failed to register with the master.