4dkankan-center-modeling-control/src/main/java/com/fdkankan/contro/mq/nsq/NsqClient.java

package com.fdkankan.contro.mq.nsq;

import com.github.brainlag.nsq.NSQConsumer;
import com.github.brainlag.nsq.lookup.DefaultNSQLookup;
import com.github.brainlag.nsq.lookup.NSQLookup;

public class NsqClient {

    public static void main(String[] args) {
        NSQLookup lookup = new DefaultNSQLookup();
        lookup.addLookupAddress("192.168.0.127", 4161);
        NSQConsumer consumer = new NSQConsumer(lookup, "topic-bd", "channel-bd", (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();
    }

}