Hello world for Golang stream client (#383)

Author: Gsantomaggio

go-stream/README.md

@@ -0,0 +1,24 @@
+# Go code for RabbitMQ tutorials
+
+
+Here you can find Go code examples from [RabbitMQ tutorials](https://www.rabbitmq.com/getstarted.html).
+
+
+## Requirements
+
+These examples use the [`rabbitmq/rabbitmq-stream-go-client`](https://github.com/rabbitmq/rabbitmq-stream-go-client) client library.
+Get it first with
+
+     go get -u github.com/rabbitmq/rabbitmq-stream-go-client
+
+## Code
+
+Code examples are executed via `go run`:
+
+[Tutorial one: "Hello World!"](https://www.rabbitmq.com/tutorials/tutorial-one-go-stream.html):
+
+    go run send.go
+    go run receive.go
+
+
+To learn more, see [`rabbitmq/rabbitmq-stream-go-client`](https://github.com/rabbitmq/rabbitmq-stream-go-client).

go-stream/go.mod

@@ -0,0 +1,13 @@
+module github.com/rabbitmq/rabbitmq-tutorials
+
+go 1.22.0
+
+require github.com/rabbitmq/rabbitmq-stream-go-client v1.4.1
+
+require (
+	github.com/golang/snappy v0.0.4 // indirect
+	github.com/klauspost/compress v1.17.8 // indirect
+	github.com/pierrec/lz4 v2.6.1+incompatible // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/spaolacci/murmur3 v1.1.0 // indirect
+)

go-stream/go.sum

@@ -0,0 +1,12 @@
+github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
+github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/klauspost/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU=
+github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
+github.com/pierrec/lz4 v2.6.1+incompatible h1:9UY3+iC23yxF0UfGaYrGplQ+79Rg+h/q9FV9ix19jjM=
+github.com/pierrec/lz4 v2.6.1+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
+github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/rabbitmq/rabbitmq-stream-go-client v1.4.1 h1:QWHiXPio2rhQU98TKFhyooGWH2Xviwwz9RFGdIpIlUg=
+github.com/rabbitmq/rabbitmq-stream-go-client v1.4.1/go.mod h1:CbFPhxC2+ctPq0FmWD3CiZWWGiP7sP4joRpw4YTlyL4=
+github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=
+github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=

go-stream/receive.go

@@ -0,0 +1,50 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"github.com/rabbitmq/rabbitmq-stream-go-client/pkg/amqp"
+	"github.com/rabbitmq/rabbitmq-stream-go-client/pkg/stream"
+	"os"
+)
+
+func CheckErrReceive(err error) {
+	if err != nil {
+		fmt.Printf("%s ", err)
+		os.Exit(1)
+	}
+}
+func main() {
+
+	env, err := stream.NewEnvironment(
+		stream.NewEnvironmentOptions().
+			SetHost("localhost").
+			SetPort(5552).
+			SetUser("guest").
+			SetPassword("guest"))
+	CheckErrReceive(err)
+
+	streamName := "hello-go-stream"
+	err = env.DeclareStream(streamName,
+		&stream.StreamOptions{
+			MaxLengthBytes: stream.ByteCapacity{}.GB(2),
+		},
+	)
+	CheckErrReceive(err)
+
+	messagesHandler := func(consumerContext stream.ConsumerContext, message *amqp.Message) {
+		fmt.Printf("Stream: %s - Received message: %s\n", consumerContext.Consumer.GetStreamName(),
+			message.Data)
+	}
+
+	consumer, err := env.NewConsumer(streamName, messagesHandler,
+		stream.NewConsumerOptions().SetOffset(stream.OffsetSpecification{}.First()))
+	CheckErrReceive(err)
+
+	reader := bufio.NewReader(os.Stdin)
+	fmt.Println(" [x] Waiting for messages. enter to close the consumer")
+	_, _ = reader.ReadString('\n')
+	err = consumer.Close()
+	CheckErrReceive(err)
+
+}

go-stream/send.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"github.com/rabbitmq/rabbitmq-stream-go-client/pkg/amqp"
+	"github.com/rabbitmq/rabbitmq-stream-go-client/pkg/stream"
+	"os"
+)
+
+func CheckErrSend(err error) {
+	if err != nil {
+		fmt.Printf("%s ", err)
+		os.Exit(1)
+	}
+}
+func main() {
+	env, err := stream.NewEnvironment(
+		stream.NewEnvironmentOptions().
+			SetHost("localhost").
+			SetPort(5552).
+			SetUser("guest").
+			SetPassword("guest"))
+	CheckErrSend(err)
+
+	streamName := "hello-go-stream"
+	err = env.DeclareStream(streamName,
+		&stream.StreamOptions{
+			MaxLengthBytes: stream.ByteCapacity{}.GB(2),
+		},
+	)
+	CheckErrSend(err)
+
+	producer, err := env.NewProducer(streamName, stream.NewProducerOptions())
+	CheckErrSend(err)
+
+	// Send a message
+	err = producer.Send(amqp.NewMessage([]byte("Hello world")))
+	CheckErrSend(err)
+	fmt.Printf(" [x] 'Hello world' Message sent\n")
+
+	reader := bufio.NewReader(os.Stdin)
+	fmt.Println(" [x] Press enter to close the producer")
+	_, _ = reader.ReadString('\n')
+	err = producer.Close()
+	CheckErrSend(err)
+}