rsb.transport.spread

Class RefCountingSpreadWrapper

java.lang.Object

rsb.AbstractActivatable

rsb.transport.spread.RefCountingSpreadWrapper

All Implemented Interfaces:

Closeable, AutoCloseable, Activatable, SpreadWrapper

public class RefCountingSpreadWrapper
extends AbstractActivatable
implements SpreadWrapper

A facade for SpreadWrapper instances which counts calls to activate() and deactivate() and only passes these calls down to a wrapped instance of SpreadWrapper in case they are the first or the last.

Author:

jwienke

Nested Class Summary

Nested classes/interfaces inherited from interface rsb.transport.spread.SpreadWrapper

SpreadWrapper.ConnectionState

Nested classes/interfaces inherited from interface rsb.Activatable

Activatable.State

Constructor Summary

Constructors

Constructor and Description
RefCountingSpreadWrapper(SpreadWrapper wrapped) Creates a new instance wrapping an the given instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	activate() Activates all resources that belong to a specific object.
void	deactivate() Deactivate all resources that are owned by a specific object in order to correctly tear down.
String	getPrivateGroup() Returns the name of the private spread group for the wrapped connection.
InetAddress	getSpreadhost()
SpreadWrapper.ConnectionState	getStatus() Indicates the current state of the underlying connection.
URI	getTransportUri() Returns the transport URI for this spread connection.
boolean	isActive() Tells whether this class is currently active or not.
boolean	isConnected() Indicate whether this wrapper is currently successfully connected to a spread daemon.
boolean	isShutdown() Indicate whether a shutdown was requested.
boolean	isUseTcpNoDelay()
void	join(String group) If connected, joins the specified group.
void	leave(String group) If connected and joined, leaves the specified group.
spread.SpreadMessage	receive() Receive the next message from the spread connection in groups this wrapper has joined.
void	send(DataMessage msg) Sends the given message.

Methods inherited from class rsb.AbstractActivatable

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RefCountingSpreadWrapper

public RefCountingSpreadWrapper(SpreadWrapper wrapped)

Creates a new instance wrapping an the given instance.

Parameters:

wrapped - instance to wrap.

Method Detail

activate

public void activate()
              throws RSBException

Description copied from interface: Activatable

Activates all resources that belong to a specific object.

Specified by:

activate in interface Activatable

Throws:

RSBException - generic error related to RSB

deactivate

public void deactivate()
                throws RSBException,
                       InterruptedException

Description copied from interface: Activatable

Deactivate all resources that are owned by a specific object in order to correctly tear down. The method should only return once the object is completely deactivated including possible background threads.

Specified by:

deactivate in interface Activatable

Throws:

RSBException - generic error related to RSB

InterruptedException - interrupted while waiting for proper deactivation. Object might be in an undefined state now

isActive

public boolean isActive()

Description copied from interface: Activatable

Tells whether this class is currently active or not.

Specified by:

isActive in interface Activatable

Returns:

true if active

getStatus

public SpreadWrapper.ConnectionState getStatus()

Description copied from interface: SpreadWrapper

Indicates the current state of the underlying connection.

Specified by:

getStatus in interface SpreadWrapper

Returns:

the status

getSpreadhost

public InetAddress getSpreadhost()

Specified by:

getSpreadhost in interface SpreadWrapper

Returns:

the spreadhost

isUseTcpNoDelay

public boolean isUseTcpNoDelay()

Specified by:

isUseTcpNoDelay in interface SpreadWrapper

Returns:

the useTcpNoDelay

join

public void join(String group)
          throws spread.SpreadException

Description copied from interface: SpreadWrapper

If connected, joins the specified group. Otherwise, call is ignored. Calling this method does not wait until messages can effectively be received. You have to wait for a membership message containing your private group to be sure that this is the case.

Specified by:

join in interface SpreadWrapper

Parameters:

group - group to join

Throws:

spread.SpreadException - error joining

send

public void send(DataMessage msg)

Description copied from interface: SpreadWrapper

Sends the given message.

Specified by:

send in interface SpreadWrapper

Parameters:

msg - the message to send

leave

public void leave(String group)

Description copied from interface: SpreadWrapper

If connected and joined, leaves the specified group.

Specified by:

leave in interface SpreadWrapper

Parameters:

group - the group to leave

getPrivateGroup

public String getPrivateGroup()

Description copied from interface: SpreadWrapper

Returns the name of the private spread group for the wrapped connection.

Specified by:

getPrivateGroup in interface SpreadWrapper

Returns:

name of the group or null if not connected so far.

isConnected

public boolean isConnected()

Description copied from interface: SpreadWrapper

Indicate whether this wrapper is currently successfully connected to a spread daemon.

Specified by:

isConnected in interface SpreadWrapper

Returns:

true if connected, else false

receive

public spread.SpreadMessage receive()
                             throws InterruptedIOException,
                                    spread.SpreadException

Description copied from interface: SpreadWrapper

Receive the next message from the spread connection in groups this wrapper has joined. Blocks if no message is available.

Specified by:

receive in interface SpreadWrapper

Returns:

the next message

Throws:

InterruptedIOException - interrupted while waiting for the message

spread.SpreadException - error while reading the next message

isShutdown

public boolean isShutdown()

Description copied from interface: SpreadWrapper

Indicate whether a shutdown was requested.

Specified by:

isShutdown in interface SpreadWrapper

Returns:

true if requested.

getTransportUri

public URI getTransportUri()

Description copied from interface: SpreadWrapper

Returns the transport URI for this spread connection.

Specified by:

getTransportUri in interface SpreadWrapper

Returns:

URI representing this connection