Package | Description |
---|---|
org.apache.storm.jms.trident |
Modifier and Type | Method and Description |
---|---|
ITridentSpout.BatchCoordinator<JmsBatch> |
TridentJmsSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.Emitter<JmsBatch> |
TridentJmsSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.