org.brutusin.rpc.client.wskt

Class WebsocketEndpoint

java.lang.Object

org.brutusin.rpc.client.wskt.WebsocketEndpoint

public class WebsocketEndpoint
extends Object

Author:

Ignacio del Valle Alles idelvall@brutusin.org

Constructor Summary

Constructors

Constructor and Description
WebsocketEndpoint(javax.websocket.WebSocketContainer webSocketContainer, URI endpoint, Config cfg)

Method Summary

Modifier and Type	Method and Description
void	close()
void	exec(RpcCallback callback, String serviceId, org.brutusin.json.spi.JsonNode input)
URI	getEndpoint()
Map<String,ServiceItem>	getServices()
Map<String,ComponentItem>	getTopics()
boolean	isAvailable()
void	subscribe(String topicId, TopicCallback callback)
void	unsubscribe(String topicId)

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketEndpoint

public WebsocketEndpoint(javax.websocket.WebSocketContainer webSocketContainer,
                         URI endpoint,
                         Config cfg)

Method Detail

getServices

public Map<String,ServiceItem> getServices()

getTopics

public Map<String,ComponentItem> getTopics()

exec

public void exec(RpcCallback callback,
                 String serviceId,
                 org.brutusin.json.spi.JsonNode input)

subscribe

public void subscribe(String topicId,
                      TopicCallback callback)

unsubscribe

public void unsubscribe(String topicId)

getEndpoint

public URI getEndpoint()

isAvailable

public boolean isAvailable()

close

public void close()
           throws IOException

Throws:

IOException