Uses of Interface
org.apache.storm.utils.JCQueue.Consumer
Package
Description
-
Uses of JCQueue.Consumer in org.apache.storm.daemon.worker
-
Uses of JCQueue.Consumer in org.apache.storm.executor
-
Uses of JCQueue.Consumer in org.apache.storm.executor.bolt
-
Uses of JCQueue.Consumer in org.apache.storm.executor.spout
-
Uses of JCQueue.Consumer in org.apache.storm.utils
Modifier and TypeMethodDescriptionint
JCQueue.consume
(JCQueue.Consumer consumer) Non blocking.int
JCQueue.consume
(JCQueue.Consumer consumer, JCQueue.ExitCondition exitCond) Non blocking.