rsb.transport

Class Router

java.lang.Object

rsb.filter.FilterObservable

rsb.transport.Router

All Implemented Interfaces:

EventHandler

public class Router
extends FilterObservable
implements EventHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected PortConfiguration	config
protected EventReceivingStrategy	ep
protected Port	inPort
protected Port	outPort

Constructor Summary

Constructors

Constructor and Description
Router(TransportFactory f, PortConfiguration pc)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
void	addFilter(Filter filter)
void	addHandler(Handler handler, boolean wait)
void	deactivate()
void	handle(Event e)
void	publishSync(Event e) Publish an Event over the event bus.
void	removeFilter(Filter filter)
void	removeHandler(Handler handler, boolean wait)

Methods inherited from class rsb.filter.FilterObservable

addObserver, clearObservers, notifyObservers, removeObserver

Methods inherited from class java.lang.Object

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

Field Detail

inPort

protected Port inPort

outPort

protected Port outPort

ep

protected EventReceivingStrategy ep

config

protected PortConfiguration config

Constructor Detail

Router

public Router(TransportFactory f,
      PortConfiguration pc)

Method Detail

activate

public void activate()
              throws InitializeException

Throws:

InitializeException

publishSync

public void publishSync(Event e)
                 throws ConversionException

Publish an Event over the event bus.

Parameters:

e - The Event to be published

Throws:

ConversionException

deactivate

public void deactivate()

addFilter

public void addFilter(Filter filter)

removeFilter

public void removeFilter(Filter filter)

addHandler

public void addHandler(Handler handler,
              boolean wait)

removeHandler

public void removeHandler(Handler handler,
                 boolean wait)
                   throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

handle

public void handle(Event e)

Specified by:

handle in interface EventHandler