Package org.apache.storm.messaging.local
Class Context
java.lang.Object
org.apache.storm.messaging.local.Context
- All Implemented Interfaces:
IContext
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse) This method establishes a server side connection.connect(String stormId, 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.voidThis method is invoked at the startup of messaging plugin.voidterm()This method is invoked when a worker is unloading a messaging plugin.
-
Constructor Details
-
Context
public Context()
-
-
Method Details
-
prepare
Description copied from interface:IContextThis method is invoked at the startup of messaging plugin. -
bind
public IConnection bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse) Description copied from interface:IContextThis method establishes a server side connection.- Specified by:
bindin interfaceIContext- Parameters:
stormId- topology IDport- port #cb- The callback to deliver received messages tonewConnectionResponse- Supplier of the initial message to send to new client connections. If authentication is required, the message will be sent after authentication is complete.- Returns:
- server side connection
-
connect
Description copied from interface:IContextThis method establish a client side connection to a remote server implementation should return a new connection every call. -
term
public void term()Description copied from interface:IContextThis method is invoked when a worker is unloading a messaging plugin.
-