A (fast?) netty-based Java8 client for NSQ heavily forked of TrendrrNSQClient.
<dependency> <groupId>com.github.brainlag</groupId> <artifactId>nsq-client</artifactId> <version>1.0.0.RC2</version> </dependency> Example usage:
NSQLookup lookup = new DefaultNSQLookup(); lookup.addLookupAddress("localhost", 4161); NSQConsumer consumer = new NSQConsumer(lookup, "speedtest", "dustin", (message) -> { System.out.println("received: " + message); //now mark the message as finished. message.finished(); //or you could requeue it, which indicates a failure and puts it back on the queue. //message.requeue(); }); consumer.start(); Example usage:
NSQProducer producer = new NSQProducer().addAddress("localhost", 4150).start(); producer.produce("TestTopic", ("this is a message").getBytes()); By default Backoff does not kick in and a consumer will eat all your memory and CPU. To enable Backoff you have to set your own thread pool executer with:
consumer.setExecutor(...);