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 © 2016 The Apache Software Foundation. All Rights Reserved.