org.kaaproject.kaa.client.channel.impl

Class DefaultChannelManager

java.lang.Object

org.kaaproject.kaa.client.channel.impl.DefaultChannelManager

All Implemented Interfaces:

KaaChannelManager, KaaInternalChannelManager

public class DefaultChannelManager
extends Object
implements KaaInternalChannelManager

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
DefaultChannelManager(BootstrapManager manager, Map<TransportProtocolId,List<TransportConnectionInfo>> bootststrapServers, ExecutorContext executorContext)

Method Summary

Modifier and Type	Method and Description
void	addChannel(KaaDataChannel channel) Updates the manager by adding the channel.
void	clearChannelList() Clears the list of channels.
TransportConnectionInfo	getActiveServer(TransportType type) Returns information about server that is used for data transfer for specified TransportType
KaaDataChannel	getChannel(String id) Retrieves channel by the unique channel id.
List<KaaDataChannel>	getChannels() Retrieves the list of current channels.
void	onServerFailed(TransportConnectionInfo server) Reports to Channel Manager in case link with server was not established.
void	onTransportConnectionInfoUpdated(TransportConnectionInfo newServer) Reports to Channel Manager about the new server.
void	pause() Pauses all active channels.
void	removeChannel(KaaDataChannel channel) Updates the manager by removing the channel from the manager.
void	removeChannel(String id) Updates the manager by removing the channel from the manager.
void	resume() Restores channels' activity.
void	setBootstrapDemultiplexer(KaaDataDemultiplexer demultiplexer)
void	setBootstrapMultiplexer(KaaDataMultiplexer multiplexer)
void	setChannel(TransportType transport, KaaDataChannel channel) Updates the manager by setting the channel to the specified TransportType.
void	setConnectivityChecker(ConnectivityChecker checker) Sets connectivity checker to the existing channels.
void	setFailoverManager(FailoverManager failoverManager) Sets a new failover manager
void	setOperationDemultiplexer(KaaDataDemultiplexer demultiplexer)
void	setOperationMultiplexer(KaaDataMultiplexer multiplexer)
void	shutdown() Shuts down the manager and all registered channels.
void	sync(TransportType type) Invoke sync on active channel by specified transport type
void	syncAck(TransportType type) Invoke sync acknowledgement on active channel by specified transport type
void	syncAll(TransportType type) Invoke sync acknowledgement on active channel

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

DefaultChannelManager

public DefaultChannelManager(BootstrapManager manager,
                             Map<TransportProtocolId,List<TransportConnectionInfo>> bootststrapServers,
                             ExecutorContext executorContext)

Method Detail

setChannel

public void setChannel(TransportType transport,
                       KaaDataChannel channel)
                throws KaaInvalidChannelException

Description copied from interface: KaaChannelManager

Updates the manager by setting the channel to the specified TransportType.

Specified by:

setChannel in interface KaaChannelManager

Parameters:

transport - the type of the transport which is going to receive updates using the specified channel.

channel - the channel to be added.

Throws:

KaaInvalidChannelException - the kaa invalid channel exception

See Also:

KaaDataChannel

addChannel

public void addChannel(KaaDataChannel channel)

Description copied from interface: KaaChannelManager

Updates the manager by adding the channel.

Specified by:

addChannel in interface KaaChannelManager

Parameters:

channel - the channel to be added.

See Also:

KaaDataChannel

removeChannel

public void removeChannel(KaaDataChannel channel)

Description copied from interface: KaaChannelManager

Updates the manager by removing the channel from the manager.

Specified by:

removeChannel in interface KaaChannelManager

Parameters:

channel - the channel to be removed.

See Also:

KaaDataChannel

removeChannel

public void removeChannel(String id)

Description copied from interface: KaaChannelManager

Updates the manager by removing the channel from the manager.

Specified by:

removeChannel in interface KaaChannelManager

Parameters:

id - the channel's id.

See Also:

KaaDataChannel

getChannels

public List<KaaDataChannel> getChannels()

Description copied from interface: KaaChannelManager

Retrieves the list of current channels.

Specified by:

getChannels in interface KaaChannelManager

Returns:

the channels' list.

