diff --git a/clients/go/notes/notes.go b/clients/go/notes/notes.go
index ad99361..4cdb080 100755
--- a/clients/go/notes/notes.go
+++ b/clients/go/notes/notes.go
@@ -28,6 +28,12 @@ func (t *NotesService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
 	return rsp, t.client.Call("notes", "Delete", request, rsp)
 }
 
+// Specify the note to events
+func (t *NotesService) Events(request *EventsRequest) (*EventsResponse, error) {
+	rsp := &EventsResponse{}
+	return rsp, t.client.Call("notes", "Events", request, rsp)
+}
+
 // List all the notes
 func (t *NotesService) List(request *ListRequest) (*ListResponse, error) {
 	rsp := &ListResponse{}
@@ -40,12 +46,6 @@ func (t *NotesService) Read(request *ReadRequest) (*ReadResponse, error) {
 	return rsp, t.client.Call("notes", "Read", request, rsp)
 }
 
-// Specify the note to events
-func (t *NotesService) Subscribe(request *SubscribeRequest) (*SubscribeResponse, error) {
-	rsp := &SubscribeResponse{}
-	return rsp, t.client.Call("notes", "Subscribe", request, rsp)
-}
-
 // Update a note
 func (t *NotesService) Update(request *UpdateRequest) (*UpdateResponse, error) {
 	rsp := &UpdateResponse{}
@@ -73,6 +73,18 @@ type DeleteResponse struct {
 	Note *Note `json:"note"`
 }
 
+type EventsRequest struct {
+	// optionally specify a note id
+	Id string `json:"id"`
+}
+
+type EventsResponse struct {
+	// the event which occured; create, delete, update
+	Event string `json:"event"`
+	// the note which the operation occured on
+	Note *Note `json:"note"`
+}
+
 type ListRequest struct {
 }
 
@@ -104,18 +116,6 @@ type ReadResponse struct {
 	Note *Note `json:"note"`
 }
 
-type SubscribeRequest struct {
-	// optionally specify a note id
-	Id string `json:"id"`
-}
-
-type SubscribeResponse struct {
-	// the event which occured; create, delete, update
-	Event string `json:"event"`
-	// the note which the operation occured on
-	Note *Note `json:"note"`
-}
-
 type UpdateRequest struct {
 	Note *Note `json:"note"`
 }
diff --git a/clients/ts/package.json b/clients/ts/package.json
index 3a39462..19600ef 100644
--- a/clients/ts/package.json
+++ b/clients/ts/package.json
@@ -76,5 +76,5 @@
   "prepare": "npm run build"
  },
  "types": "index.d.ts",
- "version": "1.0.594"
+ "version": "1.0.597"
 }
\ No newline at end of file
diff --git a/examples/notes/events/curl/subscribeToEvents.sh b/examples/notes/events/curl/subscribeToEvents.sh
new file mode 100755
index 0000000..bbdd17e
--- /dev/null
+++ b/examples/notes/events/curl/subscribeToEvents.sh
@@ -0,0 +1,6 @@
+curl "https://api.m3o.com/v1/notes/Events" \
+-H "Content-Type: application/json" \
+-H "Authorization: Bearer $MICRO_API_TOKEN" \
+-d '{
+  "id": "63c0cdf8-2121-11ec-a881-0242e36f037a"
+}'
\ No newline at end of file
diff --git a/examples/notes/events/go/subscribeToEvents.go b/examples/notes/events/go/subscribeToEvents.go
new file mode 100755
index 0000000..66782a4
--- /dev/null
+++ b/examples/notes/events/go/subscribeToEvents.go
@@ -0,0 +1,17 @@
+package example
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/micro/services/clients/go/notes"
+)
+
+// Specify the note to events
+func SubscribeToEvents() {
+	notesService := notes.NewNotesService(os.Getenv("MICRO_API_TOKEN"))
+	rsp, err := notesService.Events(&notes.EventsRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	fmt.Println(rsp, err)
+}
diff --git a/examples/notes/events/node/subscribeToEvents.js b/examples/notes/events/node/subscribeToEvents.js
new file mode 100755
index 0000000..62ec86b
--- /dev/null
+++ b/examples/notes/events/node/subscribeToEvents.js
@@ -0,0 +1,12 @@
+const { NotesService } = require("m3o/notes");
+
+// Specify the note to events
+async function subscribeToEvents() {
+  let notesService = new NotesService(process.env.MICRO_API_TOKEN);
+  let rsp = await notesService.events({
+    id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+  });
+  console.log(rsp);
+}
+
+subscribeToEvents();
diff --git a/examples/stream/publish/go/publishAMessage.go b/examples/stream/publish/go/publishAMessage.go
index 7a0d501..eee4024 100755
--- a/examples/stream/publish/go/publishAMessage.go
+++ b/examples/stream/publish/go/publishAMessage.go
@@ -12,9 +12,9 @@ func PublishAmessage() {
 	streamService := stream.NewStreamService(os.Getenv("MICRO_API_TOKEN"))
 	rsp, err := streamService.Publish(&stream.PublishRequest{
 		Message: map[string]interface{}{
-			"user": "john",
 			"id":   "1",
 			"type": "signup",
+			"user": "john",
 		},
 		Topic: "events",
 	})