Module swim.io.mqtt

Package swim.io.mqtt

Class AbstractMqttService

java.lang.Object

swim.io.mqtt.AbstractMqttService

All Implemented Interfaces:

FlowContext, MqttService

public abstract class AbstractMqttService
extends Object
implements MqttService, FlowContext

Field Summary

Fields

Modifier and Type	Field	Description
protected MqttServiceContext	context

Constructor Summary

Constructors

Constructor	Description
AbstractMqttService()

Method Summary

Modifier and Type	Method	Description
abstract MqttSocket<?,?>	createSocket()
void	didAccept(MqttSocket<?,?> socket)
void	didBind()
void	didFail(Throwable error)
void	didUnbind()
FlowControl	flowControl()	Returns the current FlowControl state of the underlying network channel.
void	flowControl(FlowControl flowControl)	Enqueues an atomic replacement of the underlying network channel's flow control state with a new flowControl.
FlowControl	flowControl(FlowModifier flowModifier)	Enqueues an atomic modification to the underlying network channel's flow control state by applying a flowModifier delta.
InetSocketAddress	localAddress()
MqttServiceContext	mqttServiceContext()
MqttSettings	mqttSettings()
void	setMqttServiceContext(MqttServiceContext context)
void	unbind()

Methods inherited from class java.lang.Object

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

Field Details

context

protected MqttServiceContext context

Constructor Details

AbstractMqttService

public AbstractMqttService()

Method Details

mqttServiceContext

public MqttServiceContext mqttServiceContext()

Specified by:

mqttServiceContext in interface MqttService

setMqttServiceContext

public void setMqttServiceContext(MqttServiceContext context)

Specified by:

setMqttServiceContext in interface MqttService

createSocket

public abstract MqttSocket<?,?> createSocket()

Specified by:

createSocket in interface MqttService

didBind

public void didBind()

Specified by:

didBind in interface MqttService

didAccept

public void didAccept(MqttSocket<?,?> socket)

Specified by:

didAccept in interface MqttService

didUnbind

public void didUnbind()

Specified by:

didUnbind in interface MqttService

didFail

public void didFail(Throwable error)

Specified by:

didFail in interface MqttService

flowControl

public FlowControl flowControl()

Description copied from interface: FlowContext

Returns the current FlowControl state of the underlying network channel.

Specified by:

flowControl in interface FlowContext

flowControl

public void flowControl(FlowControl flowControl)

Description copied from interface: FlowContext

Enqueues an atomic replacement of the underlying network channel's flow control state with a new flowControl.

Specified by:

flowControl in interface FlowContext

flowControl

public FlowControl flowControl(FlowModifier flowModifier)

Description copied from interface: FlowContext

Enqueues an atomic modification to the underlying network channel's flow control state by applying a flowModifier delta.

Specified by:

flowControl in interface FlowContext

mqttSettings

public MqttSettings mqttSettings()

localAddress

public InetSocketAddress localAddress()

unbind

public void unbind()