java.lang.Object
swim.io.mqtt.AbstractMqttService
- All Implemented Interfaces:
FlowContext
,MqttService
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionabstract MqttSocket<?,
?> void
didAccept
(MqttSocket<?, ?> socket) void
didBind()
void
void
Returns the currentFlowControl
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 newflowControl
.flowControl
(FlowModifier flowModifier) Enqueues an atomic modification to the underlying network channel's flow control state by applying aflowModifier
delta.void
setMqttServiceContext
(MqttServiceContext context) void
unbind()
-
Field Details
-
context
-
-
Constructor Details
-
AbstractMqttService
public AbstractMqttService()
-
-
Method Details
-
mqttServiceContext
- Specified by:
mqttServiceContext
in interfaceMqttService
-
setMqttServiceContext
- Specified by:
setMqttServiceContext
in interfaceMqttService
-
createSocket
- Specified by:
createSocket
in interfaceMqttService
-
didBind
public void didBind()- Specified by:
didBind
in interfaceMqttService
-
didAccept
- Specified by:
didAccept
in interfaceMqttService
-
didUnbind
public void didUnbind()- Specified by:
didUnbind
in interfaceMqttService
-
didFail
- Specified by:
didFail
in interfaceMqttService
-
flowControl
Description copied from interface:FlowContext
Returns the currentFlowControl
state of the underlying network channel.- Specified by:
flowControl
in interfaceFlowContext
-
flowControl
Description copied from interface:FlowContext
Enqueues an atomic replacement of the underlying network channel's flow control state with a newflowControl
.- Specified by:
flowControl
in interfaceFlowContext
-
flowControl
Description copied from interface:FlowContext
Enqueues an atomic modification to the underlying network channel's flow control state by applying aflowModifier
delta.- Specified by:
flowControl
in interfaceFlowContext
-
mqttSettings
-
localAddress
-
unbind
public void unbind()
-