org.apache.storm.messaging.netty

Class Context

java.lang.Object

org.apache.storm.messaging.netty.Context

All Implemented Interfaces:

IContext

public class Context
extends Object
implements IContext

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and Description
IConnection	bind(String storm_id, int port) establish a server with a binding port
IConnection	connect(String storm_id, String host, int port, AtomicBoolean[] remoteBpStatus) establish a connection to a remote server
void	prepare(Map<String,Object> topoConf) initialization per Storm configuration
void	term() terminate this context

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Context

public Context()

Method Detail

prepare

public void prepare(Map<String,Object> topoConf)

initialization per Storm configuration

Specified by:

prepare in interface IContext

Parameters:

topoConf - storm configuration

bind

public IConnection bind(String storm_id,
                        int port)

establish a server with a binding port

Specified by:

bind in interface IContext

Parameters:

storm_id - topology ID

port - port #

Returns:

server side connection

connect

public IConnection connect(String storm_id,
                           String host,
                           int port,
                           AtomicBoolean[] remoteBpStatus)

establish a connection to a remote server

Specified by:

connect in interface IContext

Parameters:

storm_id - topology ID

host - remote host

port - remote port

remoteBpStatus - array of booleans reflecting Back Pressure status of remote tasks.

Returns:

client side connection

term

public void term()

terminate this context

Specified by:

term in interface IContext