Skip to content

Instantly share code, notes, and snippets.

View eestolano's full-sized avatar

Esteban Molina-Estolano eestolano

View GitHub Profile

Keybase proof

I hereby claim:

  • I am eestolano on github.
  • I am eestolano (https://keybase.io/eestolano) on keybase.
  • I have a public key ASDjrQTaIBl8U5v_aWtma70GRDWghSAh_T99NnLcqCOQugo

To claim this, I am signing this object:

@eestolano
eestolano / MinimalExample.java
Created April 16, 2012 18:35
InterruptedException when closing DistributedQueue
import java.util.concurrent.TimeUnit;
import com.netflix.curator.framework.*;
import com.netflix.curator.framework.recipes.queue.QueueBuilder;
import com.netflix.curator.framework.recipes.queue.DistributedQueue;
import com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer;
import com.netflix.curator.framework.recipes.queue.QueueSerializer;
import com.netflix.curator.framework.state.ConnectionState;
import com.netflix.curator.framework.state.ConnectionStateListener;
import com.netflix.curator.retry.RetryNTimes;
@eestolano
eestolano / MinimalExample.java
Created April 16, 2012 18:33
InterruptedException when closing DistributedQueue
import java.util.concurrent.TimeUnit;
import com.netflix.curator.framework.*;
import com.netflix.curator.framework.recipes.queue.QueueBuilder;
import com.netflix.curator.framework.recipes.queue.DistributedQueue;
import com.netflix.curator.framework.recipes.queue .BlockingQueueConsumer;
import com.netflix.curator.framework.recipes.queue.QueueSerializer;
import com.netflix.curator.framework.state.ConnectionState;
import com.netflix.curator.framework.state.ConnectionStateListener;
import com.netflix.curator.retry.RetryNTimes;