MqttEndpointImpl (Vertx Javadocs 4.0.3.GA API)

java.lang.Object
- io.vertx.mqtt.impl.MqttEndpointImpl

All Implemented Interfaces:

MqttEndpoint
```
public class MqttEndpointImpl
extends Object
implements MqttEndpoint
```
Represents an MQTT endpoint for point-to-point communication with the remote MQTT client

Constructor Summary

Constructors
Constructor and Description
`MqttEndpointImpl(NetSocketInternal conn, String clientIdentifier, MqttAuth auth, MqttWill will, boolean isCleanSession, int protocolVersion, String protocolName, int keepAliveTimeoutSeconds)` Constructor

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`MqttEndpoint`	`accept()` Like `MqttEndpoint.accept(boolean)` with no session is present.
`MqttEndpointImpl`	`accept(boolean sessionPresent)` Sends the CONNACK message to the remote MQTT client with "connection accepted" return code.
`MqttAuth`	`auth()`
`MqttEndpoint`	`autoKeepAlive(boolean isAutoKeepAlive)` Enable/disable auto keep alive (sending ping response)
`String`	`clientIdentifier()`
`void`	`close()` Close the endpoint, so the connection with remote MQTT client
`MqttEndpointImpl`	`closeHandler(Handler<Void> handler)` Set a close handler.
`MqttEndpointImpl`	`disconnectHandler(Handler<Void> handler)` Set a disconnect handler on the MQTT endpoint.
`MqttEndpointImpl`	`exceptionHandler(Handler<Throwable> handler)` Set an exception handler.
`boolean`	`isAutoKeepAlive()`
`boolean`	`isCleanSession()`
`boolean`	`isConnected()`
`boolean`	`isPublishAutoAck()`
`boolean`	`isSsl()`
`boolean`	`isSubscriptionAutoAck()`
`int`	`keepAliveTimeSeconds()`
`int`	`lastMessageId()`
`SocketAddress`	`localAddress()`
`MqttEndpointImpl`	`pingHandler(Handler<Void> handler)` Set the pingreq handler on the MQTT endpoint.
`MqttEndpointImpl`	`pong()` Sends the PINGRESP message to the remote MQTT client
`String`	`protocolName()`
`int`	`protocolVersion()`
`Future<Integer>`	`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain)` Sends the PUBLISH message to the remote MQTT client
`MqttEndpointImpl`	`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, Handler<AsyncResult<Integer>> publishSentHandler)` Sends the PUBLISH message to the remote MQTT server
`Future<Integer>`	`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId)` Like `MqttEndpoint.publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler)` but returns a `Future` of the asynchronous result
`MqttEndpointImpl`	`publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, Handler<AsyncResult<Integer>> publishSentHandler)` Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
`MqttEndpointImpl`	`publishAcknowledge(int publishMessageId)` Sends the PUBACK message to the remote MQTT client
`MqttEndpointImpl`	`publishAcknowledgeHandler(Handler<Integer> handler)` Set the puback handler on the MQTT endpoint.
`MqttEndpoint`	`publishAutoAck(boolean isPublishAutoAck)` Enable/disable publishing (in/out) auto acknowledge
`MqttEndpointImpl`	`publishComplete(int publishMessageId)` Sends the PUBCOMP message to the remote MQTT client
`MqttEndpointImpl`	`publishCompletionHandler(Handler<Integer> handler)` Set the pubcomp handler on the MQTT endpoint.
`MqttEndpointImpl`	`publishHandler(Handler<MqttPublishMessage> handler)` Set the publish handler on the MQTT endpoint.
`MqttEndpointImpl`	`publishReceived(int publishMessageId)` Sends the PUBREC message to the remote MQTT client
`MqttEndpointImpl`	`publishReceivedHandler(Handler<Integer> handler)` Set the pubrec handler on the MQTT endpoint.
`MqttEndpointImpl`	`publishRelease(int publishMessageId)` Sends the PUBREL message to the remote MQTT client
`MqttEndpointImpl`	`publishReleaseHandler(Handler<Integer> handler)` Set the pubrel handler on the MQTT endpoint.
`MqttEndpointImpl`	`reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode)` Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.
`SocketAddress`	`remoteAddress()`
`MqttEndpoint`	`setClientIdentifier(String clientIdentifier)` Set client identifier if not provided by the remote MQTT client (zero-bytes)
`SSLSession`	`sslSession()`
`MqttEndpointImpl`	`subscribeAcknowledge(int subscribeMessageId, List<io.netty.handler.codec.mqtt.MqttQoS> grantedQoSLevels)` Sends the SUBACK message to the remote MQTT client
`MqttEndpointImpl`	`subscribeHandler(Handler<MqttSubscribeMessage> handler)` Set a subscribe handler on the MQTT endpoint.
`void`	`subscriptionAutoAck(boolean isSubscriptionAutoAck)` Enable/disable subscription/unsubscription requests auto acknowledge
`MqttEndpointImpl`	`unsubscribeAcknowledge(int unsubscribeMessageId)` Sends the UNSUBACK message to the remote MQTT client
`MqttEndpointImpl`	`unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)` Set a unsubscribe handler on the MQTT endpoint.
`MqttWill`	`will()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MqttEndpointImpl
```
public MqttEndpointImpl(NetSocketInternal conn,
                        String clientIdentifier,
                        MqttAuth auth,
                        MqttWill will,
                        boolean isCleanSession,
                        int protocolVersion,
                        String protocolName,
                        int keepAliveTimeoutSeconds)
