From 4a5993b5f7039d40f678871f00d5cdbb164b00c8 Mon Sep 17 00:00:00 2001 From: Ivan Kozlovic Date: Mon, 21 Nov 2016 09:16:00 -0700 Subject: [PATCH] Update imports due to rename of repo nats to go-nats --- examples/stan-bench.go | 5 ++--- stan.go | 2 +- stan_test.go | 9 ++++----- sub.go | 2 +- 4 files changed, 8 insertions(+), 10 deletions(-) diff --git a/examples/stan-bench.go b/examples/stan-bench.go index 30bdc66..e6bd4c6 100644 --- a/examples/stan-bench.go +++ b/examples/stan-bench.go @@ -11,10 +11,9 @@ import ( "sync" "time" + "github.com/nats-io/go-nats" "github.com/nats-io/go-nats-streaming" - "github.com/nats-io/nats" - "github.com/nats-io/nats/bench" - + "github.com/nats-io/go-nats/bench" ) // Some sane defaults diff --git a/stan.go b/stan.go index 780488e..6151287 100644 --- a/stan.go +++ b/stan.go @@ -10,8 +10,8 @@ import ( "sync" "time" + "github.com/nats-io/go-nats" "github.com/nats-io/go-nats-streaming/pb" - "github.com/nats-io/nats" "github.com/nats-io/nuid" ) diff --git a/stan_test.go b/stan_test.go index 1c5144a..9a0d632 100644 --- a/stan_test.go +++ b/stan_test.go @@ -18,13 +18,12 @@ import ( "testing" "time" + natsd "github.com/nats-io/gnatsd/test" + "github.com/nats-io/go-nats" "github.com/nats-io/go-nats-streaming/pb" - "github.com/nats-io/nats" + natstest "github.com/nats-io/go-nats/test" "github.com/nats-io/nats-streaming-server/server" "github.com/nats-io/nats-streaming-server/test" - natstest "github.com/nats-io/nats/test" - - natsd "github.com/nats-io/gnatsd/test" ) func RunServer(ID string) *server.StanServer { @@ -1245,7 +1244,7 @@ func TestDurableSubscriber(t *testing.T) { if nr := atomic.AddInt32(&received, 1); nr == 10 { // Reduce risk of test failure by allowing server to // process acks before processing Close() requesting - time.Sleep(500 * time.Millisecond) + time.Sleep(time.Second) sc.Close() ch <- true } else { diff --git a/sub.go b/sub.go index 6617b62..dcb9ce2 100644 --- a/sub.go +++ b/sub.go @@ -8,8 +8,8 @@ import ( "sync" "time" + "github.com/nats-io/go-nats" "github.com/nats-io/go-nats-streaming/pb" - "github.com/nats-io/nats" ) const (