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