com.pivotal.rabbitmq

Class RabbitEndpoint

java.lang.Object

com.pivotal.rabbitmq.RabbitEndpoint

public class RabbitEndpoint
extends Object

Constructor Summary

Constructors

Constructor and Description
RabbitEndpoint(String name, Supplier<String> applicationIdSupplier, Supplier<String> connectionNameSupplier, RabbitProperties rabbitProperties)

Method Summary

Modifier and Type	Method and Description
reactor.util.retry.Retry	amqpConnectionErrors()
void	close()
reactor.rabbitmq.Receiver	createReceiver()
reactor.rabbitmq.Sender	createSender()
Supplier<String>	getApplicationId()
com.rabbitmq.http.client.ReactorNettyClient	getManagementAPI()
RabbitProperties	getProperties()
String	getVirtualHost()
static Predicate<Throwable>	is(Class<? extends Throwable> type)
reactor.util.retry.Retry	managementConnectionErrors()
reactor.util.retry.Retry	topologyAvailabilityErrors()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitEndpoint

public RabbitEndpoint(String name,
                      Supplier<String> applicationIdSupplier,
                      Supplier<String> connectionNameSupplier,
                      RabbitProperties rabbitProperties)

Method Detail

getProperties

public RabbitProperties getProperties()

getApplicationId

public Supplier<String> getApplicationId()

getVirtualHost

public String getVirtualHost()

getManagementAPI

public com.rabbitmq.http.client.ReactorNettyClient getManagementAPI()

createSender

public reactor.rabbitmq.Sender createSender()

createReceiver

public reactor.rabbitmq.Receiver createReceiver()

amqpConnectionErrors

public reactor.util.retry.Retry amqpConnectionErrors()

managementConnectionErrors

public reactor.util.retry.Retry managementConnectionErrors()

topologyAvailabilityErrors

public reactor.util.retry.Retry topologyAvailabilityErrors()

is

public static Predicate<Throwable> is(Class<? extends Throwable> type)

close

public void close()
           throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object