load from autoload

edobtc · Apr 26, 2024 · 3cd5011 · 3cd5011
1 parent 27adaa5
commit 3cd5011
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/events/publishers/autoload/autoload.go b/events/publishers/autoload/autoload.go
@@ -11,6 +11,7 @@ import (
 	"github.com/edobtc/cloudkit/events/publishers/aws/lambda"
 	"github.com/edobtc/cloudkit/events/publishers/aws/sns"
 	"github.com/edobtc/cloudkit/events/publishers/filesystem"
+	"github.com/edobtc/cloudkit/events/publishers/rmq"
 	"github.com/edobtc/cloudkit/events/publishers/webhook"
 	"github.com/edobtc/cloudkit/events/publishers/websocket"
 )
@@ -36,6 +37,8 @@ func NewPublisher(adapter string) (delivery.Publisher, error) {
 		return webhook.NewPublisher()
 	case "websocket", "ws":
 		return websocket.NewPublisher()
+	case "rabbitmq", "rmq", "amqp":
+		return rmq.NewPublisher()
 	default:
 		return nil, ErrAdapterNotFound
 	}