bin/storm.py
def drpc():
    """Syntax: [storm drpc]

    Launches a DRPC daemon. This command should be run under supervision
    with a tool like daemontools or monit.

    See Distributed RPC for more information.
    (http://storm.apache.org/documentation/Distributed-RPC)
    """
    cppaths = [CLUSTER_CONF_DIR]
    jvmopts = parse_args(confvalue("drpc.childopts", cppaths)) + [
        "-Dlogfile.name=drpc.log",
        "-DLog4jContextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector",
        "-Dlog4j.configurationFile=" + os.path.join(get_log4j2_conf_dir(), "cluster.xml")
    ]
    allextrajars = get_wildcard_dir(STORM_WEBAPP_LIB_DIR)
    allextrajars.append(CLUSTER_CONF_DIR)
    exec_storm_class(
        "org.apache.storm.daemon.drpc.DRPCServer",
        jvmtype="-server",
        daemonName="drpc",
        jvmopts=jvmopts,
        extrajars=allextrajars)
Syntax: [storm drpc]

    Launches a DRPC daemon. This command should be run under supervision
    with a tool like daemontools or monit.

    See Distributed RPC for more information.
    (http://storm.apache.org/documentation/Distributed-RPC)
    
[storm drpc]
Launches a DRPC daemon. This command should be run under supervision
with a tool like daemontools or monit.

See Distributed RPC for more information.
[ storm drpc ] Launches a DRPC daemon . This command should be run under supervision with a tool like daemontools or monit . See Distributed RPC for more information .
def drpc():
    cppaths = [CLUSTER_CONF_DIR]
    jvmopts = parse_args(confvalue("drpc.childopts", cppaths)) + [
        "-Dlogfile.name=drpc.log",
        "-DLog4jContextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector",
        "-Dlog4j.configurationFile=" + os.path.join(get_log4j2_conf_dir(), "cluster.xml")
    ]
    allextrajars = get_wildcard_dir(STORM_WEBAPP_LIB_DIR)
    allextrajars.append(CLUSTER_CONF_DIR)
    exec_storm_class(
        "org.apache.storm.daemon.drpc.DRPCServer",
        jvmtype="-server",
        daemonName="drpc",
        jvmopts=jvmopts,
        extrajars=allextrajars)
def drpc ( ) : cppaths = [ CLUSTER_CONF_DIR ] jvmopts = parse_args ( confvalue ( "drpc.childopts" , cppaths ) ) + [ "-Dlogfile.name=drpc.log" , "-DLog4jContextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector" , "-Dlog4j.configurationFile=" + os . path . join ( get_log4j2_conf_dir ( ) , "cluster.xml" ) ] allextrajars = get_wildcard_dir ( STORM_WEBAPP_LIB_DIR ) allextrajars . append ( CLUSTER_CONF_DIR ) exec_storm_class ( "org.apache.storm.daemon.drpc.DRPCServer" , jvmtype = "-server" , daemonName = "drpc" , jvmopts = jvmopts , extrajars = allextrajars )
Syntax: [storm drpc]
Launches a DRPC daemon.
Syntax : [ storm drpc ] Launches a DRPC daemon .
"""Syntax: [storm drpc]

    Launches a DRPC daemon. This command should be run under supervision
    with a tool like daemontools or monit.

    See Distributed RPC for more information.
    (http://storm.apache.org/documentation/Distributed-RPC)
    """