io.druid.firehose.rabbitmq

Class RabbitMQFirehoseConfig

java.lang.Object

io.druid.firehose.rabbitmq.RabbitMQFirehoseConfig

public class RabbitMQFirehoseConfig
extends Object

A configuration object for a RabbitMQ connection.

Constructor Summary

Constructors

Constructor and Description
RabbitMQFirehoseConfig(String queue, String exchange, String routingKey, boolean durable, boolean exclusive, boolean autoDelete, int maxRetries, int retryIntervalSeconds, long maxDurationSeconds)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getExchange()
long	getMaxDurationSeconds()
int	getMaxRetries()
String	getQueue()
int	getRetryIntervalSeconds()
String	getRoutingKey()
int	hashCode()
boolean	isAutoDelete()
boolean	isDurable()
boolean	isExclusive()
static RabbitMQFirehoseConfig	makeDefaultConfig()

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMQFirehoseConfig

public RabbitMQFirehoseConfig(String queue,
                              String exchange,
                              String routingKey,
                              boolean durable,
                              boolean exclusive,
                              boolean autoDelete,
                              int maxRetries,
                              int retryIntervalSeconds,
                              long maxDurationSeconds)

Method Detail

makeDefaultConfig

public static RabbitMQFirehoseConfig makeDefaultConfig()

getQueue

public String getQueue()

getExchange

public String getExchange()

getRoutingKey

public String getRoutingKey()

isDurable

public boolean isDurable()

isExclusive

public boolean isExclusive()

isAutoDelete

public boolean isAutoDelete()

getMaxRetries

public int getMaxRetries()

getRetryIntervalSeconds

public int getRetryIntervalSeconds()

getMaxDurationSeconds

public long getMaxDurationSeconds()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object