Andy comments

Repositories
Issues
Comments

Results 3 comments of


                                            Andy

Question about the struct 'subscription'

@MarcMagnin That's fine. I just go through the code , this may be related to the '$queue' in the cmd subscribe? @chowyu08

Question about the struct 'subscription'

@chowyu08 @MarcMagnin Now I get it that the concept somehow is like the 'group' in kafka or the 'channel' in nsq. We can use it for example to do LB....

fail to run message.requeue();

I came across the same problem when receiving messages from nsq. The java code below ` protected MsgConsumer(MsgConfig config, String topic) { NSQLookup lookup = new DefaultNSQLookup(); lookup.addLookupAddress(config.getHost(), config.getPort()); logger.info("start...