unistack-org/micro-broker-stan
4
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 5 Wiki Activity

use new NATS streaming client repo path

Browse Source
This commit is contained in:
fztcjjl 2019-05-30 11:45:20 +08:00 committed by Vasiliy Tolstov
parent 54a1eae3e2
commit 1291ceb68c
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
options.go
View File

@ -6,7 +6,7 @@ import (
"github.com/micro/go-micro/broker" "github.com/micro/go-micro/broker"
"github.com/micro/go-micro/server" "github.com/micro/go-micro/server"
stan "github.com/nats-io/go-nats-streaming" stan "github.com/nats-io/stan.go"
) )
type optionsKey struct{} type optionsKey struct{}

4
stan.go
View File

@ -14,7 +14,7 @@ import (
"github.com/micro/go-micro/broker" "github.com/micro/go-micro/broker"
"github.com/micro/go-micro/cmd" "github.com/micro/go-micro/cmd"
"github.com/micro/go-micro/codec/json" "github.com/micro/go-micro/codec/json"
stan "github.com/nats-io/go-nats-streaming" stan "github.com/nats-io/stan.go"
) )
type stanBroker struct { type stanBroker struct {
@ -221,7 +221,7 @@ func (n *stanBroker) Connect() error {
stan.ConnectWait(n.sopts.ConnectTimeout), stan.ConnectWait(n.sopts.ConnectTimeout),
stan.PubAckWait(n.sopts.AckTimeout), stan.PubAckWait(n.sopts.AckTimeout),
stan.MaxPubAcksInflight(n.sopts.MaxPubAcksInflight), stan.MaxPubAcksInflight(n.sopts.MaxPubAcksInflight),
stan.Pings(n.sopts.PingIterval, n.sopts.PingMaxOut), stan.Pings(n.sopts.PingInterval, n.sopts.PingMaxOut),
stan.SetConnectionLostHandler(n.sopts.ConnectionLostCB), stan.SetConnectionLostHandler(n.sopts.ConnectionLostCB),
} }
nopts = append(nopts, stan.NatsURL(strings.Join(n.addrs, ","))) nopts = append(nopts, stan.NatsURL(strings.Join(n.addrs, ",")))

2
stan_test.go
View File

@ -6,7 +6,7 @@ import (
"testing" "testing"
"github.com/micro/go-micro/broker" "github.com/micro/go-micro/broker"
stan "github.com/nats-io/go-nats-streaming" stan "github.com/nats-io/stan.go"
) )
var addrTestCases = []struct { var addrTestCases = []struct {