rsb.transport.spread

Class SpreadPort

java.lang.Object

rsb.filter.AbstractFilterObserver

rsb.transport.AbstractPort

rsb.transport.spread.SpreadPort

All Implemented Interfaces:

FilterObserver, RSBObject, Port

public class SpreadPort
extends AbstractPort

A port which connects to a spread daemon network.

Author:

swrede

Field Summary

Fields inherited from class rsb.filter.AbstractFilterObserver

LOG

Constructor Summary

Constructors

Constructor and Description
SpreadPort(SpreadWrapper sw, EventHandler eventHandler, ConverterSelectionStrategy<java.nio.ByteBuffer> inStrategy, ConverterSelectionStrategy<java.nio.ByteBuffer> outStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate() Activates all network resources that belong to a specific object.
void	deactivate() Deactivate all network resources that are owned by a specific object in order to reactivate it.
java.lang.String	getType()
boolean	isActive() Tells wether this class is currently active or not.
void	notify(ScopeFilter e, FilterAction a)
void	push(Event event)
void	setQualityOfServiceSpec(QualityOfServiceSpec qos) Sets the quality of service requirements on sending and receiving event notifications.

Methods inherited from class rsb.filter.AbstractFilterObserver

notify, notify, notify

Methods inherited from class java.lang.Object

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

Methods inherited from interface rsb.filter.FilterObserver

notify, notify, notify

Constructor Detail

SpreadPort

public SpreadPort(SpreadWrapper sw,
          EventHandler eventHandler,
          ConverterSelectionStrategy<java.nio.ByteBuffer> inStrategy,
          ConverterSelectionStrategy<java.nio.ByteBuffer> outStrategy)

Parameters:

sw -

eventHandler - if null, no receiving of events will be done

strategy -

outStrategy -

Method Detail

activate

public void activate()
              throws InitializeException

Description copied from interface: RSBObject

Activates all network resources that belong to a specific object.

Throws:

InitializeException

notify

public void notify(ScopeFilter e,
          FilterAction a)

Specified by:

notify in interface FilterObserver

Overrides:

notify in class AbstractFilterObserver

push

public void push(Event event)
          throws ConversionException

Specified by:

push in interface Port

Specified by:

push in class AbstractPort

Throws:

ConversionException

deactivate

public void deactivate()
                throws RSBException

Description copied from interface: RSBObject

Deactivate all network resources that are owned by a specific object in order to reactivate it.

Throws:

RSBException

getType

public java.lang.String getType()

setQualityOfServiceSpec

public void setQualityOfServiceSpec(QualityOfServiceSpec qos)

Description copied from interface: Port

Sets the quality of service requirements on sending and receiving event notifications.

Parameters:

qos - new spec to apply

isActive

public boolean isActive()

Description copied from interface: RSBObject

Tells wether this class is currently active or not.

Returns:

true if active