Package | Description |
---|---|
org.apache.storm.multilang | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
void |
ISerializer.writeBoltMsg(BoltMsg msg)
This method sends a bolt message to a non-JVM bolt process.
|
void |
JsonSerializer.writeBoltMsg(BoltMsg boltMsg) |
Modifier and Type | Method and Description |
---|---|
void |
ShellBoltMessageQueue.putBoltMsg(BoltMsg boltMsg)
put bolt message to its queue.
|
void |
ShellProcess.writeBoltMsg(BoltMsg msg) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.