Package org.ros.internal.node.service

Class DefaultServiceServer<T,S>

java.lang.Object

org.ros.internal.node.service.DefaultServiceServer<T,S>

All Implemented Interfaces:

ServiceServer<T,S>

public class DefaultServiceServer<T,S>
extends Object
implements ServiceServer<T,S>

Default implementation of a ServiceServer.

Author:

damonkohler@google.com (Damon Kohler)

Constructor Summary

Constructors

Constructor	Description
DefaultServiceServer(ServiceDeclaration serviceDeclaration, ServiceResponseBuilder<T,S> serviceResponseBuilder, AdvertiseAddress advertiseAddress, org.ros.message.MessageDeserializer<T> messageDeserializer, org.ros.message.MessageSerializer<S> messageSerializer, org.ros.message.MessageFactory messageFactory, ScheduledExecutorService scheduledExecutorService)

Method Summary

Modifier and Type	Method	Description
void	addListener(ServiceServerListener<T,S> listener)	Add a ServiceServerListener.
org.jboss.netty.buffer.ChannelBuffer	finishHandshake(ConnectionHeader incomingConnectionHeader)
GraphName	getName()
URI	getUri()
org.jboss.netty.channel.ChannelHandler	newRequestHandler()
void	shutdown()	Stops the service and unregisters it.
void	signalOnMasterRegistrationFailure()	Signal all ServiceServerListeners that the ServiceServer has failed to register with the master.
void	signalOnMasterRegistrationSuccess()	Signal all ServiceServerListeners that the ServiceServer has been successfully registered with the master.
void	signalOnMasterUnregistrationFailure()	Signal all ServiceServerListeners that the ServiceServer has failed to unregister with the master.
void	signalOnMasterUnregistrationSuccess()	Signal all ServiceServerListeners that the ServiceServer has been successfully unregistered with the master.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DefaultServiceServer

public DefaultServiceServer(ServiceDeclaration serviceDeclaration,
 ServiceResponseBuilder<T,S> serviceResponseBuilder,
 AdvertiseAddress advertiseAddress,
 org.ros.message.MessageDeserializer<T> messageDeserializer,
 org.ros.message.MessageSerializer<S> messageSerializer,
 org.ros.message.MessageFactory messageFactory,
 ScheduledExecutorService scheduledExecutorService)

Method Details

finishHandshake

public org.jboss.netty.buffer.ChannelBuffer finishHandshake(ConnectionHeader incomingConnectionHeader)

getUri

public URI getUri()

Specified by:

getUri in interface ServiceServer<T,S>

Returns:

the URI for this ServiceServer

getName

public GraphName getName()

Specified by:

getName in interface ServiceServer<T,S>

Returns:

the name of the ServiceServer

newRequestHandler

public org.jboss.netty.channel.ChannelHandler newRequestHandler()

signalOnMasterRegistrationSuccess

public void signalOnMasterRegistrationSuccess()

Signal all ServiceServerListeners that the ServiceServer has been successfully registered with the master.

Each listener is called in a separate thread.

signalOnMasterRegistrationFailure

public void signalOnMasterRegistrationFailure()

Signal all ServiceServerListeners that the ServiceServer has failed to register with the master.

Each listener is called in a separate thread.

signalOnMasterUnregistrationSuccess

public void signalOnMasterUnregistrationSuccess()

Signal all ServiceServerListeners that the ServiceServer has been successfully unregistered with the master.

Each listener is called in a separate thread.

signalOnMasterUnregistrationFailure

public void signalOnMasterUnregistrationFailure()

Signal all ServiceServerListeners that the ServiceServer has failed to unregister with the master.

Each listener is called in a separate thread.

shutdown

public void shutdown()

Description copied from interface: ServiceServer

Stops the service and unregisters it.

Specified by:

shutdown in interface ServiceServer<T,S>

addListener

public void addListener(ServiceServerListener<T,S> listener)

Description copied from interface: ServiceServer

Add a ServiceServerListener.

Specified by:

addListener in interface ServiceServer<T,S>

Parameters:

listener - the ServiceServerListener to add

toString

public String toString()

Overrides:

toString in class Object