See Also:

KaaDataChannel

getActiveServer

public TransportConnectionInfo getActiveServer(TransportType type)

Description copied from interface: KaaChannelManager

Returns information about server that is used for data transfer for specified TransportType

Specified by:

getActiveServer in interface KaaChannelManager

Parameters:

type - - type that is used to identify active channel

Returns:

TransportConnectionInfo active server

sync

public void sync(TransportType type)

Description copied from interface: KaaChannelManager

Invoke sync on active channel by specified transport type

Specified by:

sync in interface KaaChannelManager

Parameters:

type - the type

syncAck

public void syncAck(TransportType type)

Description copied from interface: KaaChannelManager

Invoke sync acknowledgement on active channel by specified transport type

Specified by:

syncAck in interface KaaChannelManager

Parameters:

type - the type

syncAll

public void syncAll(TransportType type)

Description copied from interface: KaaChannelManager

Invoke sync acknowledgement on active channel

Specified by:

syncAll in interface KaaChannelManager

Parameters:

type - - type that is used to identify active channel

getChannel

public KaaDataChannel getChannel(String id)

Description copied from interface: KaaChannelManager

Retrieves channel by the unique channel id.

Specified by:

getChannel in interface KaaChannelManager

Parameters:

id - the channel's id.

Returns:

channel object.

See Also:

KaaDataChannel

onTransportConnectionInfoUpdated

public void onTransportConnectionInfoUpdated(TransportConnectionInfo newServer)

Description copied from interface: KaaInternalChannelManager

Reports to Channel Manager about the new server.

Specified by:

onTransportConnectionInfoUpdated in interface KaaInternalChannelManager

Parameters:

newServer - the parameters of the new server.

See Also:

TransportConnectionInfo

onServerFailed

public void onServerFailed(TransportConnectionInfo server)

Description copied from interface: KaaChannelManager

Reports to Channel Manager in case link with server was not established.

Specified by:

onServerFailed in interface KaaChannelManager

Parameters:

server - the parameters of server that was not connected.

See Also:

TransportConnectionInfo

clearChannelList

public void clearChannelList()

Description copied from interface: KaaChannelManager

Clears the list of channels.

Specified by:

clearChannelList in interface KaaChannelManager

setConnectivityChecker

public void setConnectivityChecker(ConnectivityChecker checker)

Description copied from interface: KaaInternalChannelManager

Sets connectivity checker to the existing channels.

Specified by:

setConnectivityChecker in interface KaaInternalChannelManager

Parameters:

checker - platform-dependent connectivity checker.

See Also:

ConnectivityChecker

shutdown

public void shutdown()

Description copied from interface: KaaInternalChannelManager

Shuts down the manager and all registered channels. The instance can no longer be used.

Specified by:

shutdown in interface KaaInternalChannelManager

pause

public void pause()

Description copied from interface: KaaInternalChannelManager

Pauses all active channels.

Specified by:

pause in interface KaaInternalChannelManager

resume

public void resume()

Description copied from interface: KaaInternalChannelManager

Restores channels' activity.

Specified by:

resume in interface KaaInternalChannelManager

setOperationMultiplexer

public void setOperationMultiplexer(KaaDataMultiplexer multiplexer)

Specified by:

setOperationMultiplexer in interface KaaInternalChannelManager

setOperationDemultiplexer

public void setOperationDemultiplexer(KaaDataDemultiplexer demultiplexer)

Specified by:

setOperationDemultiplexer in interface KaaInternalChannelManager

setBootstrapMultiplexer

public void setBootstrapMultiplexer(KaaDataMultiplexer multiplexer)

Specified by:

setBootstrapMultiplexer in interface KaaInternalChannelManager

setBootstrapDemultiplexer

public void setBootstrapDemultiplexer(KaaDataDemultiplexer demultiplexer)

Specified by:

setBootstrapDemultiplexer in interface KaaInternalChannelManager

setFailoverManager

public void setFailoverManager(FailoverManager failoverManager)

Description copied from interface: KaaChannelManager

Sets a new failover manager

Specified by:

setFailoverManager in interface KaaChannelManager

Parameters:

failoverManager - the failover manager