Constructor and Description |
---|
Context() |
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,
AtomicBoolean[] remoteBpStatus)
This method establish a client side connection to a remote server implementation should return a new connection every call
|
void |
prepare(Map<String,Object> topoConf)
This method is invoked at the startup of messaging plugin
|
void |
term()
This method is invoked when a worker is unloading a messaging plugin
|
public void prepare(Map<String,Object> topoConf)
IContext
This method is invoked at the startup of messaging plugin
public IConnection bind(String storm_id, int port)
IContext
This method establishes a server side connection
public IConnection connect(String storm_id, String host, int port, AtomicBoolean[] remoteBpStatus)
IContext
This method establish a client side connection to a remote server implementation should return a new connection every call
Copyright © 2019 The Apache Software Foundation. All rights reserved.