io.druid.firehose.rabbitmq

Class JacksonifiedConnectionFactory

java.lang.Object

com.rabbitmq.client.ConnectionFactory

io.druid.firehose.rabbitmq.JacksonifiedConnectionFactory

All Implemented Interfaces:

Cloneable

public class JacksonifiedConnectionFactory
extends com.rabbitmq.client.ConnectionFactory

A Jacksonified version of the RabbitMQ ConnectionFactory for better integration into the realtime.spec configuration file format.

Field Summary

Fields inherited from class com.rabbitmq.client.ConnectionFactory

DEFAULT_AMQP_OVER_SSL_PORT, DEFAULT_AMQP_PORT, DEFAULT_CHANNEL_MAX, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_FRAME_MAX, DEFAULT_HEARTBEAT, DEFAULT_HOST, DEFAULT_NUM_CONSUMER_THREADS, DEFAULT_PASS, DEFAULT_USER, DEFAULT_VHOST, USE_DEFAULT_PORT

Constructor Summary

Constructors

Constructor and Description
JacksonifiedConnectionFactory(String host, int port, String username, String password, String virtualHost, String uri, int requestedChannelMax, int requestedFrameMax, int requestedHeartbeat, int connectionTimeout, Map<String,Object> clientProperties)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
int	getConnectionTimeout()
String	getHost()
String	getPassword()
int	getPort()
int	getRequestedChannelMax()
int	getRequestedFrameMax()
int	getRequestedHeartbeat()
Map<String,Object>	getSerializableClientProperties()
String	getUri()
String	getUsername()
String	getVirtualHost()
int	hashCode()
static JacksonifiedConnectionFactory	makeDefaultConnectionFactory()

Methods inherited from class com.rabbitmq.client.ConnectionFactory

clone, configureSocket, createFrameHandler, createFrameHandler, getClientProperties, getNumConsumerThreads, getSaslConfig, getSocketFactory, isSSL, newConnection, newConnection, newConnection, newConnection, setClientProperties, setConnectionTimeout, setHost, setNumConsumerThreads, setPassword, setPort, setRequestedChannelMax, setRequestedFrameMax, setRequestedHeartbeat, setSaslConfig, setSocketFactory, setUri, setUri, setUsername, setVirtualHost, useSslProtocol, useSslProtocol, useSslProtocol, useSslProtocol

Methods inherited from class java.lang.Object

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

Constructor Detail

JacksonifiedConnectionFactory

public JacksonifiedConnectionFactory(String host,
                             int port,
                             String username,
                             String password,
                             String virtualHost,
                             String uri,
                             int requestedChannelMax,
                             int requestedFrameMax,
                             int requestedHeartbeat,
                             int connectionTimeout,
                             Map<String,Object> clientProperties)
                              throws Exception

Throws:

Exception

Method Detail

makeDefaultConnectionFactory

public static JacksonifiedConnectionFactory makeDefaultConnectionFactory()
                                                                  throws Exception

Throws:

Exception

getHost

public String getHost()

Overrides:

getHost in class com.rabbitmq.client.ConnectionFactory

getPort

public int getPort()

Overrides:

getPort in class com.rabbitmq.client.ConnectionFactory

getUsername

public String getUsername()

Overrides:

getUsername in class com.rabbitmq.client.ConnectionFactory

getPassword

public String getPassword()

Overrides:

getPassword in class com.rabbitmq.client.ConnectionFactory

getVirtualHost

public String getVirtualHost()

Overrides:

getVirtualHost in class com.rabbitmq.client.ConnectionFactory

getUri

public String getUri()

getRequestedChannelMax

public int getRequestedChannelMax()

Overrides:

getRequestedChannelMax in class com.rabbitmq.client.ConnectionFactory

getRequestedFrameMax

public int getRequestedFrameMax()

Overrides:

getRequestedFrameMax in class com.rabbitmq.client.ConnectionFactory

getRequestedHeartbeat

public int getRequestedHeartbeat()

Overrides:

getRequestedHeartbeat in class com.rabbitmq.client.ConnectionFactory

getConnectionTimeout

public int getConnectionTimeout()

Overrides:

getConnectionTimeout in class com.rabbitmq.client.ConnectionFactory

getSerializableClientProperties

public Map<String,Object> getSerializableClientProperties()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object