Serialized Form

Package com.rapportive.storm.amqp

Class com.rapportive.storm.amqp.ExclusiveQueueWithBinding extends Object implements Serializable

serialVersionUID:

7923072289071634425L

Serialized Fields

exchange

String exchange

routingKey

String routingKey

Class com.rapportive.storm.amqp.SharedQueueWithBinding extends Object implements Serializable

serialVersionUID:

2364833412534518859L

Serialized Fields

queueName

String queueName

exchange

String exchange

routingKey

String routingKey

queue_ttl

long queue_ttl

queue_expires

long queue_expires

queue_max_length

long queue_max_length

Package com.rapportive.storm.spout

Class com.rapportive.storm.spout.AMQPSpout extends Object implements Serializable

serialVersionUID:

11258942292629265L

Serialized Fields

amqpHost

String amqpHost

amqpPort

int amqpPort

amqpUsername

String amqpUsername

amqpPassword

String amqpPassword

amqpVhost

String amqpVhost

requeueOnFail

boolean requeueOnFail

enableErrorStream

boolean enableErrorStream

autoAck

boolean autoAck

queueDeclaration

QueueDeclaration queueDeclaration

serialisationScheme

org.apache.storm.spout.Scheme serialisationScheme

collector

org.apache.storm.spout.SpoutOutputCollector collector

prefetchCount

int prefetchCount