diff --git a/pkg/eventbus/eventbus.go b/pkg/eventbus/eventbus.go
index 31cf99f4a..ae480c9ef 100644
--- a/pkg/eventbus/eventbus.go
+++ b/pkg/eventbus/eventbus.go
@@ -46,6 +46,10 @@ func Service() *eventbus {
 	return gEventBus
 }
 
+func Set(eb *eventbus) {
+	gEventBus = eb
+}
+
 func New() *eventbus {
 	return &eventbus{
 		wg:       &sync.WaitGroup{},
diff --git a/tests/compose/main_test.go b/tests/compose/main_test.go
index a1b6d7dc3..e5e2a0dab 100644
--- a/tests/compose/main_test.go
+++ b/tests/compose/main_test.go
@@ -2,6 +2,7 @@ package compose
 
 import (
 	"context"
+	"github.com/cortezaproject/corteza-server/pkg/eventbus"
 	"os"
 	"testing"
 
@@ -45,6 +46,8 @@ type (
 var (
 	testApp app.Runnable
 	r       chi.Router
+
+	eventBus = eventbus.New()
 )
 
 func init() {
@@ -58,6 +61,10 @@ func db() *factory.DB {
 func (app *TestApp) Initialize(ctx context.Context) (err error) {
 	service.DefaultPermissions = permissions.NewTestService(ctx, app.Log, db(), "compose_permission_rules")
 	service.DefaultStore, err = plain.NewWithAfero(afero.NewMemMapFs(), "test")
+
+	eventBus = eventbus.New()
+	eventbus.Set(eventBus)
+
 	return
 }