From 784e1a71d38280cdd20be7bc795faf7a1281f0da Mon Sep 17 00:00:00 2001 From: asim Date: Wed, 3 Nov 2021 15:48:48 +0000 Subject: [PATCH] Commit from GitHub Actions (Generate Clients & Examples) --- clients/go/stream/stream.go | 2 +- clients/ts/package.json | 2 +- examples/event/publish/go/publishAnEvent.go | 2 +- examples/mq/publish/go/publishAMessage.go | 2 +- examples/stream/sendMessage/go/sendMessage.go | 2 +- examples/stream/sendMessage/node/sendMessage.js | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/clients/go/stream/stream.go b/clients/go/stream/stream.go index 16decf5..3fc1253 100755 --- a/clients/go/stream/stream.go +++ b/clients/go/stream/stream.go @@ -28,7 +28,7 @@ func (t *StreamService) ListMessages(request *ListMessagesRequest) (*ListMessage return rsp, t.client.Call("stream", "ListMessages", request, rsp) } -// SendMessage a message to the stream. +// Send a message to the stream. func (t *StreamService) SendMessage(request *SendMessageRequest) (*SendMessageResponse, error) { rsp := &SendMessageResponse{} return rsp, t.client.Call("stream", "SendMessage", request, rsp) diff --git a/clients/ts/package.json b/clients/ts/package.json index fbd1c40..566ac13 100644 --- a/clients/ts/package.json +++ b/clients/ts/package.json @@ -78,5 +78,5 @@ "prepare": "npm run build" }, "types": "index.d.ts", - "version": "1.0.619" + "version": "1.0.620" } \ No newline at end of file diff --git a/examples/event/publish/go/publishAnEvent.go b/examples/event/publish/go/publishAnEvent.go index cd945dc..a6a3b0e 100755 --- a/examples/event/publish/go/publishAnEvent.go +++ b/examples/event/publish/go/publishAnEvent.go @@ -12,9 +12,9 @@ func PublishAnEvent() { eventService := event.NewEventService(os.Getenv("MICRO_API_TOKEN")) rsp, err := eventService.Publish(&event.PublishRequest{ Message: map[string]interface{}{ - "id": "1", "type": "signup", "user": "john", + "id": "1", }, Topic: "user", }) diff --git a/examples/mq/publish/go/publishAMessage.go b/examples/mq/publish/go/publishAMessage.go index 6cbfe0d..e3cfd27 100755 --- a/examples/mq/publish/go/publishAMessage.go +++ b/examples/mq/publish/go/publishAMessage.go @@ -12,9 +12,9 @@ func PublishAmessage() { mqService := mq.NewMqService(os.Getenv("MICRO_API_TOKEN")) rsp, err := mqService.Publish(&mq.PublishRequest{ Message: map[string]interface{}{ - "type": "signup", "user": "john", "id": "1", + "type": "signup", }, Topic: "events", }) diff --git a/examples/stream/sendMessage/go/sendMessage.go b/examples/stream/sendMessage/go/sendMessage.go index d11e011..4ec3e5b 100755 --- a/examples/stream/sendMessage/go/sendMessage.go +++ b/examples/stream/sendMessage/go/sendMessage.go @@ -7,7 +7,7 @@ import ( "github.com/micro/services/clients/go/stream" ) -// SendMessage a message to the stream. +// Send a message to the stream. func SendMessage() { streamService := stream.NewStreamService(os.Getenv("MICRO_API_TOKEN")) rsp, err := streamService.SendMessage(&stream.SendMessageRequest{ diff --git a/examples/stream/sendMessage/node/sendMessage.js b/examples/stream/sendMessage/node/sendMessage.js index bf191eb..1f2e95b 100755 --- a/examples/stream/sendMessage/node/sendMessage.js +++ b/examples/stream/sendMessage/node/sendMessage.js @@ -1,6 +1,6 @@ const { StreamService } = require("m3o/stream"); -// SendMessage a message to the stream. +// Send a message to the stream. async function sendMessage() { let streamService = new StreamService(process.env.MICRO_API_TOKEN); let rsp = await streamService.sendMessage({