org.apache.storm.messaging.local

Class Context

java.lang.Object

org.apache.storm.messaging.local.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) 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 implementation should return a new connection every call
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

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 storm_conf)

Description copied from interface: IContext

This method is invoked at the startup of messaging plugin

Specified by:

prepare in interface IContext

Parameters:

storm_conf - storm configuration

bind

public IConnection bind(String storm_id,
                        int port)

Description copied from interface: IContext

This method establishes a server side connection

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)

Description copied from interface: IContext

This method establish a client side connection to a remote server implementation should return a new connection every call

Specified by:

connect in interface IContext

Parameters:

storm_id - topology ID

host - remote host

port - remote port

Returns:

client side connection

term

public void term()

Description copied from interface: IContext

This method is invoked when a worker is unload a messaging plugin

Specified by:

term in interface IContext