DuccLogger logger = DuccLogger.getLogger(this.getClass(), COMPONENT_NAME);

       

        public ResourceManagerEventListener resourceManagerDelegateListener(ResourceManagerComponent rm) {

            int nodeStability = SystemPropertyResolver.getIntProperty("ducc.rm.node.stability", DEFAULT_STABILITY_COUNT);

            int agentMetricsRate = SystemPropertyResolver.getIntProperty("ducc.agent.node.metrics.publish.rate", DEFAULT_NODE_METRICS_RATE);

            NodeStability ns = new NodeStability(rm, nodeStability, agentMetricsRate);           

            rm.setNodeStability(ns);

            ns.start();

            return jmel;

        }

                                             common.rmStateUpdateEndpoint);

       

                //  Instantiate Resource Manager delegate listener. This listener will receive

                //  incoming messages.

                //  Inject a dispatcher into the listener in case it needs to send

                //  a message to another component.

                //  Inject Camel Router that will generate state updates at regular intervals

                // jrc rm.getContext().addRoutes(this.routeBuilderForRMStateUpdate(rm, common.rmStateUpdateEndpoint, Integer.parseInt(common.rmStatePublishRate)));

                //  Inject Camel Router that will handle Job Manager state update messages