```
    Constructor
    
    Parameters:
    
    conn - connection instance with the remote MQTT client
    
    clientIdentifier - client identifier of the remote
    
    auth - instance with the authentication information
    
    will - instance with the will information
    
    isCleanSession - if the sessione should be cleaned or not
    
    protocolVersion - protocol version required by the client
    
    protocolName - protocol name sent by the client
    
    keepAliveTimeoutSeconds - keep alive timeout (in seconds)
- Method Detail
  - clientIdentifier
```
public String clientIdentifier()
```
    Specified by:
    
    clientIdentifier in interface MqttEndpoint
    
    Returns:
    
    the client identifier as provided by the remote MQTT client
  - auth
```
public MqttAuth auth()
```
    Specified by:
    
    auth in interface MqttEndpoint
    
    Returns:
    
    the Authentication information as provided by the remote MQTT client
  - will
```
public MqttWill will()
```
    Specified by:
    
    will in interface MqttEndpoint
    
    Returns:
    
    the Will information as provided by the remote MQTT client
  - isCleanSession
```
public boolean isCleanSession()
```
    Specified by:
    
    isCleanSession in interface MqttEndpoint
    
    Returns:
    
    true when clean session is requested by the remote MQTT client
  - protocolVersion
```
public int protocolVersion()
```
    Specified by:
    
    protocolVersion in interface MqttEndpoint
    
    Returns:
    
    the protocol version required by the remote MQTT client
  - protocolName
```
public String protocolName()
```
    Specified by:
    
    protocolName in interface MqttEndpoint
    
    Returns:
    
    the protocol name provided by the remote MQTT client
  - keepAliveTimeSeconds
```
public int keepAliveTimeSeconds()
```
    Specified by:
    
    keepAliveTimeSeconds in interface MqttEndpoint
    
    Returns:
    
    the keep alive timeout (in seconds) specified by the remote MQTT client
  - lastMessageId
```
public int lastMessageId()
```
    Specified by:
    
    lastMessageId in interface MqttEndpoint
    
    Returns:
    
    the message identifier used for last published message
  - subscriptionAutoAck
```
public void subscriptionAutoAck(boolean isSubscriptionAutoAck)
```
    Description copied from interface: MqttEndpoint
    
    Enable/disable subscription/unsubscription requests auto acknowledge
    
    Specified by:
    
    subscriptionAutoAck in interface MqttEndpoint
    
    Parameters:
    
    isSubscriptionAutoAck - auto acknowledge status
  - isSubscriptionAutoAck
```
public boolean isSubscriptionAutoAck()
```
    Specified by:
    
    isSubscriptionAutoAck in interface MqttEndpoint
    
    Returns:
    
    true when auto acknowledge status for subscription/unsubscription requests
  - publishAutoAck
```
public MqttEndpoint publishAutoAck(boolean isPublishAutoAck)
```
    Description copied from interface: MqttEndpoint
    
    Enable/disable publishing (in/out) auto acknowledge
    
    Specified by:
    
    publishAutoAck in interface MqttEndpoint
    
    Parameters:
    
    isPublishAutoAck - auto acknowledge status
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - isPublishAutoAck
```
public boolean isPublishAutoAck()
```
    Specified by:
    
    isPublishAutoAck in interface MqttEndpoint
    
    Returns:
    
    auto acknowledge status for publishing (in/out)
  - autoKeepAlive
```
public MqttEndpoint autoKeepAlive(boolean isAutoKeepAlive)
```
    Description copied from interface: MqttEndpoint
    
    Enable/disable auto keep alive (sending ping response)
    
    Specified by:
    
    autoKeepAlive in interface MqttEndpoint
    
    Parameters:
    
    isAutoKeepAlive - auto keep alive
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - isAutoKeepAlive
```
public boolean isAutoKeepAlive()
```
    Specified by:
    
    isAutoKeepAlive in interface MqttEndpoint
    
    Returns:
    
    the auto keep alive status (sending ping response)
  - isConnected
```
public boolean isConnected()
```
    Specified by:
    
    isConnected in interface MqttEndpoint
    
    Returns:
    
    if the connection between remote client and local endpoint is established/open
  - setClientIdentifier
```
public MqttEndpoint setClientIdentifier(String clientIdentifier)
```
    Description copied from interface: MqttEndpoint
    
    Set client identifier if not provided by the remote MQTT client (zero-bytes)
    
    Specified by:
    
    setClientIdentifier in interface MqttEndpoint
    
    Parameters:
    
    clientIdentifier - the client identifier
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - disconnectHandler
```
public MqttEndpointImpl disconnectHandler(Handler<Void> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set a disconnect handler on the MQTT endpoint. This handler is called when a DISCONNECT message is received by the remote MQTT client
    
    Specified by:
    
    disconnectHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - subscribeHandler
```
public MqttEndpointImpl subscribeHandler(Handler<MqttSubscribeMessage> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set a subscribe handler on the MQTT endpoint. This handler is called when a SUBSCRIBE message is received by the remote MQTT client
    
    Specified by:
    
    subscribeHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - unsubscribeHandler
```
public MqttEndpointImpl unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set a unsubscribe handler on the MQTT endpoint. This handler is called when a UNSUBSCRIBE message is received by the remote MQTT client
    
    Specified by:
    
    unsubscribeHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishHandler
```
public MqttEndpointImpl publishHandler(Handler<MqttPublishMessage> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the publish handler on the MQTT endpoint. This handler is called when a PUBLISH message is received by the remote MQTT client
    
    Specified by:
    
    publishHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishAcknowledgeHandler
```
public MqttEndpointImpl publishAcknowledgeHandler(Handler<Integer> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the puback handler on the MQTT endpoint. This handler is called when a PUBACK message is received by the remote MQTT client
    
    Specified by:
    
    publishAcknowledgeHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishReceivedHandler
```
public MqttEndpointImpl publishReceivedHandler(Handler<Integer> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the pubrec handler on the MQTT endpoint. This handler is called when a PUBREC message is received by the remote MQTT client
    
    Specified by:
    
    publishReceivedHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishReleaseHandler
```
public MqttEndpointImpl publishReleaseHandler(Handler<Integer> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the pubrel handler on the MQTT endpoint. This handler is called when a PUBREL message is received by the remote MQTT client
    
    Specified by:
    
    publishReleaseHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishCompletionHandler
```
public MqttEndpointImpl publishCompletionHandler(Handler<Integer> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the pubcomp handler on the MQTT endpoint. This handler is called when a PUBCOMP message is received by the remote MQTT client
    
    Specified by:
    
    publishCompletionHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - pingHandler
```
public MqttEndpointImpl pingHandler(Handler<Void> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set the pingreq handler on the MQTT endpoint. This handler is called when a PINGREQ message is received by the remote MQTT client. In any case the endpoint sends the PINGRESP internally after executing this handler.
    
    Specified by:
    
    pingHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - closeHandler
```
public MqttEndpointImpl closeHandler(Handler<Void> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set a close handler. This will be called when the MQTT endpoint is closed
    
    Specified by:
    
    closeHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - exceptionHandler
```
public MqttEndpointImpl exceptionHandler(Handler<Throwable> handler)
```
    Description copied from interface: MqttEndpoint
    
    Set an exception handler. This will be called when an error at protocol level happens
    
    Specified by:
    
    exceptionHandler in interface MqttEndpoint
    
    Parameters:
    
    handler - the handler
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - accept
```
public MqttEndpoint accept()
```
    Description copied from interface: MqttEndpoint
    
    Like MqttEndpoint.accept(boolean) with no session is present.
    
    Specified by:
    
    accept in interface MqttEndpoint
  - accept
```
public MqttEndpointImpl accept(boolean sessionPresent)
```
    Description copied from interface: MqttEndpoint
    
    Sends the CONNACK message to the remote MQTT client with "connection accepted" return code. See MqttEndpoint.reject(MqttConnectReturnCode) for refusing connection
    
    Specified by:
    
    accept in interface MqttEndpoint
    
    Parameters:
    
    sessionPresent - if a previous session is present
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - reject
```
public MqttEndpointImpl reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode)
```
    Description copied from interface: MqttEndpoint
    
    Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code. See MqttEndpoint.accept(boolean) for accepting connection
    
    Specified by:
    
    reject in interface MqttEndpoint
    
    Parameters:
    
    returnCode - the connect return code
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - subscribeAcknowledge
```
public MqttEndpointImpl subscribeAcknowledge(int subscribeMessageId,
                                             List<io.netty.handler.codec.mqtt.MqttQoS> grantedQoSLevels)
```
    Description copied from interface: MqttEndpoint
    
    Sends the SUBACK message to the remote MQTT client
    
    Specified by:
    
    subscribeAcknowledge in interface MqttEndpoint
    
    Parameters:
    
    subscribeMessageId - identifier of the SUBSCRIBE message to acknowledge
    
    grantedQoSLevels - granted QoS levels for the requested topics
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - unsubscribeAcknowledge
```
public MqttEndpointImpl unsubscribeAcknowledge(int unsubscribeMessageId)
```
    Description copied from interface: MqttEndpoint
    
    Sends the UNSUBACK message to the remote MQTT client
    
    Specified by:
    
    unsubscribeAcknowledge in interface MqttEndpoint
    
    Parameters:
    
    unsubscribeMessageId - identifier of the UNSUBSCRIBE message to acknowledge
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishAcknowledge
```
public MqttEndpointImpl publishAcknowledge(int publishMessageId)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBACK message to the remote MQTT client
    
    Specified by:
    
    publishAcknowledge in interface MqttEndpoint
    
    Parameters:
    
    publishMessageId - identifier of the PUBLISH message to acknowledge
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishReceived
```
public MqttEndpointImpl publishReceived(int publishMessageId)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBREC message to the remote MQTT client
    
    Specified by:
    
    publishReceived in interface MqttEndpoint
    
    Parameters:
    
    publishMessageId - identifier of the PUBLISH message to acknowledge
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishRelease
```
public MqttEndpointImpl publishRelease(int publishMessageId)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBREL message to the remote MQTT client
    
    Specified by:
    
    publishRelease in interface MqttEndpoint
    
    Parameters:
    
    publishMessageId - identifier of the PUBLISH message to acknowledge
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publishComplete
```
public MqttEndpointImpl publishComplete(int publishMessageId)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBCOMP message to the remote MQTT client
    
    Specified by:
    
    publishComplete in interface MqttEndpoint
    
    Parameters:
    
    publishMessageId - identifier of the PUBLISH message to acknowledge
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - publish
```
public Future<Integer> publish(String topic,
                               Buffer payload,
                               io.netty.handler.codec.mqtt.MqttQoS qosLevel,
                               boolean isDup,
                               boolean isRetain)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBLISH message to the remote MQTT client
    
    Specified by:
    
    publish in interface MqttEndpoint
    
    Parameters:
    
    topic - topic on which the message is published
    
    payload - message payload
    
    qosLevel - quality of service level
    
    isDup - if the message is a duplicate
    
    isRetain - if the message needs to be retained
    
    Returns:
    
    a Future completed after PUBLISH packet sent with a packetId
  - publish
```
public MqttEndpointImpl publish(String topic,
                                Buffer payload,
                                io.netty.handler.codec.mqtt.MqttQoS qosLevel,
                                boolean isDup,
                                boolean isRetain,
                                Handler<AsyncResult<Integer>> publishSentHandler)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBLISH message to the remote MQTT server
    
    Specified by:
    
    publish in interface MqttEndpoint
    
    Parameters:
    
    topic - topic on which the message is published
    
    payload - message payload
    
    qosLevel - QoS level
    
    isDup - if the message is a duplicate
    
    isRetain - if the message needs to be retained
    
    publishSentHandler - handler called after PUBLISH packet sent with a packetId
    
    Returns:
    
    current MQTT client instance
  - publish
```
public Future<Integer> publish(String topic,
                               Buffer payload,
                               io.netty.handler.codec.mqtt.MqttQoS qosLevel,
                               boolean isDup,
                               boolean isRetain,
                               int messageId)
```
    Description copied from interface: MqttEndpoint
    
    Like MqttEndpoint.publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler) but returns a Future of the asynchronous result
    
    Specified by:
    
    publish in interface MqttEndpoint
  - publish
```
public MqttEndpointImpl publish(String topic,
                                Buffer payload,
                                io.netty.handler.codec.mqtt.MqttQoS qosLevel,
                                boolean isDup,
                                boolean isRetain,
                                int messageId,
                                Handler<AsyncResult<Integer>> publishSentHandler)
```
    Description copied from interface: MqttEndpoint
    
    Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
    
    Specified by:
    
    publish in interface MqttEndpoint
    
    Parameters:
    
    topic - topic on which the message is published
    
    payload - message payload
    
    qosLevel - QoS level
    
    isDup - if the message is a duplicate
    
    isRetain - if the message needs to be retained
    
    messageId - message ID
    
    publishSentHandler - handler called after PUBLISH packet sent with a packetId
    
    Returns:
    
    current MQTT client instance
  - pong
```
public MqttEndpointImpl pong()
```
    Description copied from interface: MqttEndpoint
    
    Sends the PINGRESP message to the remote MQTT client
    
    Specified by:
    
    pong in interface MqttEndpoint
    
    Returns:
    
    a reference to this, so the API can be used fluently
  - close
```
public void close()
```
    Description copied from interface: MqttEndpoint
    
    Close the endpoint, so the connection with remote MQTT client
    
    Specified by:
    
    close in interface MqttEndpoint
  - localAddress
```
public SocketAddress localAddress()
```
    Specified by:
    
    localAddress in interface MqttEndpoint
    
    Returns:
    
    the local address for this socket
  - remoteAddress
```
public SocketAddress remoteAddress()
```
    Specified by:
    
    remoteAddress in interface MqttEndpoint
    
    Returns:
    
    the remote address for this socket
  - isSsl
```
public boolean isSsl()
```
    Specified by:
    
    isSsl in interface MqttEndpoint
    
    Returns:
    
    true if this MqttEndpoint is encrypted via SSL/TLS.
  - sslSession
```
public SSLSession sslSession()
```
    Specified by:
    
    sslSession in interface MqttEndpoint
    
    Returns:
    
    SSLSession associated with the underlying socket. Returns null if connection is not SSL.
    
    See Also:
    
    SSLSession

Class MqttEndpointImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

MqttEndpointImpl

Method Detail

clientIdentifier

auth

will

isCleanSession

protocolVersion

protocolName

keepAliveTimeSeconds

lastMessageId

subscriptionAutoAck

isSubscriptionAutoAck

publishAutoAck

isPublishAutoAck

autoKeepAlive

isAutoKeepAlive

isConnected

setClientIdentifier

disconnectHandler

subscribeHandler

unsubscribeHandler

publishHandler

publishAcknowledgeHandler

publishReceivedHandler

publishReleaseHandler

publishCompletionHandler

pingHandler

closeHandler

exceptionHandler

accept

accept

reject

subscribeAcknowledge

unsubscribeAcknowledge

publishAcknowledge

publishReceived

publishRelease

publishComplete

publish

publish

publish

publish

pong

close

localAddress

remoteAddress

isSsl

sslSession