Class Context

java.lang.Object
org.apache.storm.messaging.netty.Context
All Implemented Interfaces:
IContext

public class Context extends Object implements IContext
  • Constructor Details

    • Context

      public Context()
  • Method Details

    • prepare

      public void prepare(Map<String,Object> topoConf)
      initialization per Storm configuration.
      Specified by:
      prepare in interface IContext
      Parameters:
      topoConf - storm configuration
    • prepare

      public void prepare(Map<String,Object> topoConf, StormMetricRegistry metricRegistry)
      Description copied from interface: IContext
      This method is invoked at the startup of messaging plugin.
      Specified by:
      prepare in interface IContext
      Parameters:
      topoConf - storm configuration
      metricRegistry - storm metric registry
    • bind

      public IConnection bind(String stormId, int port, IConnectionCallback cb, Supplier<Object> newConnectionResponse)
      establish a server with a binding port.
      Specified by:
      bind in interface IContext
      Parameters:
      stormId - topology ID
      port - port #
      cb - The callback to deliver received messages to
      newConnectionResponse - 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

      public IConnection connect(String stormId, String host, int port, AtomicBoolean[] remoteBpStatus)
      establish a connection to a remote server.
      Specified by:
      connect in interface IContext
      Parameters:
      stormId - 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