Package io.vertx.mutiny.ext.stomp

Class StompServerConnection

java.lang.Object

io.vertx.mutiny.ext.stomp.StompServerConnection

public class StompServerConnection
extends Object

Class representing a connection between a STOMP client a the server. It keeps a references on the client socket, so let write to this socket.

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field	Description
static TypeArg<StompServerConnection>	__TYPE_ARG

Constructor Summary

Constructors

Constructor	Description
StompServerConnection(io.vertx.ext.stomp.StompServerConnection delegate)
StompServerConnection(Object delegate)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configureHeartbeat(long ping, long pong, Consumer<StompServerConnection> pingHandler)
boolean	equals(Object o)
io.vertx.ext.stomp.StompServerConnection	getDelegate()
StompServerHandler	handler()
int	hashCode()
static StompServerConnection	newInstance(io.vertx.ext.stomp.StompServerConnection arg)
void	onServerActivity()
void	ping()
StompServer	server()
String	session()
SSLSession	sslSession()
String	toString()
StompServerConnection	write(io.vertx.ext.stomp.Frame frame)
StompServerConnection	write(Buffer buffer)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final TypeArg<StompServerConnection> __TYPE_ARG

Constructor Detail

StompServerConnection

public StompServerConnection(io.vertx.ext.stomp.StompServerConnection delegate)

StompServerConnection

public StompServerConnection(Object delegate)

Method Detail

getDelegate

public io.vertx.ext.stomp.StompServerConnection getDelegate()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

write

public StompServerConnection write(io.vertx.ext.stomp.Frame frame)

Parameters:

frame - the frame, must not be null.

Returns:

the current StompServerConnection

write

public StompServerConnection write(Buffer buffer)

Parameters:

buffer - the buffer

Returns:

the current StompServerConnection

server

public StompServer server()

Returns:

the STOMP server serving this connection.

handler

public StompServerHandler handler()

Returns:

the STOMP server handler dealing with this connection

session

public String session()

Returns:

the STOMP session id computed when the client has established the connection to the server

close

public void close()

ping

public void ping()

onServerActivity

public void onServerActivity()

configureHeartbeat

public void configureHeartbeat(long ping,
                               long pong,
                               Consumer<StompServerConnection> pingHandler)

Parameters:

ping - ping time

pong - pong time

pingHandler - the ping handler

sslSession

public SSLSession sslSession()

Returns:

SSLSession associated with the underlying socket. Returns null if connection is not SSL.

newInstance

public static StompServerConnection newInstance(io.vertx.ext.stomp.StompServerConnection arg)