"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "nsqd/lookup.go" between
nsq-1.2.0.tar.gz and nsq-1.2.1.tar.gz

About: nsq is a realtime distributed and and decentralized messaging platform.

lookup.go  (nsq-1.2.0)	:	lookup.go  (nsq-1.2.1)
skipping to change at line 19		skipping to change at line 19
"time"		"time"
"github.com/nsqio/go-nsq"		"github.com/nsqio/go-nsq"
"github.com/nsqio/nsq/internal/version"		"github.com/nsqio/nsq/internal/version"
)		)
func connectCallback(n *NSQD, hostname string) func(*lookupPeer) {		func connectCallback(n *NSQD, hostname string) func(*lookupPeer) {
return func(lp *lookupPeer) {		return func(lp *lookupPeer) {
ci := make(map[string]interface{})		ci := make(map[string]interface{})
ci["version"] = version.Binary		ci["version"] = version.Binary
ci["tcp_port"] = n.RealTCPAddr().Port		ci["tcp_port"] = n.getOpts().BroadcastTCPPort
ci["http_port"] = n.RealHTTPAddr().Port		ci["http_port"] = n.getOpts().BroadcastHTTPPort
ci["hostname"] = hostname		ci["hostname"] = hostname
ci["broadcast_address"] = n.getOpts().BroadcastAddress		ci["broadcast_address"] = n.getOpts().BroadcastAddress
cmd, err := nsq.Identify(ci)		cmd, err := nsq.Identify(ci)
if err != nil {		if err != nil {
lp.Close()		lp.Close()
return		return
}		}
resp, err := lp.Command(cmd)		resp, err := lp.Command(cmd)
if err != nil {		if err != nil {
End of changes. 1 change blocks.
2 lines changed or deleted		2 lines changed or added

---