Uses of Interface
com.rapportive.storm.amqp.QueueDeclaration

Packages that use QueueDeclaration

Package	Description
com.rapportive.storm.amqp
com.rapportive.storm.spout

Uses of QueueDeclaration in com.rapportive.storm.amqp

Classes in com.rapportive.storm.amqp that implement QueueDeclaration

Modifier and Type	Class and Description
class	ExclusiveQueueWithBinding Declares an exclusive, server-named queue and binds it to an existing exchange.
class	SharedQueueWithBinding Declares a named, durable queue and binds it to an existing exchange.

Uses of QueueDeclaration in com.rapportive.storm.spout

Constructors in com.rapportive.storm.spout with parameters of type QueueDeclaration

Constructor and Description
AMQPSpout(String host, int port, String username, String password, String vhost, QueueDeclaration queueDeclaration, org.apache.storm.spout.Scheme scheme) Create a new AMQP spout.
AMQPSpout(String host, int port, String username, String password, String vhost, QueueDeclaration queueDeclaration, org.apache.storm.spout.Scheme scheme, boolean requeueOnFail, boolean enableErrorStream, boolean autoAck) Create a new AMQP spout.