Uses of Class
org.apache.storm.jms.trident.TridentJmsSpout
-
Packages that use TridentJmsSpout Package Description org.apache.storm.jms.trident -
-
Uses of TridentJmsSpout in org.apache.storm.jms.trident
Methods in org.apache.storm.jms.trident that return TridentJmsSpout Modifier and Type Method Description TridentJmsSpout
TridentJmsSpout. named(String name)
Set the name for this spout, to improve log identification.TridentJmsSpout
TridentJmsSpout. withJmsAcknowledgeMode(int jmsAcknowledgeMode)
Set the JMS acknowledge mode for messages being processed by this spout.TridentJmsSpout
TridentJmsSpout. withJmsProvider(JmsProvider provider)
Set theJmsProvider
implementation that this Spout will use to connect to a JMSjavax.jms.Desination
.TridentJmsSpout
TridentJmsSpout. withTupleProducer(JmsTupleProducer tupleProducer)
Set theJmsTupleProducer
implementation that will convertjavax.jms.Message
object tobacktype.storm.tuple.Values
objects to be emitted.
-