A C D E F I N O Q S W

A

ack(Object) - Method in class com.rapportive.storm.spout.AMQPSpout

Acks the message with the AMQP broker.

AMQPSpout - Class in com.rapportive.storm.spout

Spout to feed messages into Storm from an AMQP queue.

AMQPSpout(String, int, String, String, String, QueueDeclaration, Scheme) - Constructor for class com.rapportive.storm.spout.AMQPSpout

Create a new AMQP spout.

C

close() - Method in class com.rapportive.storm.spout.AMQPSpout

Cancels the queue subscription, and disconnects from the AMQP broker.

com.rapportive.storm.amqp - package com.rapportive.storm.amqp

com.rapportive.storm.spout - package com.rapportive.storm.spout

CONFIG_PREFETCH_COUNT - Static variable in class com.rapportive.storm.spout.AMQPSpout

Storm config key to set the AMQP basic.qos prefetch-count parameter.

D

declare(Channel) - Method in class com.rapportive.storm.amqp.ExclusiveQueueWithBinding

Verifies the exchange exists, creates an exclusive, server-named queue and binds it to the exchange.

declare(Channel) - Method in interface com.rapportive.storm.amqp.QueueDeclaration

Declare the queue, and any exchanges and bindings that it needs.

declare(Channel) - Method in class com.rapportive.storm.amqp.SharedQueueWithBinding

Verifies the exchange exists, creates the named queue if it does not exist, and binds it to the exchange.

declareOutputFields(OutputFieldsDeclarer) - Method in class com.rapportive.storm.spout.AMQPSpout

Declares the output fields of this spout according to the provided Scheme.

E

ExclusiveQueueWithBinding - Class in com.rapportive.storm.amqp

Declares an exclusive, server-named queue and binds it to an existing exchange.

ExclusiveQueueWithBinding(String, String) - Constructor for class com.rapportive.storm.amqp.ExclusiveQueueWithBinding

Create a declaration of an exclusive server-named queue bound to the specified exchange.

F

fail(Object) - Method in class com.rapportive.storm.spout.AMQPSpout

Tells the AMQP broker to drop (Basic.Reject) the message.

I

isDistributed() - Method in class com.rapportive.storm.spout.AMQPSpout

This spout can be distributed among multiple workers if the QueueDeclaration supports it.

isParallelConsumable() - Method in class com.rapportive.storm.amqp.ExclusiveQueueWithBinding

Returns false as this queue is not safe for parallel consumers.

isParallelConsumable() - Method in interface com.rapportive.storm.amqp.QueueDeclaration

Indicate whether this queue is safe for parallel consumers.

isParallelConsumable() - Method in class com.rapportive.storm.amqp.SharedQueueWithBinding

Returns true as this queue is safe for parallel consumers.

N

nextTuple() - Method in class com.rapportive.storm.spout.AMQPSpout

Emits the next message from the queue as a tuple.

O

open(Map, TopologyContext, SpoutOutputCollector) - Method in class com.rapportive.storm.spout.AMQPSpout

Connects to the AMQP broker, declares the queue and subscribes to incoming messages.

Q

QueueDeclaration - Interface in com.rapportive.storm.amqp

Declaration of a queue to consume, and any exchange bindings the queue needs.

S

SharedQueueWithBinding - Class in com.rapportive.storm.amqp

Declares a named, durable queue and binds it to an existing exchange.

SharedQueueWithBinding(String, String, String) - Constructor for class com.rapportive.storm.amqp.SharedQueueWithBinding

Create a declaration of a named, durable, non-exclusive queue bound to the specified exchange.

W

WAIT_AFTER_SHUTDOWN_SIGNAL - Static variable in class com.rapportive.storm.spout.AMQPSpout

Time in milliseconds to wait after losing connection to the AMQP broker before attempting to reconnect.

WAIT_FOR_NEXT_MESSAGE - Static variable in class com.rapportive.storm.spout.AMQPSpout

Time in milliseconds to wait for a message from the queue if there is no message ready when the topology requests a tuple (via AMQPSpout.nextTuple()).

A C D E F I N O Q S W