Uses of Interface
org.apache.storm.utils.JCQueue.Consumer

Packages that use JCQueue.Consumer

Package	Description
org.apache.storm.daemon.worker
org.apache.storm.executor
org.apache.storm.executor.bolt
org.apache.storm.executor.spout
org.apache.storm.utils

Uses of JCQueue.Consumer in org.apache.storm.daemon.worker

Classes in org.apache.storm.daemon.worker that implement JCQueue.Consumer

Modifier and Type	Class and Description
class	WorkerTransfer

Uses of JCQueue.Consumer in org.apache.storm.executor

Classes in org.apache.storm.executor that implement JCQueue.Consumer

Modifier and Type	Class and Description
class	Executor

Uses of JCQueue.Consumer in org.apache.storm.executor.bolt

Classes in org.apache.storm.executor.bolt that implement JCQueue.Consumer

Modifier and Type	Class and Description
class	BoltExecutor

Uses of JCQueue.Consumer in org.apache.storm.executor.spout

Classes in org.apache.storm.executor.spout that implement JCQueue.Consumer

Modifier and Type	Class and Description
class	SpoutExecutor

Uses of JCQueue.Consumer in org.apache.storm.utils

Methods in org.apache.storm.utils with parameters of type JCQueue.Consumer

Modifier and Type	Method and Description
int	JCQueue.consume(JCQueue.Consumer consumer) Non blocking.
int	JCQueue.consume(JCQueue.Consumer consumer, JCQueue.ExitCondition exitCond) Non blocking.