    @Test
    @Ignore
    public void connect() throws Exception {

    	ExecutorService executor = Executors.newFixedThreadPool(1);
    	when(manager.newFixedThreadPool(any(ZeromqConsumer.class), anyString(), anyInt())).thenReturn(executor);

    	// CONNECT mode by default
    	consumer.doStart();
    	Thread.sleep(50);
    	verify(socket).connect(endpoint.getSocketAddress());
    }