reactor.rabbitmq

Class Utils.SingleConnectionSupplier

java.lang.Object

reactor.rabbitmq.Utils.SingleConnectionSupplier

All Implemented Interfaces:

Utils.ExceptionFunction<com.rabbitmq.client.ConnectionFactory,com.rabbitmq.client.Connection>

Enclosing class:

Utils

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Connection	apply(com.rabbitmq.client.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 com.rabbitmq.client.Connection> creationAction)

SingleConnectionSupplier

public SingleConnectionSupplier(Callable<? extends com.rabbitmq.client.Connection> creationAction,
                                Duration waitTimeout)

Method Detail

apply

public com.rabbitmq.client.Connection apply(com.rabbitmq.client.ConnectionFactory connectionFactory)
                                     throws Exception

Specified by:

apply in interface Utils.ExceptionFunction<com.rabbitmq.client.ConnectionFactory,com.rabbitmq.client.Connection>

Throws:

Exception