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

Class AbstractHttpChannel

java.lang.Object

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

All Implemented Interfaces:

KaaDataChannel

Direct Known Subclasses:

DefaultBootstrapChannel, DefaultOperationHttpChannel

public abstract class AbstractHttpChannel
extends Object
implements KaaDataChannel

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractHttpChannel(AbstractKaaClient client, KaaClientState state)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	connectionFailed(boolean failed)
protected abstract Runnable	createChannelRunnable(Map<org.kaaproject.kaa.common.TransportType,ChannelDirection> typeMap)
protected ExecutorService	createExecutor()
protected KaaDataDemultiplexer	getDemultiplexer()
protected AbstractHttpClient	getHttpClient()
protected KaaDataMultiplexer	getMultiplexer()
TransportConnectionInfo	getServer() Retrieves info about current used server
TransportProtocolId	getTransportProtocolId() Retrieves the TransportProtocolId.
protected abstract String	getURLSufix()
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<org.kaaproject.kaa.common.TransportType> types) Updates the channel's state of the specific service.
void	sync(org.kaaproject.kaa.common.TransportType type) Updates the channel's state of the specific service.
void	syncAck(Set<org.kaaproject.kaa.common.TransportType> types) Notifies channel about successful acknowledgment of the sync only in case of smth change.
void	syncAck(org.kaaproject.kaa.common.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

Methods inherited from interface org.kaaproject.kaa.client.channel.KaaDataChannel

getId, getServerType, getSupportedTransportTypes

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

AbstractHttpChannel

public AbstractHttpChannel(AbstractKaaClient client,
                   KaaClientState state)

Method Detail

createExecutor

protected ExecutorService createExecutor()

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

sync

public void sync(org.kaaproject.kaa.common.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<org.kaaproject.kaa.common.TransportType> types)

Description copied from interface: KaaDataChannel

Updates the channel's state of the specific service.

Specified by:

sync in interface KaaDataChannel

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

getURLSufix

protected abstract String getURLSufix()

getServer

public TransportConnectionInfo getServer()

Description copied from interface: KaaDataChannel

Retrieves info about current used server

Specified by:

getServer in interface KaaDataChannel

Returns:

Server info

See Also:

ServerInfo

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

connectionFailed

protected void connectionFailed(boolean failed)

getMultiplexer

protected KaaDataMultiplexer getMultiplexer()

getDemultiplexer

protected KaaDataDemultiplexer getDemultiplexer()

getHttpClient

protected AbstractHttpClient getHttpClient()

createChannelRunnable

protected abstract Runnable createChannelRunnable(Map<org.kaaproject.kaa.common.TransportType,ChannelDirection> typeMap)