Modifier and Type | Method and Description |
---|---|
Future<List<JsonRpcResponse>> |
JsonRpcClient.batchCall(List<JsonRpcRequest> requests)
Sends requests in batch and returns
Future representation of JsonRpcResponse . |
Future<JsonRpcResponse> |
JsonRpcClient.call(JsonRpcRequest req)
Sends single request and returns
Future representation of JsonRpcResponse . |
ReactorClient |
JsonRpcClient.getClient() |
Modifier and Type | Method and Description |
---|---|
void |
ReactorClient.connect() |
protected abstract ReactorClient |
Reactor.createClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
ReactorClient |
Reactor.createClient(String hostname,
int port) |
protected abstract ReactorClient |
Reactor.createConnectedClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel channel) |
Future<ReactorListener> |
Reactor.createListener(String hostname,
int port,
ReactorListener.EventListener owner) |
static Reactor |
ReactorFactory.getReactor(ManagerProvider provider,
ReactorType type)
Provides instance of
Reactor based on ManagerProvider availability and
type provided. |
protected abstract void |
ReactorClient.postConnect(OneTimeCallback callback)
Transport specific post connection functionality.
|
protected void |
SSLClient.postConnect(OneTimeCallback callback) |
protected void |
PlainClient.postConnect(OneTimeCallback callback) |
void |
ReactorClient.process() |
Runnable |
SSLEngineNioHelper.process() |
void |
SSLClient.process() |
protected abstract void |
ReactorClient.processIncoming()
Process incoming channel.
|
protected void |
ReactorClient.processOutgoing() |
abstract void |
ReactorClient.sendMessage(byte[] message)
Sends message using provided byte array.
|
Constructor and Description |
---|
PlainClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
PlainClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel socketChannel) |
SSLClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslctx) |
SSLClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslctx,
SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
ReactorClient |
SSLStompReactor.createClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
ReactorClient |
StompReactor.createClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
ReactorClient |
SSLStompReactor.createConnectedClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel channel) |
ReactorClient |
StompReactor.createConnectedClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel channel) |
protected void |
SSLStompClient.postConnect(OneTimeCallback callback) |
protected void |
StompListener.postConnect(OneTimeCallback callback) |
protected void |
StompClient.postConnect(OneTimeCallback callback) |
protected void |
SSLStompListener.postConnect(OneTimeCallback callback) |
protected void |
StompCommonClient.processIncoming() |
void |
SSLStompClient.sendMessage(byte[] message) |
Constructor and Description |
---|
SSLStompClient(Reactor reactor,
Selector selector,
String hostname,
int port,
SSLContext sslContext) |
SSLStompListener(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel socketChannel,
SSLContext sslContext) |
StompClient(Reactor reactor,
Selector selector,
String hostname,
int port) |
StompListener(Reactor reactor,
Selector selector,
String hostname,
int port,
SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
static Message |
Message.parse(byte[] array) |
Modifier and Type | Method and Description |
---|---|
void |
OneTimeCallback.checkAndExecute() |
abstract void |
OneTimeCallback.execute() |
Copyright © 2016. All rights reserved.