reactor.rabbitmq

Class Utils.SingleConnectionSupplier

java.lang.Object

reactor.rabbitmq.Utils.SingleConnectionSupplier

All Implemented Interfaces:

Utils.ExceptionFunction<ConnectionFactory,Connection>

Enclosing class:

Utils

public static class Utils.SingleConnectionSupplier
extends Object
implements Utils.ExceptionFunction<ConnectionFactory,Connection>

Constructor Summary

Constructors

Constructor and Description
SingleConnectionSupplier(Callable<? extends Connection> creationAction)
SingleConnectionSupplier(Callable<? extends Connection> creationAction, Duration waitTimeout)

Method Summary

Modifier and Type	Method and Description
Connection	apply(ConnectionFactory connectionFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleConnectionSupplier

public SingleConnectionSupplier(Callable<? extends Connection> creationAction)

SingleConnectionSupplier

public SingleConnectionSupplier(Callable<? extends Connection> creationAction,
                                Duration waitTimeout)

Method Detail

apply

public Connection apply(ConnectionFactory connectionFactory)
                 throws Exception

Specified by:

apply in interface Utils.ExceptionFunction<ConnectionFactory,Connection>

Throws:

Exception