JavaNSQClient

JavaNSQClient copied to clipboard

I try to set the timeout of NSQConsumer but this throw a Cast Exception ``` NSQConfig config= new NSQConfig(); config.setMsgTimeout(Util.NSQ_MSG_TIMEOUT); NSQConsumer consumer = new NSQConsumer(lookup, topic, NsqChannelConst.REPORTS_CHANNEL, (message) -> {...

josueLy

java.lang.IllegalStateException: Queue full

7

``` java.lang.IllegalStateException: Queue full at java.util.AbstractQueue.add(AbstractQueue.java:98) at com.github.brainlag.nsq.Connection.incoming(Connection.java:115) at com.github.brainlag.nsq.netty.NSQHandler.lambda$channelRead0$3(NSQHandler.java:41) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:358) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112) at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) at java.lang.Thread.run(Thread.java:748) ``` Went through the code and found the following line...

rohithbv1991

fail to run message.requeue();

2

nsq version：1.0 os：centos 7.4 codes: public static void main( String[] args ) { NSQLookup lookup = new DefaultNSQLookup(); lookup.addLookupAddress("192.168.1.228", 4161); NSQConsumer consumer = new NSQConsumer(lookup, "TestTopic", "dusti", (message) -> {...

gzliudan


ningkexin

Failed resolution of: Ljava/util/Optional;

1

I use android studio run this test . java.lang.NoClassDefFoundError: Failed resolution of: Ljava/util/Optional;

weiandebeiying

hama2510

Hi, I am wondering how to connect to nsqd without lookup. The consumer samples online always use nsqdlookup firstly then connect and I've failed to find a way to set...

ozszsh

Could not create connection to server xxxxxxx - NSQConsumer.createConnection

1

Producer works fine, but consumer can not start . Stacktrace may like this: com.github.brainlag.nsq.exceptions.NoConnectionsException: Could not connect to server at com.github.brainlag.nsq.Connection.(Connection.java:62) ~[nsq-client-1.0.0.RC4.jar:?] at com.github.brainlag.nsq.NSQConsumer.createConnection(NSQConsumer.java:80) ~[nsq-client-1.0.0.RC4.jar:?] at com.github.brainlag.nsq.NSQConsumer.connect(NSQConsumer.java:210) ~[nsq-client-1.0.0.RC4.jar:?] at com.github.brainlag.nsq.NSQConsumer.lambda$start$0(NSQConsumer.java:73)...

Bwjh

java-nsq-client: update netty to 4.1.19.Final

1

Netty dependency is now updated to 4.1.19.Final as it's used as peer dependencies that are commonly used with the nsq client. Fixes #41

mgenov

Upgrading netty to 4.1.x

1

There are breaking changes between 4.1 and 4.0 Most of the project start to use 4.1 and this creates classpath errors. It'll be good upgrading netty to 4.1.x

aldemirenes