org.kaaproject.kaa.client.channel.impl

Class DefaultChannelManager

java.lang.Object

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

All Implemented Interfaces:

PingServerStorage, KaaChannelManager

public class DefaultChannelManager
extends Object
implements KaaChannelManager, PingServerStorage

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
DefaultChannelManager(BootstrapManager manager, Map<org.kaaproject.kaa.common.bootstrap.gen.ChannelType,List<ServerInfo>> bootststrapServers)

Method Summary

Methods

Modifier and Type	Method and Description
void	addChannel(KaaDataChannel channel) Updates the manager by adding the channel.
void	clearChannelList() Clears the list of channels.
KaaDataChannel	getChannel(String id) Retrieves channel by the unique channel id.
KaaDataChannel	getChannelByTransportType(org.kaaproject.kaa.common.TransportType type) Retrieves a list of channels by the specific transport type.
List<KaaDataChannel>	getChannels() Retrieves the list of current channels.
List<KaaDataChannel>	getChannelsByType(org.kaaproject.kaa.common.bootstrap.gen.ChannelType type) Retrieves a list of channels by the specific type (HTTP, HTTP_LP etc.).
AbstractServerInfo	getCurrentPingServer()
void	onServerFailed(ServerInfo server) Reports to Channel Manager in case link with server was not established.
void	onServerUpdated(ServerInfo 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	setChannel(org.kaaproject.kaa.common.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	shutdown() Shuts down the manager and all registered channels.

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<org.kaaproject.kaa.common.bootstrap.gen.ChannelType,List<ServerInfo>> bootststrapServers)

Method Detail

setChannel

public void setChannel(org.kaaproject.kaa.common.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

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

getChannelsByType

public List<KaaDataChannel> getChannelsByType(org.kaaproject.kaa.common.bootstrap.gen.ChannelType type)

Description copied from interface: KaaChannelManager

Retrieves a list of channels by the specific type (HTTP, HTTP_LP etc.).

Specified by:

getChannelsByType in interface KaaChannelManager

Parameters:

type - type of the channel.

Returns:

a list of channels.

See Also:

ChannelType, KaaDataChannel

getChannelByTransportType

public KaaDataChannel getChannelByTransportType(org.kaaproject.kaa.common.TransportType type)

Description copied from interface: KaaChannelManager

Retrieves a list of channels by the specific transport type.

Specified by:

getChannelByTransportType in interface KaaChannelManager

Parameters:

type - the transport's type.

Returns:

a list of channels.

See Also:

TransportType, KaaDataChannel

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

onServerUpdated

public void onServerUpdated(ServerInfo newServer)

Description copied from interface: KaaChannelManager

Reports to Channel Manager about the new server.

Specified by:

onServerUpdated in interface KaaChannelManager

Parameters:

newServer - the parameters of the new server.

See Also:

ServerInfo

onServerFailed

public void onServerFailed(ServerInfo 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:

ServerInfo

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: KaaChannelManager

Sets connectivity checker to the existing channels.

Specified by:

setConnectivityChecker in interface KaaChannelManager

Parameters:

checker - platform-dependent connectivity checker.

See Also:

ConnectivityChecker

getCurrentPingServer

public AbstractServerInfo getCurrentPingServer()

Specified by:

getCurrentPingServer in interface PingServerStorage

shutdown

public void shutdown()

Description copied from interface: KaaChannelManager

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

Specified by:

shutdown in interface KaaChannelManager

pause

public void pause()

Description copied from interface: KaaChannelManager

Pauses all active channels.

Specified by:

pause in interface KaaChannelManager

resume

public void resume()

Description copied from interface: KaaChannelManager

Restores channels' activity.

Specified by:

resume in interface KaaChannelManager