rocks.xmpp.core.session

Class SendTask<S extends Stanza>

java.lang.Object

rocks.xmpp.core.session.SendTask<S>

All Implemented Interfaces:

java.util.concurrent.Future<java.lang.Void>

public final class SendTask<S extends Stanza>
extends java.lang.Object
implements java.util.concurrent.Future<java.lang.Void>

A send task is the result of a send action and allows to keep track of the sent stanza.

This class implements Future, which Future.isDone() is done}, when the stanza has been sent to the server.

See Also:

XmppSession.sendMessage(Message)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
java.lang.Void	get()
java.lang.Void	get(long timeout, java.util.concurrent.TimeUnit timeUnit)
S	getStanza() Gets the stanza, which has been sent.
boolean	isCancelled()
boolean	isDone()
void	onAcknowledge(java.util.function.Consumer<S> onAcknowledge) Called when the sent stanza has been acknowledged by the server.
void	onFailed(java.util.function.BiConsumer<java.lang.Throwable,S> onFailure) Called, when a send operation failed.
void	onSent(java.util.function.Consumer<S> onSent) Called, when a stanza has been sent to the server.

Methods inherited from class java.lang.Object

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

Method Detail

getStanza

public final S getStanza()

Gets the stanza, which has been sent.

Returns:

The stanza.

onAcknowledge

public final void onAcknowledge(java.util.function.Consumer<S> onAcknowledge)

Called when the sent stanza has been acknowledged by the server.

Parameters:

onAcknowledge - The consumer.

onSent

public final void onSent(java.util.function.Consumer<S> onSent)

Called, when a stanza has been sent to the server. Note, that this does not mean, that the server received it.

Parameters:

onSent - The callback.

onFailed

public final void onFailed(java.util.function.BiConsumer<java.lang.Throwable,S> onFailure)

Called, when a send operation failed.

Parameters:

onFailure - The callback.

cancel

public final boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<java.lang.Void>

isCancelled

public final boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<java.lang.Void>

isDone

public final boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<java.lang.Void>

get

public final java.lang.Void get()
                         throws java.lang.InterruptedException,
                                java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<java.lang.Void>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public final java.lang.Void get(long timeout,
                                java.util.concurrent.TimeUnit timeUnit)
                         throws java.lang.InterruptedException,
                                java.util.concurrent.ExecutionException,
                                java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<java.lang.Void>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException