Package | Description |
---|---|
org.rapidoidx.net | |
org.rapidoidx.net.impl |
Modifier and Type | Method and Description |
---|---|
static TCPClient |
TCP.connect(String host,
int port,
Protocol protocol) |
ChannelHolder |
TCPClient.connect(String serverHost,
int serverPort,
Protocol clientProtocol,
boolean autoreconnecting,
ConnState state) |
ChannelHolder[] |
TCPClient.connect(String serverHost,
int serverPort,
Protocol clientProtocol,
int connections,
boolean autoreconnecting,
ConnState state) |
static TCPServer |
TCP.listen(Protocol protocol) |
TCPClientBuilder |
TCPClientBuilder.protocol(Protocol protocol) |
TCPServerBuilder |
TCPServerBuilder.protocol(Protocol protocol) |
Modifier and Type | Class and Description |
---|---|
class |
ExchangeProtocol<T extends DefaultExchange<?,?>> |
class |
FiniteStateProtocol |
Modifier and Type | Field and Description |
---|---|
protected Protocol |
RapidoidServerLoop.protocol |
Modifier and Type | Method and Description |
---|---|
Protocol |
RapidoidServerLoop.getProtocol() |
Protocol |
RapidoidConnection.getProtocol() |
Protocol |
ProtocolBridge.peer1() |
Protocol |
ProtocolBridge.peer2() |
Modifier and Type | Method and Description |
---|---|
ChannelHolder |
RapidoidClientLoop.connect(String serverHost,
int serverPort,
Protocol clientProtocol,
boolean autoreconnecting,
ConnState state) |
ChannelHolder[] |
RapidoidClientLoop.connect(String serverHost,
int serverPort,
Protocol clientProtocol,
int connectionsN,
boolean autoreconnecting,
ConnState state) |
void |
RapidoidConnection.setProtocol(Protocol protocol) |
Constructor and Description |
---|
ConnectionTarget(SocketChannel socketChannel,
InetSocketAddress addr,
Protocol protocol,
ChannelHolderImpl holder,
boolean autoreconnecting,
ConnState state) |
RapidoidChannel(SocketChannel socketChannel,
boolean isClient,
Protocol protocol) |
RapidoidChannel(SocketChannel socketChannel,
boolean isClient,
Protocol protocol,
ChannelHolderImpl holder,
boolean autoreconnecting,
ConnState state) |
RapidoidClientLoop(Protocol protocol,
Class<? extends DefaultExchange<?,?>> exchangeClass,
Class<? extends RapidoidHelper> helperClass) |
RapidoidServerLoop(Protocol protocol,
Class<? extends DefaultExchange<?,?>> exchangeClass,
Class<? extends RapidoidHelper> helperClass) |
RapidoidWorker(String name,
org.rapidoidx.buffer.BufGroup bufs,
Protocol protocol,
RapidoidHelper helper,
int bufSizeKB,
boolean noNelay) |
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.