Method DRPC

storm-server/src/main/java/org/apache/storm/daemon/drpc/DRPC.java:79–82

(StormMetricsRegistry metricsRegistry, Map<String, Object> conf)

    private final IAuthorizer auth;

    public DRPC(StormMetricsRegistry metricsRegistry, Map<String, Object> conf) {
        this(metricsRegistry, mkAuthorizationHandler((String) conf.get(DaemonConfig.DRPC_AUTHORIZER), conf),
             ObjectReader.getInt(conf.get(DaemonConfig.DRPC_REQUEST_TIMEOUT_SECS), 600) * 1000);
    }

    public DRPC(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs) {
        this.auth = auth;