diff --git a/examples/stringsvc4/main.go b/examples/stringsvc4/main.go index c644707..fcc5a8a 100644 --- a/examples/stringsvc4/main.go +++ b/examples/stringsvc4/main.go @@ -13,7 +13,7 @@ natstransport "github.com/go-kit/kit/transport/nats" httptransport "github.com/go-kit/kit/transport/http" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" ) // StringService provides operations on strings. diff --git a/transport/nats/encode_decode.go b/transport/nats/encode_decode.go index ec4accf..e819a89 100644 --- a/transport/nats/encode_decode.go +++ b/transport/nats/encode_decode.go @@ -3,7 +3,7 @@ import ( "context" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" ) // DecodeRequestFunc extracts a user-domain request object from a publisher diff --git a/transport/nats/publisher.go b/transport/nats/publisher.go index 5bc75fa..9b7e829 100644 --- a/transport/nats/publisher.go +++ b/transport/nats/publisher.go @@ -4,7 +4,7 @@ "context" "encoding/json" "github.com/go-kit/kit/endpoint" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" "time" ) diff --git a/transport/nats/publisher_test.go b/transport/nats/publisher_test.go index 0272b1f..a29c764 100644 --- a/transport/nats/publisher_test.go +++ b/transport/nats/publisher_test.go @@ -7,7 +7,7 @@ "time" natstransport "github.com/go-kit/kit/transport/nats" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" ) func TestPublisher(t *testing.T) { diff --git a/transport/nats/request_response_funcs.go b/transport/nats/request_response_funcs.go index 32cec57..8222564 100644 --- a/transport/nats/request_response_funcs.go +++ b/transport/nats/request_response_funcs.go @@ -3,7 +3,7 @@ import ( "context" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" ) // RequestFunc may take information from a publisher request and put it into a diff --git a/transport/nats/subscriber.go b/transport/nats/subscriber.go index 0cc542f..33f4a15 100644 --- a/transport/nats/subscriber.go +++ b/transport/nats/subscriber.go @@ -8,7 +8,7 @@ "github.com/go-kit/kit/log" "github.com/go-kit/kit/transport" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats.go" ) // Subscriber wraps an endpoint and provides nats.MsgHandler. diff --git a/transport/nats/subscriber_test.go b/transport/nats/subscriber_test.go index b235443..09ce8b6 100644 --- a/transport/nats/subscriber_test.go +++ b/transport/nats/subscriber_test.go @@ -9,8 +9,8 @@ "testing" "time" - "github.com/nats-io/gnatsd/server" - "github.com/nats-io/go-nats" + "github.com/nats-io/nats-server/server" + "github.com/nats-io/nats.go" "github.com/go-kit/kit/endpoint" natstransport "github.com/go-kit/kit/transport/nats"