public interface IContext
| Modifier and Type | Method and Description |
|---|---|
IConnection |
bind(String storm_id,
int port)
This method establishes a server side connection
|
IConnection |
connect(String storm_id,
String host,
int port)
This method establish a client side connection to a remote server
|
void |
prepare(Map storm_conf)
This method is invoked at the startup of messaging plugin
|
void |
term()
This method is invoked when a worker is unload a messaging plugin
|
void prepare(Map storm_conf)
storm_conf - storm configurationvoid term()
IConnection bind(String storm_id, int port)
storm_id - topology IDport - port #IConnection connect(String storm_id, String host, int port)
storm_id - topology IDhost - remote hostport - remote portCopyright © 2015. All rights reserved.