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

Public Member Functions
void	addListener (PublisherListener< T > listener)
void	addSubscriber (SubscriberIdentifier subscriberIdentifer, Channel channel)
	DefaultPublisher (NodeIdentifier nodeIdentifier, TopicDeclaration topicDeclaration, MessageSerializer< T > serializer, MessageFactory messageFactory, ScheduledExecutorService executorService)
ChannelBuffer	finishHandshake (ConnectionHeader incomingHeader)
PublisherIdentifier	getIdentifier ()
boolean	getLatchMode ()
int	getNumberOfSubscribers ()
boolean	hasSubscribers ()
T	newMessage ()
void	publish (T message)
void	setLatchMode (boolean enabled)
void	shutdown (long timeout, TimeUnit unit)
void	shutdown ()
void	signalOnMasterRegistrationFailure ()
void	signalOnMasterRegistrationSuccess ()
void	signalOnMasterUnregistrationFailure ()
void	signalOnMasterUnregistrationSuccess ()
PublisherDeclaration	toDeclaration ()
String	toString ()
Private Member Functions
void	signalOnNewSubscriber (final SubscriberIdentifier subscriberIdentifier)
void	signalOnShutdown (long timeout, TimeUnit unit)
Private Attributes
final ListenerGroup < PublisherListener< T > >	listeners
final MessageFactory	messageFactory
final NodeIdentifier	nodeIdentifier
final OutgoingMessageQueue< T >	outgoingMessageQueue
Static Private Attributes
static final boolean	DEBUG = false
static final long	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 Publisher.

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

Definition at line 46 of file DefaultPublisher.java.

Constructor & Destructor Documentation

org.ros.internal.node.topic.DefaultPublisher< T >.DefaultPublisher	(	NodeIdentifier	nodeIdentifier,
		TopicDeclaration	topicDeclaration,
		MessageSerializer< T >	serializer,
		MessageFactory	messageFactory,
		ScheduledExecutorService	executorService
	)		`[inline]`

Definition at line 67 of file DefaultPublisher.java.

Member Function Documentation

void org.ros.internal.node.topic.DefaultPublisher< T >.addListener ( PublisherListener< T > listener ) [inline]

Definition at line 203 of file DefaultPublisher.java.

void org.ros.internal.node.topic.DefaultPublisher< T >.addSubscriber	(	SubscriberIdentifier	subscriberIdentifer,
		Channel	channel
	)		`[inline]`

Add a Subscriber connection to this Publisher.

Parameters:

subscriberIdentifer	the SubscriberIdentifier of the new subscriber
channel	the communication Channel to the Subscriber

Definition at line 193 of file DefaultPublisher.java.

ChannelBuffer org.ros.internal.node.topic.DefaultPublisher< T >.finishHandshake ( ConnectionHeader incomingHeader ) [inline]

Complete connection handshake on buffer. This generates the connection header for this publisher to send and also updates the connection state of this publisher.

Returns:: encoded connection header from subscriber

Definition at line 157 of file DefaultPublisher.java.

PublisherIdentifier org.ros.internal.node.topic.DefaultPublisher< T >.getIdentifier ( ) [inline]

Definition at line 119 of file DefaultPublisher.java.

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

Definition at line 104 of file DefaultPublisher.java.

int org.ros.internal.node.topic.DefaultPublisher< T >.getNumberOfSubscribers ( ) [inline]

Definition at line 133 of file DefaultPublisher.java.

boolean org.ros.internal.node.topic.DefaultPublisher< T >.hasSubscribers ( ) [inline]

Definition at line 128 of file DefaultPublisher.java.

T org.ros.internal.node.topic.DefaultPublisher< T >.newMessage ( ) [inline]

Definition at line 138 of file DefaultPublisher.java.

void org.ros.internal.node.topic.DefaultPublisher< T >.publish ( T message ) [inline]

Definition at line 143 of file DefaultPublisher.java.

void org.ros.internal.node.topic.DefaultPublisher< T >.setLatchMode ( boolean enabled ) [inline]

Definition at line 99 of file DefaultPublisher.java.

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

Definition at line 109 of file DefaultPublisher.java.

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

Definition at line 115 of file DefaultPublisher.java.

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

Signal all PublisherListeners that the Publisher has failed to register with the master.