public class RapidoidClientLoop extends AbstractEventLoop<TCPClient> implements TCPClient, TCPClientInfo
selector
ownerThread, status
Constructor and Description |
---|
RapidoidClientLoop(Protocol protocol,
Class<? extends DefaultExchange<?>> exchangeClass,
Class<? extends RapidoidHelper> helperClass) |
Modifier and Type | Method and Description |
---|---|
protected void |
beforeLoop() |
ChannelHolder |
connect(String serverHost,
int serverPort,
Protocol clientProtocol,
boolean autoreconnecting,
ConnState state) |
ChannelHolder[] |
connect(String serverHost,
int serverPort,
Protocol clientProtocol,
int connectionsN,
boolean autoreconnecting,
ConnState state) |
protected void |
doProcessing() |
TCPClientInfo |
info() |
long |
messagesProcessed() |
protected static SocketChannel |
openSocket() |
TCPClient |
shutdown() |
TCPClient |
start() |
acceptOP, connectOP, failedOP, getSelectorTimeout, insideLoop, readOP, writeOP
afterLoop, assertStatus, checkOnSameThread, onSameThread, run, stopLoop, waitToStart, waitToStop
public RapidoidClientLoop(Protocol protocol, Class<? extends DefaultExchange<?>> exchangeClass, Class<? extends RapidoidHelper> helperClass)
protected void doProcessing()
doProcessing
in class AbstractEventLoop<TCPClient>
protected final void beforeLoop()
beforeLoop
in class AbstractLoop<TCPClient>
public ChannelHolder connect(String serverHost, int serverPort, Protocol clientProtocol, boolean autoreconnecting, ConnState state)
public ChannelHolder[] connect(String serverHost, int serverPort, Protocol clientProtocol, int connectionsN, boolean autoreconnecting, ConnState state)
protected static SocketChannel openSocket()
public TCPClient start()
start
in interface org.rapidoid.activity.Activity<TCPClient>
start
in class AbstractLoop<TCPClient>
public TCPClient shutdown()
shutdown
in interface org.rapidoid.activity.Activity<TCPClient>
shutdown
in class AbstractLoop<TCPClient>
public TCPClientInfo info()
public long messagesProcessed()
messagesProcessed
in interface TCPClientInfo
Copyright © 2014–2015 Nikolche Mihajlovski and contributors. All rights reserved.