Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package backtype.storm.contrib.signals;
 
 import  org.slf4j.Logger;
 import  org.slf4j.LoggerFactory;
 
 import  com.netflix.curator.framework.CuratorFrameworkFactory;
 import  com.netflix.curator.retry.RetryNTimes;
 
    private static final Logger LOG = LoggerFactory.getLogger(StandaloneSignalConnection.class);
    private String connectString;
    private int zkRetries = 5;
    private int zkRetryInterval = 1000;
    public StandaloneSignalConnection(String nameSignalListener listenerString connectString) {
        this. = name;
        this. = listener;
        this. = connectString;
    }
    public void init() throws Exception {
        this. = CuratorFrameworkFactory.builder().namespace().connectString()
                .retryPolicy(new RetryNTimes(this.this.)).build();
        this..start();
        super.initWatcher();
    }
New to GrepCode? Check out our FAQ X