| Package | Description |
|---|---|
| org.apache.storm.messaging | |
| org.apache.storm.messaging.local | |
| 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 |
|---|---|
IConnection |
IContext.bind(String stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse)
This method establishes a server side connection.
|
| Modifier and Type | Method and Description |
|---|---|
IConnection |
Context.bind(String stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse) |
| Modifier and Type | Method and Description |
|---|---|
IConnection |
Context.bind(String stormId,
int port,
IConnectionCallback cb,
Supplier<Object> newConnectionResponse)
establish a server with a binding port.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.