Package | Description |
---|---|
org.apache.storm.messaging | |
org.apache.storm.messaging.netty |
Modifier and Type | Class and Description |
---|---|
class |
DeserializingConnectionCallback
A class that is called when a TaskMessage arrives.
|
Modifier and Type | Method and Description |
---|---|
void |
IConnection.registerRecv(IConnectionCallback cb)
Register a callback to be notified when data is ready to be processed.
|
Modifier and Type | Method and Description |
---|---|
void |
Client.registerRecv(IConnectionCallback cb)
Receiving messages is not supported by a client.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.