Package io.smallrye.reactive.messaging.amqp

Class ConnectionHolder

java.lang.Object

io.smallrye.reactive.messaging.amqp.ConnectionHolder

public class ConnectionHolder
extends Object

Constructor Summary

Constructors

Constructor	Description
ConnectionHolder(io.vertx.mutiny.amqp.AmqpClient client, AmqpConnectorCommonConfiguration configuration, io.vertx.mutiny.core.Vertx vertx)

Method Summary

Modifier and Type	Method	Description
io.vertx.mutiny.core.Context	getContext()
io.smallrye.mutiny.Uni<io.vertx.mutiny.amqp.AmqpConnection>	getOrEstablishConnection()
io.vertx.mutiny.core.Vertx	getVertx()
void	onFailure(Consumer<Throwable> callback)
static CompletionStage<Void>	runOnContext(io.vertx.mutiny.core.Context context, Runnable runnable)
static CompletionStage<Void>	runOnContextAndReportFailure(io.vertx.mutiny.core.Context context, Throwable reason, Runnable runnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionHolder

public ConnectionHolder(io.vertx.mutiny.amqp.AmqpClient client,
                        AmqpConnectorCommonConfiguration configuration,
                        io.vertx.mutiny.core.Vertx vertx)

Method Detail

getContext

public io.vertx.mutiny.core.Context getContext()

getVertx

public io.vertx.mutiny.core.Vertx getVertx()

onFailure

public void onFailure(Consumer<Throwable> callback)

getOrEstablishConnection

public io.smallrye.mutiny.Uni<io.vertx.mutiny.amqp.AmqpConnection> getOrEstablishConnection()

runOnContext

public static CompletionStage<Void> runOnContext(io.vertx.mutiny.core.Context context,
                                                 Runnable runnable)

runOnContextAndReportFailure

public static CompletionStage<Void> runOnContextAndReportFailure(io.vertx.mutiny.core.Context context,
                                                                 Throwable reason,
                                                                 Runnable runnable)