nsqAdapter

nsq-adapter

A small adapter library that makes using the awesome nsq-service easier.

It provides as thin wrapper around bitly's nsq-services to simplify usage of nsq's asynchronous message queues for midsized projects.

Basically, you define a new nsq-adapter struct and call the following methods:

• Subscribe() to subscribe to a specific topic and handle incoming messages
• Publish() to send a message to a specific topic
• Request() to send a request to a specific topic and wait for a response
• RespondTo() to send a response message to a request

Please take a look at the example and the samples in the testing directory for an idea about the usage of the package.

usage

package main

import (
	"github.com/tikiatua/nsq-adapter"
)

const (
	nsqlookupdAddress string = "192.168.99.100:4161"
)

func main() {

	// create a new nsqadapter with the name of our service
	queue := nsqAdapter.New("name-of-my-service", nsqlookupdAddress)

	// initialize the ability to handle responses.
	// this will create a topic called [name-of-service]-responses
	// that will be used to receive responses to requests issued
	// from this service
	queue.InitializeResponseHandling()

	// create a channel that will receive message from
	// a topic we would like to subscribe to
	messageChan := make(chan nsqAdapter.Message)

	// subscribe to any topic and channel
	// (note: multiple subscribers to the same channel can be used for load balancing)
	queue.Subscribe("please-do-something-with-this", "requests", messageChan)

	// handle all incoming messages of our subscription
	for {
  		// wait for incoming messages
		message := <-messageChan

		// handle the messages
		fmt.Println("RECEIVED:", message.Payload)

    	// send a response if the message is a request
		if message.MessageType == nsqAdapter.MessageTypeRequest {
			queue.RespondTo(message, "this is an answer from name-of-my-service")
		}
	}
}

You can find an example usage with a testclient, a webserver and a simple repository service in the testing directory