rocks.xmpp.extensions.httpbind

Class BoshConnection

java.lang.Object

rocks.xmpp.core.net.AbstractConnection

rocks.xmpp.extensions.httpbind.BoshConnection

All Implemented Interfaces:

java.lang.AutoCloseable, Connection

public final class BoshConnection
extends AbstractConnection

The implementation of XEP-0124: Bidirectional-streams Over Synchronous HTTP (BOSH) and XEP-0206: XMPP Over BOSH.

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletionStage<java.lang.Void>	closeFuture() Returns a future which is complete, when the connection is closed.
long	detach() Detaches this BOSH session without closing (aka terminating) it.
void	flush() Flushes the connection.
java.net.InetSocketAddress	getRemoteAddress() Gets the remote address of this connection.
java.lang.String	getRoute() Gets the route.
java.lang.String	getSessionId() Gets the session id of this BOSH connection.
boolean	isSecure() Indicates whether this connection is secured by TLS/SSL.
boolean	isUsingAcknowledgements() Indicates whether this connection uses acknowledgements, e.g. by means of stream management or BOSH acks.
java.util.concurrent.CompletionStage<java.lang.Void>	open(SessionOpen sessionOpen) Opens the XML stream to the peer entity.
java.util.concurrent.CompletableFuture<java.lang.Void>	send(StreamElement element) Sends an element to the peer entity.
java.lang.String	toString()
java.util.concurrent.CompletableFuture<java.lang.Void>	write(StreamElement streamElement) Writes the element to the stream without really sending it.

Methods inherited from class rocks.xmpp.core.net.AbstractConnection

close, closeAsync, closeAsync, getConfiguration, getStreamId

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

open

public final java.util.concurrent.CompletionStage<java.lang.Void> open(SessionOpen sessionOpen)

Description copied from interface: Connection

Opens the XML stream to the peer entity.

Parameters:

sessionOpen - The session open information.

isSecure

public final boolean isSecure()

Description copied from interface: Connection

Indicates whether this connection is secured by TLS/SSL.

Returns:

True, if this connection is secured.

closeFuture

public final java.util.concurrent.CompletionStage<java.lang.Void> closeFuture()

Description copied from interface: Connection

Returns a future which is complete, when the connection is closed.

Returns:

The close future.

detach

public final long detach()

Detaches this BOSH session without closing (aka terminating) it. This way the BOSH session is still alive on the server and can be ported over to a web page, but new BOSH requests are no longer sent by this connection.

Returns:

The current request ID (RID) which was used for the last BOSH request.

See Also:

https://conversejs.org/docs/html/#prebinding-and-single-session-support

send

public final java.util.concurrent.CompletableFuture<java.lang.Void> send(StreamElement element)

Description copied from interface: Connection

Sends an element to the peer entity. This is basically a short cut for write + flush.

Parameters:

element - The element.

Returns:

The future representing the send process and which allows to cancel it.

write

public final java.util.concurrent.CompletableFuture<java.lang.Void> write(StreamElement streamElement)

Description copied from interface: Connection

Writes the element to the stream without really sending it. It must be flushed.

Parameters:

streamElement - The element.

Returns:

The send future.

flush

public final void flush()

Description copied from interface: Connection

Flushes the connection. Any buffered elements written via Connection.write(StreamElement) are sent.

getSessionId

public final java.lang.String getSessionId()

Gets the session id of this BOSH connection.

Returns:

The session id.

getRemoteAddress

public final java.net.InetSocketAddress getRemoteAddress()

Description copied from interface: Connection

Gets the remote address of this connection.

Returns:

The remote address.

isUsingAcknowledgements

public final boolean isUsingAcknowledgements()

Description copied from interface: Connection

Indicates whether this connection uses acknowledgements, e.g. by means of stream management or BOSH acks.

Specified by:

isUsingAcknowledgements in interface Connection

Overrides:

isUsingAcknowledgements in class AbstractConnection

Returns:

If this connection uses acknowledgements.

getRoute

public final java.lang.String getRoute()

Gets the route.

A connection manager MAY be configured to enable sessions with more than one server in different domains. When requesting a session with such a “proxy” connection manager, a client SHOULD include a ‘route’ attribute that specifies the protocol, hostname, and port of the server with which it wants to communicate, formatted as “proto:host:port” (e.g., “xmpp:example.com:9999”).

Returns:

The route.

toString

public final java.lang.String toString()

Overrides:

toString in class java.lang.Object