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 © 2019 The Apache Software Foundation. All rights reserved.