Module swim.io.mqtt

Package swim.io.mqtt

Class MqttSocketService

java.lang.Object

swim.io.mqtt.MqttSocketService

All Implemented Interfaces:

FlowContext, IpService, MqttServiceContext

public class MqttSocketService
extends Object
implements IpService, MqttServiceContext

Field Summary

Fields

Modifier and Type	Field	Description
protected IpServiceContext	context
protected MqttSettings	mqttSettings
protected MqttService	service

Constructor Summary

Constructors

Constructor	Description
MqttSocketService(MqttService service, MqttSettings mqttSettings)

Method Summary

Modifier and Type	Method	Description
IpSocket	createSocket()	Returns a new IpSocket binding to handle an incoming network connection.
void	didAccept(IpSocket socket)	Lifecycle callback invoked by the service context after the underlying network listener has accepted a new socket connection.
void	didBind()	Lifecycle callback invoked by the service context after the underlying network listener has bound to a port.
void	didFail(Throwable error)	Lifecycle callback invoked by the service context when the underlying network listener fails by throwing an error.
void	didUnbind()	Lifecycle callback invoked by the service context after the underlying network listener has been unbound.
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.
IpServiceContext	ipServiceContext()	Returns the network listener context to which this IpService is bound; returns null if this IpService is unbound.
InetSocketAddress	localAddress()
MqttSettings	mqttSettings()
void	setIpServiceContext(IpServiceContext context)	Sets the network listener context to which this IpService is bound.
void	unbind()

Methods inherited from class java.lang.Object

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

Field Detail

service

protected final MqttService service

mqttSettings

protected final MqttSettings mqttSettings

context

protected IpServiceContext context

Constructor Detail

MqttSocketService

public MqttSocketService(MqttService service,
                         MqttSettings mqttSettings)

Method Detail

ipServiceContext

public IpServiceContext ipServiceContext()

Description copied from interface: IpService

Returns the network listener context to which this IpService is bound; returns null if this IpService is unbound.

Specified by:

ipServiceContext in interface IpService

setIpServiceContext

public void setIpServiceContext(IpServiceContext context)

Description copied from interface: IpService

Sets the network listener context to which this IpService is bound.

Specified by:

setIpServiceContext in interface IpService

createSocket

public IpSocket createSocket()

Description copied from interface: IpService

Returns a new IpSocket binding to handle an incoming network connection.

Specified by:

createSocket in interface IpService

didBind

public void didBind()

Description copied from interface: IpService

Lifecycle callback invoked by the service context after the underlying network listener has bound to a port.

Specified by:

didBind in interface IpService

didAccept

public void didAccept(IpSocket socket)

Description copied from interface: IpService

Lifecycle callback invoked by the service context after the underlying network listener has accepted a new socket connection.

Specified by:

didAccept in interface IpService

didUnbind

public void didUnbind()

Description copied from interface: IpService

Lifecycle callback invoked by the service context after the underlying network listener has been unbound.

Specified by:

didUnbind in interface IpService

didFail

public void didFail(Throwable error)

Description copied from interface: IpService

Lifecycle callback invoked by the service context when the underlying network listener fails by throwing an error. The listener will automatically be closed.

Specified by:

didFail in interface IpService

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()

Specified by:

mqttSettings in interface MqttServiceContext

localAddress

public InetSocketAddress localAddress()

Specified by:

localAddress in interface MqttServiceContext

unbind

public void unbind()

Specified by:

unbind in interface MqttServiceContext