org.rapidoid.net.impl

Class RapidoidServerLoop

java.lang.Object

org.rapidoid.activity.NamedActivity<T>

org.rapidoid.activity.LifecycleActivity<T>

org.rapidoid.net.impl.AbstractLoop<TCPServer>

org.rapidoid.net.impl.RapidoidServerLoop

All Implemented Interfaces:

Runnable, org.rapidoid.activity.Activity<TCPServer>, TCPServer, TCPServerInfo

public class RapidoidServerLoop
extends AbstractLoop<TCPServer>
implements TCPServer, TCPServerInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected Protocol	protocol

Fields inherited from class org.rapidoid.net.impl.AbstractLoop

ownerThread, status

Fields inherited from class org.rapidoid.activity.NamedActivity

name

Constructor Summary

Constructors

Constructor and Description
RapidoidServerLoop(Protocol protocol, Class<? extends DefaultExchange<?>> exchangeClass, Class<? extends RapidoidHelper> helperClass)

Method Summary

Modifier and Type	Method and Description
protected void	beforeLoop()
Protocol	getProtocol()
TCPServerInfo	info()
protected void	insideLoop()
long	messagesProcessed()
RapidoidConnection	newConnection()
void	process(RapidoidConnection conn)
String	process(String input)
TCPServer	shutdown()
TCPServer	start()

Methods inherited from class org.rapidoid.net.impl.AbstractLoop

afterLoop, assertStatus, checkOnSameThread, onSameThread, run, stopLoop, waitToStart, waitToStop

Methods inherited from class org.rapidoid.activity.LifecycleActivity

checkActive, halt, isActive

Methods inherited from class org.rapidoid.activity.NamedActivity

name

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.rapidoid.activity.Activity

halt, isActive, name

Field Detail

protocol

protected final Protocol protocol

Constructor Detail

RapidoidServerLoop

public RapidoidServerLoop(Protocol protocol,
                          Class<? extends DefaultExchange<?>> exchangeClass,
                          Class<? extends RapidoidHelper> helperClass)

Method Detail

beforeLoop

protected final void beforeLoop()

Overrides:

beforeLoop in class AbstractLoop<TCPServer>

start

public TCPServer start()

Specified by:

start in interface org.rapidoid.activity.Activity<TCPServer>

Overrides:

start in class AbstractLoop<TCPServer>

shutdown

public TCPServer shutdown()

Specified by:

shutdown in interface org.rapidoid.activity.Activity<TCPServer>

Overrides:

shutdown in class AbstractLoop<TCPServer>

newConnection

public RapidoidConnection newConnection()

process

public void process(RapidoidConnection conn)

process

public String process(String input)

Specified by:

process in interface TCPServer

getProtocol

public Protocol getProtocol()

info

public TCPServerInfo info()

Specified by:

info in interface TCPServer

messagesProcessed

public long messagesProcessed()

Specified by:

messagesProcessed in interface TCPServerInfo

insideLoop

protected void insideLoop()

Specified by:

insideLoop in class AbstractLoop<TCPServer>