MCPcopy Create free account
hub / github.com/apache/storm / nextId

Method nextId

storm-server/src/main/java/org/apache/storm/daemon/drpc/DRPC.java:164–166  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

162 }
163
164 private String nextId() {
165 return String.valueOf(ctr.incrementAndGet());
166 }
167
168 private ConcurrentLinkedQueue<OutstandingRequest> getQueue(String function) {
169 if (function == null) {

Callers 1

executeMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected