org.kaaproject.kaa.client.channel.impl.channels

Class DefaultOperationTcpChannel

java.lang.Object

org.kaaproject.kaa.client.channel.impl.channels.DefaultOperationTcpChannel

All Implemented Interfaces:

KaaDataChannel

public class DefaultOperationTcpChannel
extends Object
implements KaaDataChannel

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
DefaultOperationTcpChannel(KaaClientState state, FailoverManager failoverManager)

Method Summary

Modifier and Type	Method and Description
protected ScheduledExecutorService	createExecutor()
protected Socket	createSocket(String host, int port)
String	getId() Retrieves the channel's id.
TransportConnectionInfo	getServer() Retrieves info about current used server
ServerType	getServerType() Retrieves the channel's server type (i.e.
Map<TransportType,ChannelDirection>	getSupportedTransportTypes() Retrieves the map of transport types and their directions supported by this channel.
TransportProtocolId	getTransportProtocolId() Retrieves the TransportProtocolId.
void	pause() Pauses the channel's workflow.
void	resume() Resumes the channel's workflow.
void	setConnectivityChecker(ConnectivityChecker checker) Sets connectivity checker to the current channel.
void	setDemultiplexer(KaaDataDemultiplexer demultiplexer) Sets the response demultiplexer for this channel.
void	setMultiplexer(KaaDataMultiplexer multiplexer) Sets the request multiplexer for this channel.
void	setServer(TransportConnectionInfo server) Sets the server's parameters for the current channel.
void	shutdown() Shuts down the channel instance.
void	sync(Set<TransportType> types) Updates the channel's state of the specific service.
void	sync(TransportType type) Updates the channel's state of the specific service.
void	syncAck(Set<TransportType> types) Notifies channel about successful acknowledgment of the sync only in case of smth change.
void	syncAck(TransportType type) Notifies channel about successful acknowledgment of the sync only in case of smth change.
void	syncAll() Updates the channel's state of all supported services.

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

DefaultOperationTcpChannel

public DefaultOperationTcpChannel(KaaClientState state,
                                  FailoverManager failoverManager)

Method Detail

createSocket

protected Socket createSocket(String host,
                              int port)
                       throws UnknownHostException,
                              IOException

Throws:

UnknownHostException

IOException

createExecutor

protected ScheduledExecutorService createExecutor()

sync

public void sync(TransportType type)

Description copied from interface: KaaDataChannel

Updates the channel's state of the specific service.

Specified by:

sync in interface KaaDataChannel

Parameters:

type - transport type of the service.

See Also:

TransportType

sync

public void sync(Set<TransportType> types)

Description copied from interface: KaaDataChannel

Updates the channel's state of the specific service.

Specified by:

sync in interface KaaDataChannel

Parameters:

types - transport types to sync.

See Also:

TransportType

syncAll

public void syncAll()

Description copied from interface: KaaDataChannel

Updates the channel's state of all supported services.

Specified by:

syncAll in interface KaaDataChannel

syncAck

public void syncAck(TransportType type)

Description copied from interface: KaaDataChannel

Notifies channel about successful acknowledgment of the sync only in case of smth change.

Specified by:

syncAck in interface KaaDataChannel

Parameters:

type - transport type of the service.

See Also:

TransportType

syncAck

public void syncAck(Set<TransportType> types)

Description copied from interface: KaaDataChannel

Notifies channel about successful acknowledgment of the sync only in case of smth change.

Specified by:

syncAck in interface KaaDataChannel

Parameters:

types - transport type to ack.

See Also:

TransportType

setDemultiplexer

public void setDemultiplexer(KaaDataDemultiplexer demultiplexer)

Description copied from interface: KaaDataChannel

Sets the response demultiplexer for this channel.

Specified by:

setDemultiplexer in interface KaaDataChannel

Parameters:

demultiplexer - demultiplexer instance to be set.

See Also:

KaaDataDemultiplexer

setMultiplexer

public void setMultiplexer(KaaDataMultiplexer multiplexer)

Description copied from interface: KaaDataChannel

Sets the request multiplexer for this channel.

Specified by:

setMultiplexer in interface KaaDataChannel

Parameters:

multiplexer - multiplexer instance to be set.

See Also:

KaaDataMultiplexer

setServer

public void setServer(TransportConnectionInfo server)

Description copied from interface: KaaDataChannel

Sets the server's parameters for the current channel.

Specified by:

setServer in interface KaaDataChannel

Parameters:

server - server's parameters.

See Also:

TransportConnectionInfo

getServer

public TransportConnectionInfo getServer()

Description copied from interface: KaaDataChannel

Retrieves info about current used server

Specified by:

getServer in interface KaaDataChannel

Returns:

Server info

setConnectivityChecker

public void setConnectivityChecker(ConnectivityChecker checker)

Description copied from interface: KaaDataChannel

Sets connectivity checker to the current channel.

Specified by:

setConnectivityChecker in interface KaaDataChannel

Parameters:

checker - platform-dependent connectivity checker.

See Also:

ConnectivityChecker

shutdown

public void shutdown()

Description copied from interface: KaaDataChannel

Shuts down the channel instance. All connections and threads should be terminated. The instance can no longer be used.

Specified by:

shutdown in interface KaaDataChannel

pause

public void pause()

Description copied from interface: KaaDataChannel

Pauses the channel's workflow. The channel should stop all network activity.

Specified by:

pause in interface KaaDataChannel

resume

public void resume()

Description copied from interface: KaaDataChannel

Resumes the channel's workflow. The channel should restore previous connection.

Specified by:

resume in interface KaaDataChannel

getId

public String getId()

Description copied from interface: KaaDataChannel

Retrieves the channel's id. It should be unique in existing channels scope.

Specified by:

getId in interface KaaDataChannel

Returns:

the channel's id.

getTransportProtocolId

public TransportProtocolId getTransportProtocolId()

Description copied from interface: KaaDataChannel

Retrieves the TransportProtocolId.

Specified by:

getTransportProtocolId in interface KaaDataChannel

Returns:

the transport protocol id.

See Also:

TransportProtocolId

getServerType

public ServerType getServerType()

Description copied from interface: KaaDataChannel

Retrieves the channel's server type (i.e. OPERATIONS or BOOTSTRAP).

Specified by:

getServerType in interface KaaDataChannel

Returns:

the channel's server type.

See Also:

ServerType

getSupportedTransportTypes

public Map<TransportType,ChannelDirection> getSupportedTransportTypes()

Description copied from interface: KaaDataChannel

Retrieves the map of transport types and their directions supported by this channel.

Specified by:

getSupportedTransportTypes in interface KaaDataChannel

Returns:

the map of transport types.

See Also:

TransportType, ChannelDirection