| Package | Description | 
|---|---|
| org.apache.storm.jms.trident | 
| Modifier and Type | Method and 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 the  
JmsProvider implementation that this Spout will use to connect to a JMS javax.jms.Desination. | 
TridentJmsSpout | 
TridentJmsSpout.withTupleProducer(JmsTupleProducer tupleProducer)
Set the  
JmsTupleProducer implementation that will convert javax.jms.Message object to backtype.storm.tuple.Values objects to be emitted. | 
Copyright © 2020 The Apache Software Foundation. All rights reserved.