@Test public void expiredMessages() throws InterruptedException { Consumer c = new SlowConsumer(new Jedis("localhost"), "a consumer", "foo", 2000L); Producer p = new Producer(new Jedis("localhost"), "foo"); p.publish("un mensaje", 1); assertNull(c.consume()); }
public void publish(final String message) { publish(message, 0); }
Producer { public void publish(final String message) { publish(message, 0); } }
Producer { public void publish(final String message) { publish(message, 0); } Producer(final Jedis jedis, final String topic); }
Producer { public void publish(final String message) { publish(message, 0); } Producer(final Jedis jedis, final String topic); void publish(final String message); void clean(); void publish(String message, int seconds); }
Producer { public void publish(final String message) { publish(message, 0); } Producer(final Jedis jedis, final String topic); void publish(final String message); void clean(); void publish(String message, int seconds);  }