cloud.orbit.actors.net

Class DefaultPipeline

java.lang.Object

cloud.orbit.actors.net.DefaultPipeline

All Implemented Interfaces:

Pipeline

public class DefaultPipeline
extends Object
implements Pipeline

Protocol chain for orbit messages.
Inspired in netty.io and apache mina.

Constructor Summary

Constructors

Constructor and Description
DefaultPipeline()
DefaultPipeline(BasicRuntime runtime)

Method Summary

Modifier and Type	Method and Description
void	addFirst(String name, Handler handler)
void	addHandlerAfter(String base, String name, Handler handler)
void	addHandlerBefore(String base, String name, Handler handler)
void	addLast(String name, Handler handler)
Task<Void>	close()
Task<Void>	connect(Object param)
Task<Void>	disconnect()
BasicRuntime	getRuntime()
boolean	isActive()
Task<Void>	write(Object message)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPipeline

public DefaultPipeline()

DefaultPipeline

public DefaultPipeline(BasicRuntime runtime)

Method Detail

getRuntime

public BasicRuntime getRuntime()

isActive

public boolean isActive()

Specified by:

isActive in interface Pipeline

addFirst

public void addFirst(String name,
                     Handler handler)

Specified by:

addFirst in interface Pipeline

addLast

public void addLast(String name,
                    Handler handler)

Specified by:

addLast in interface Pipeline

addHandlerBefore

public void addHandlerBefore(String base,
                             String name,
                             Handler handler)

Specified by:

addHandlerBefore in interface Pipeline

addHandlerAfter

public void addHandlerAfter(String base,
                            String name,
                            Handler handler)

Specified by:

addHandlerAfter in interface Pipeline

write

public Task<Void> write(Object message)

Specified by:

write in interface Pipeline

connect

public Task<Void> connect(Object param)

Specified by:

connect in interface Pipeline

disconnect

public Task<Void> disconnect()

Specified by:

disconnect in interface Pipeline

close

public Task<Void> close()

Specified by:

close in interface Pipeline