Package | Description |
---|---|
org.apache.storm.jms.bolt | |
org.apache.storm.jms.example | |
org.apache.storm.jms.spout | |
org.apache.storm.jms.trident |
Modifier and Type | Method and Description |
---|---|
void |
JmsBolt.setJmsProvider(JmsProvider provider)
Set the JmsProvider used to connect to the JMS destination topic/queue.
|
Modifier and Type | Class and Description |
---|---|
class |
SpringJmsProvider
A
JmsProvider that uses the spring framework to obtain a JMS ConnectionFactory and Desitnation objects. |
Modifier and Type | Method and Description |
---|---|
void |
JmsSpout.setJmsProvider(JmsProvider provider)
Set
JmsSpout.jmsProvider . |
Modifier and Type | Method and Description |
---|---|
TridentJmsSpout |
TridentJmsSpout.withJmsProvider(JmsProvider provider)
Set the
JmsProvider implementation that this Spout will use to connect to a JMS javax.jms.Desination . |
JmsState.Options |
JmsState.Options.withJmsProvider(JmsProvider provider) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.