public class MasterClient
extends java.lang.Object
MasterServer.| Modifier and Type | Field and Description |
|---|---|
protected T |
xmlRpcEndpoint |
| Constructor and Description |
|---|
MasterClient(java.net.URI uri)
Create a new
MasterClient connected to the specified
MasterServer URI. |
| Modifier and Type | Method and Description |
|---|---|
Response<java.util.List<TopicDeclaration>> |
getPublishedTopics(GraphName callerName,
java.lang.String subgraph) |
java.net.URI |
getRemoteUri() |
Response<SystemState> |
getSystemState(GraphName callerName) |
Response<java.util.List<TopicType>> |
getTopicTypes(GraphName callerName)
Get a
List of all TopicSystemState message types. |
Response<java.net.URI> |
getUri(GraphName slaveName) |
Response<java.net.URI> |
lookupNode(GraphName slaveName,
java.lang.String nodeName) |
Response<java.net.URI> |
lookupService(GraphName callerName,
java.lang.String serviceName) |
Response<java.util.List<java.net.URI>> |
registerPublisher(PublisherDeclaration publisherDeclaration)
Registers the specified
PublisherDeclaration. |
Response<java.lang.Void> |
registerService(NodeIdentifier slave,
ServiceServer<?,?> service)
Registers the given
ServiceServer. |
Response<java.util.List<java.net.URI>> |
registerSubscriber(NodeIdentifier slave,
Subscriber<?> subscriber)
Registers the given
Subscriber. |
Response<java.lang.Integer> |
unregisterPublisher(PublisherIdentifier publisherIdentifier)
Unregisters the specified
PublisherDeclaration. |
Response<java.lang.Integer> |
unregisterService(NodeIdentifier slave,
ServiceServer<?,?> service)
Unregisters the specified
ServiceServer. |
Response<java.lang.Integer> |
unregisterSubscriber(NodeIdentifier slave,
Subscriber<?> subscriber)
Unregisters the specified
Subscriber. |
protected final T extends XmlRpcEndpoint xmlRpcEndpoint
public MasterClient(java.net.URI uri)
MasterClient connected to the specified
MasterServer URI.uri - the URI of the MasterServer to connect topublic Response<java.lang.Void> registerService(NodeIdentifier slave, ServiceServer<?,?> service)
ServiceServer.slave - the NodeIdentifier where the ServiceServer is
runningservice - the ServiceServer to registerResponsepublic Response<java.lang.Integer> unregisterService(NodeIdentifier slave, ServiceServer<?,?> service)
ServiceServer.slave - the NodeIdentifier where the ServiceServer is
runningservice - the ServiceServer to unregisterpublic Response<java.util.List<java.net.URI>> registerSubscriber(NodeIdentifier slave, Subscriber<?> subscriber)
Subscriber. In addition to receiving a list of
current Publishers, the Subscribers SlaveServer
will also receive notifications of new Publishers via the
publisherUpdate API.slave - the NodeIdentifier that the Subscriber is running
onsubscriber - the Subscriber to registerList or SlaveServer XML-RPC API URIs for nodes
currently publishing the specified topicpublic Response<java.lang.Integer> unregisterSubscriber(NodeIdentifier slave, Subscriber<?> subscriber)
Subscriber.slave - the NodeIdentifier where the subscriber is runningsubscriber - the Subscriber to unregisterSubscriberspublic Response<java.util.List<java.net.URI>> registerPublisher(PublisherDeclaration publisherDeclaration)
PublisherDeclaration.publisherDeclaration - the PublisherDeclaration of the Publisher to
registerList of the current SlaveServer URIs which have
Subscribers for the published TopicSystemStatepublic Response<java.lang.Integer> unregisterPublisher(PublisherIdentifier publisherIdentifier)
PublisherDeclaration.publisherIdentifier - the PublisherIdentifier of the Publisher to
unregisterPublisherspublic Response<java.net.URI> lookupNode(GraphName slaveName, java.lang.String nodeName)
slaveName - the GraphName of the callernodeName - the name of the SlaveServer to lookupURI of the SlaveServer with the given namepublic Response<java.net.URI> getUri(GraphName slaveName)
slaveName - the NodeIdentifier of the callerURI of the MasterServerpublic Response<java.net.URI> lookupService(GraphName callerName, java.lang.String serviceName)
callerName - the GraphName of the callerserviceName - the name of the ServiceServer to look upURI of the ServiceServer with the given name.
ServiceServer as a resultpublic Response<java.util.List<TopicDeclaration>> getPublishedTopics(GraphName callerName, java.lang.String subgraph)
callerName - the GraphName of the callersubgraph - the subgraph of the topicsTopicDeclarationspublic Response<java.util.List<TopicType>> getTopicTypes(GraphName callerName)
List of all TopicSystemState message types.public Response<SystemState> getSystemState(GraphName callerName)
callerName - the GraphName of the callerSystemStatepublic java.net.URI getRemoteUri()
URI of the remote XmlRpcServer