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 registerResponse
public 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 Publisher
s, the Subscriber
s SlaveServer
will also receive notifications of new Publisher
s 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 unregisterSubscriber
spublic 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
Subscriber
s for the published TopicSystemState
public Response<java.lang.Integer> unregisterPublisher(PublisherIdentifier publisherIdentifier)
PublisherDeclaration
.publisherIdentifier
- the PublisherIdentifier
of the Publisher
to
unregisterPublisher
spublic 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 MasterServer
public 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 topicsTopicDeclaration
spublic 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 callerSystemState
public java.net.URI getRemoteUri()
URI
of the remote XmlRpcServer