🔇 silent changes: added example functions for testing #11

example/rmqconn_cluster_test.go

@@ -0,0 +1,50 @@
+package example
+
+import (
+	"testing"
+
+	"github.com/sivaosorg/govm/logger"
+	"github.com/sivaosorg/govm/rabbitmqx"
+	"github.com/sivaosorg/rmqconn"
+)
+
+func TestServiceDeclareExchange(t *testing.T) {
+	r, _ := createConn()
+	r.Config.Message.SetEnabled(true)
+	message := rabbitmqx.GetRabbitMqMessageConfigSample()
+	logger.Infof("message conf requesting: %v", message)
+	svc := rmqconn.NewRmqClusterService(r)
+	err := svc.DeclareExchange(*message)
+	if err != nil {
+		logger.Errorf("Declaring exchange conf got an error", err)
+		return
+	}
+	logger.Infof("Declared exchange conf successfully")
+}
+
+func TestServiceProduceMessage(t *testing.T) {
+	r, _ := createConn()
+	r.Config.Message.SetEnabled(true)
+	message := rabbitmqx.GetRabbitMqMessageConfigSample()
+	logger.Infof("message conf requesting: %v", message)
+	svc := rmqconn.NewRmqClusterService(r)
+	err := svc.Produce(*message, "Hello 1 RabbitMQ!")
+	if err != nil {
+		logger.Errorf("Producing message got an error", err)
+		return
+	}
+	logger.Infof("Produced message successfully")
+}
+
+func TestServiceConsumeMessage(t *testing.T) {
+	r, _ := createConn()
+	r.Config.Message.SetEnabled(true)
+	message := rabbitmqx.GetRabbitMqMessageConfigSample()
+	logger.Infof("message conf requesting: %v", message)
+	svc := rmqconn.NewRmqClusterService(r)
+	err := svc.Consume(*message, nil)
+	if err != nil {
+		logger.Errorf("Consuming message got an error", err)
+		return
+	}
+}

example/rmqconn_common_test.go

@@ -0,0 +1,19 @@
+package example
+
+import (
+	"testing"
+
+	"github.com/sivaosorg/govm/dbx"
+	"github.com/sivaosorg/govm/logger"
+	"github.com/sivaosorg/govm/rabbitmqx"
+	"github.com/sivaosorg/rmqconn"
+)
+
+func createConn() (*rmqconn.RabbitMq, dbx.Dbx) {
+	return rmqconn.NewClient(*rabbitmqx.GetRabbitMqConfigSample().SetDebugMode(false).SetEnabled(true).SetPort(5672))
+}
+
+func TestConn(t *testing.T) {
+	_, s := createConn()
+	logger.Infof("Rabbit connection status: %v", s)
+}

example/rmqconn_test.go

@@ -4,23 +4,12 @@ import (
 	"os"
 	"testing"
 
-	"github.com/sivaosorg/govm/dbx"
 	"github.com/sivaosorg/govm/logger"
-	"github.com/sivaosorg/govm/rabbitmqx"
 	"github.com/sivaosorg/rmqconn"
 
 	amqp "github.com/rabbitmq/amqp091-go"
 )
 
-func createConn() (*rmqconn.RabbitMq, dbx.Dbx) {
-	return rmqconn.NewClient(*rabbitmqx.GetRabbitMqConfigSample().SetDebugMode(false).SetEnabled(true).SetPort(5672))
-}
-
-func TestConn(t *testing.T) {
-	_, s := createConn()
-	logger.Infof("Rabbit connection status: %v", s)
-}
-
 func TestCoreServiceDeclareExchangeConf(t *testing.T) {
 	r, _ := createConn()
 	r.Config.Message.SetEnabled(true)
@@ -67,6 +56,10 @@ func TestCoreServiceConsumeMessage(t *testing.T) {
 	callback := func(next amqp.Delivery) {
 		logger.Debugf("Received Exchange Name: %v, Message: %s", next.Exchange, string(next.Body))
 	}
+	// using goroutines to consume all messages
+	// go svc.ConsumeConf(callback)
+	// or
+	// go func(){ err = svc.ConsumeConf(callback) }
 	err = svc.ConsumeConf(callback)
 	if err != nil {
 		logger.Errorf("Consuming message got an error", err)