Package org.correomqtt.core.connection

Class ReconnectTask

java.lang.Object

org.correomqtt.core.concurrent.NoProgressTask<Void,Void>

org.correomqtt.core.connection.ReconnectTask

@DefaultBean
public class ReconnectTask
extends NoProgressTask<Void,Void>

Field Summary

Fields

Modifier and Type	Field	Description
protected final SoyEvents	soyEvents

Constructor Summary

Constructors

Constructor	Description
ReconnectTask(SubscribeTaskFactory subscribeTaskFactory, SoyEvents soyEvents, CorreoMqttClientFactory correoMqttClientFactory, ConnectionManager connectionManager, String connectionId)

Method Summary

Modifier and Type	Method	Description
protected Void	execute()
CompletableFuture<Void>	run()

Methods inherited from class org.correomqtt.core.concurrent.NoProgressTask

beforeHook, errorHook, finalHook, onError, onFinally, onStarted, onSuccess, successHook

Methods inherited from class java.lang.Object

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

Field Details

soyEvents

protected final SoyEvents soyEvents

Constructor Details

ReconnectTask

@Inject
public ReconnectTask(SubscribeTaskFactory subscribeTaskFactory,
 SoyEvents soyEvents,
 CorreoMqttClientFactory correoMqttClientFactory,
 ConnectionManager connectionManager,
 @Assisted
 String connectionId)

Method Details

execute

protected Void execute()
                throws Exception

Specified by:

execute in class NoProgressTask<Void,Void>

Throws:

Exception

run

public CompletableFuture<Void> run()