Add an example

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

README.md

@@ -10,4 +10,10 @@ This library is in early stages of development. It is meant to be used with Rabb
 
 ## Getting Started
 
-You can find an example in: `examples/getting_started`
+You can find an example in: `docs/examples/getting_started`
+
+## Examples
+
+You can find more examples in: `docs/examples`
+
+

examples/getting_started/main.go renamed to docs/examples/getting_started/main.go

@@ -85,16 +85,16 @@ func main() {
 			deliveryContext, err := consumer.Receive(ctx)
 			if errors.Is(err, context.Canceled) {
 				// The consumer was closed correctly
-				rabbitmq_amqp.Info("[NewConsumer]", "consumer closed. Context", err)
+				rabbitmq_amqp.Info("[Consumer]", "consumer closed. Context", err)
 				return
 			}
 			if err != nil {
 				// An error occurred receiving the message
-				rabbitmq_amqp.Error("[NewConsumer]", "Error receiving message", err)
+				rabbitmq_amqp.Error("[Consumer]", "Error receiving message", err)
 				return
 			}
 
-			rabbitmq_amqp.Info("[NewConsumer]", "Received message",
+			rabbitmq_amqp.Info("[Consumer]", "Received message",
 				fmt.Sprintf("%s", deliveryContext.Message().Data))
 
 			err = deliveryContext.Accept(context.Background())
@@ -122,16 +122,16 @@ func main() {
 		}
 		switch publishResult.Outcome.(type) {
 		case *amqp.StateAccepted:
-			rabbitmq_amqp.Info("[NewTargetPublisher]", "Message accepted", publishResult.Message.Data[0])
+			rabbitmq_amqp.Info("[Publisher]", "Message accepted", publishResult.Message.Data[0])
 			break
 		case *amqp.StateReleased:
-			rabbitmq_amqp.Warn("[NewTargetPublisher]", "Message was not routed", publishResult.Message.Data[0])
+			rabbitmq_amqp.Warn("[Publisher]", "Message was not routed", publishResult.Message.Data[0])
 			break
 		case *amqp.StateRejected:
-			rabbitmq_amqp.Warn("[NewTargetPublisher]", "Message rejected", publishResult.Message.Data[0])
+			rabbitmq_amqp.Warn("[Publisher]", "Message rejected", publishResult.Message.Data[0])
 			stateType := publishResult.Outcome.(*amqp.StateRejected)
 			if stateType.Error != nil {
-				rabbitmq_amqp.Warn("[NewTargetPublisher]", "Message rejected with error: %v", stateType.Error)
+				rabbitmq_amqp.Warn("[Publisher]", "Message rejected with error: %v", stateType.Error)
 			}
 			break
 		default:
@@ -150,11 +150,13 @@ func main() {
 	//Close the consumer
 	err = consumer.Close(context.Background())
 	if err != nil {
-		rabbitmq_amqp.Error("[NewConsumer]", err)
+		rabbitmq_amqp.Error("[Consumer]", err)
+		return
 	}
 	// Close the publisher
 	err = publisher.Close(context.Background())
 	if err != nil {
+		rabbitmq_amqp.Error("[Publisher]", err)
 		return
 	}
 

docs/examples/multi_targets_publisher/main.go

@@ -0,0 +1,95 @@
+package main
+
+import (
+	"context"
+	"github.com/Azure/go-amqp"
+	"github.com/rabbitmq/rabbitmq-amqp-go-client/rabbitmq_amqp"
+)
+
+func validateOutcome(outcome amqp.DeliveryState) {
+
+	switch outcome.(type) {
+	case *amqp.StateAccepted:
+		rabbitmq_amqp.Info("Message accepted")
+	default:
+		rabbitmq_amqp.Info("Message not accepted")
+		panic("Message not accepted")
+	}
+
+}
+
+func main() {
+
+	rabbitmq_amqp.Info("Multi Target Publisher with AMQP Go AMQP 1.0 Client")
+	queueName1 := "multi-target-queue-1"
+	queueName2 := "multi-target-queue-2"
+
+	connection, err := rabbitmq_amqp.Dial(context.Background(), []string{"amqp://"}, nil)
+	if err != nil {
+		return
+	}
+
+	_, err = connection.Management().DeclareQueue(context.Background(), &rabbitmq_amqp.QueueSpecification{
+		Name:      queueName1,
+		QueueType: rabbitmq_amqp.QueueType{Type: rabbitmq_amqp.Quorum},
+	})
+	if err != nil {
+		return
+	}
+
+	_, err = connection.Management().DeclareQueue(context.Background(), &rabbitmq_amqp.QueueSpecification{
+		Name:      queueName2,
+		QueueType: rabbitmq_amqp.QueueType{Type: rabbitmq_amqp.Classic},
+	})
+
+	if err != nil {
+		return
+	}
+
+	// Create a publisher that can publish to multiple targets
+	mtPublisher, err := connection.NewMultiTargetsPublisher(context.Background(), "test")
+	if err != nil {
+		return
+	}
+	t1, _ := rabbitmq_amqp.QueueAddress(&queueName1)
+	t2, _ := rabbitmq_amqp.QueueAddress(&queueName2)
+
+	publishResult, err := mtPublisher.Publish(context.Background(), amqp.NewMessage([]byte("hello")), t1)
+	if err != nil {
+		return
+	}
+
+	validateOutcome(publishResult.Outcome)
+
+	publishResult, err = mtPublisher.Publish(context.Background(), amqp.NewMessage([]byte("hello")), t2)
+	if err != nil {
+		return
+	}
+
+	validateOutcome(publishResult.Outcome)
+
+	// Close the publisher
+	err = mtPublisher.Close(context.Background())
+	if err != nil {
+		return
+	}
+
+	// Delete the queues
+	err = connection.Management().DeleteQueue(context.Background(), queueName1)
+	if err != nil {
+		return
+	}
+
+	err = connection.Management().DeleteQueue(context.Background(), queueName2)
+	if err != nil {
+		return
+	}
+
+	// Close the connection
+
+	err = connection.Close(context.Background())
+	if err != nil {
+		return
+	}
+
+}