Publish #
Sends a real-time <message> to Kuzzle. The <message> will be dispatched to all clients with subscriptions matching the <index>, the <collection> and the <message> content.
The <index> and <collection> are indicative and serve only to distinguish the rooms. They are not required to exist in the database
Note: real-time messages are not persisted in the database.
Arguments #
func (r *Realtime) Publish(
index string,
collection string,
message json.RawMessage,
options types.QueryOptions
) error| Arguments | Type | Description |
|---|---|---|
index | string | Index name |
collection | string | Collection name |
message | json.RawMessage | Message to send |
options | types.QueryOptions | Query options |
options #
Additional query options
| Option | Type (default) | Description |
|---|---|---|
queuable | bool ( true) | Make this request queuable or not |
Return #
Return an error is something was wrong.
Usage #
message := json.RawMessage(`{ "realtime": "rule the web" }`)
err := kuzzle.Realtime.Publish("i-dont-exist", "i-database", message, nil)
if err != nil {
log.Fatal(err)
} else {
fmt.Println("Success")
}