fulmine.distribution.channel
Interface IChannelState

All Superinterfaces:

IDestroyable, ILifeCycle

public interface IChannelState
extends ILifeCycle

Interface for the shared state object of a Channel

Author:

Ramon Servadei

Method Summary

IConnection	getConnection() The connection to use
IFrameworkContext	getContext() The local context
ILifeCycleEventListener	getEventHandler() Helper to process events received from the peer channel and from the local context.
LongField	getRxCount()
ISubscriptionManager	getRxSubscriptionManager() The subscription manager for RxSubscription instances.
Map<Integer,Integer>	getTokenMap() Holds the RxEvent listener token against the application subscription token.
LongField	getTxCount()
ISubscriptionManager	getTxSubscriptionManager() The subscription manager for TxSubscription instances.
void	init(IChannel channel, IChannelOperations channelOps) Initialise the state
boolean	isConnectionSyn() Indicates if the connection to the peer IChannel has been synchronised.
void	setConnectionSyn()

Methods inherited from interface fulmine.ILifeCycle

isActive, start

Methods inherited from interface fulmine.IDestroyable

destroy

Method Detail

getTokenMap

Map<Integer,Integer> getTokenMap()

Holds the RxEvent listener token against the application subscription token.

Returns:

a map of application listener subscription token against the RxEvent subscription token

getEventHandler

ILifeCycleEventListener getEventHandler()

Helper to process events received from the peer channel and from the local context.

init

void init(IChannel channel,
          IChannelOperations channelOps)

Initialise the state

Parameters:

channel - the channel

channelOps - the channel operations

setConnectionSyn

void setConnectionSyn()

getContext

IFrameworkContext getContext()

The local context

getTxSubscriptionManager

ISubscriptionManager getTxSubscriptionManager()

The subscription manager for TxSubscription instances. This manager handles subscriptions for transmitting local containers to the remote context; these are subscriptions from the remote context for local containers.

getRxSubscriptionManager

ISubscriptionManager getRxSubscriptionManager()

The subscription manager for RxSubscription instances. This manager handles subscriptions for receiving remote containers from remote contexts; these are subscriptions from the local context for remote containers.

isConnectionSyn

boolean isConnectionSyn()

Indicates if the connection to the peer IChannel has been synchronised. The peer channels in the peer contexts will be created at different times, so they must synchronise with each other to ensure no missed registrations occur.

getConnection

IConnection getConnection()

The connection to use

getTxCount

LongField getTxCount()

getRxCount

LongField getRxCount()