diff --git a/internal/api/api.go b/internal/api/api.go
index 55bcf40..dc19e23 100644
--- a/internal/api/api.go
+++ b/internal/api/api.go
@@ -5,9 +5,9 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"github.com/creekorful/trandoshan/api"
+	"github.com/creekorful/trandoshan/internal/messaging"
 	"github.com/creekorful/trandoshan/internal/util/logging"
 	natsutil "github.com/creekorful/trandoshan/internal/util/nats"
-	"github.com/creekorful/trandoshan/messaging"
 	"github.com/labstack/echo/v4"
 	"github.com/nats-io/nats.go"
 	"github.com/olivere/elastic/v7"
diff --git a/internal/crawler/crawler.go b/internal/crawler/crawler.go
index da72fc1..5f3f0d2 100644
--- a/internal/crawler/crawler.go
+++ b/internal/crawler/crawler.go
@@ -2,9 +2,9 @@ package crawler
 
 import (
 	"crypto/tls"
+	"github.com/creekorful/trandoshan/internal/messaging"
 	"github.com/creekorful/trandoshan/internal/util/logging"
 	natsutil "github.com/creekorful/trandoshan/internal/util/nats"
-	"github.com/creekorful/trandoshan/messaging"
 	"github.com/nats-io/nats.go"
 	"github.com/rs/zerolog/log"
 	"github.com/urfave/cli/v2"
diff --git a/internal/extractor/extractor.go b/internal/extractor/extractor.go
index 1bad571..2677102 100644
--- a/internal/extractor/extractor.go
+++ b/internal/extractor/extractor.go
@@ -2,9 +2,9 @@ package extractor
 
 import (
 	"github.com/creekorful/trandoshan/api"
+	"github.com/creekorful/trandoshan/internal/messaging"
 	"github.com/creekorful/trandoshan/internal/util/logging"
 	natsutil "github.com/creekorful/trandoshan/internal/util/nats"
-	"github.com/creekorful/trandoshan/messaging"
 	"github.com/nats-io/nats.go"
 	"github.com/rs/zerolog/log"
 	"github.com/urfave/cli/v2"
diff --git a/messaging/messaging.go b/internal/messaging/messaging.go
similarity index 100%
rename from messaging/messaging.go
rename to internal/messaging/messaging.go
diff --git a/internal/scheduler/scheduler.go b/internal/scheduler/scheduler.go
index 7ff06df..c53a295 100644
--- a/internal/scheduler/scheduler.go
+++ b/internal/scheduler/scheduler.go
@@ -5,9 +5,9 @@ import (
 	"fmt"
 	"github.com/PuerkitoBio/purell"
 	"github.com/creekorful/trandoshan/api"
+	"github.com/creekorful/trandoshan/internal/messaging"
 	"github.com/creekorful/trandoshan/internal/util/logging"
 	natsutil "github.com/creekorful/trandoshan/internal/util/nats"
-	"github.com/creekorful/trandoshan/messaging"
 	"github.com/nats-io/nats.go"
 	"github.com/rs/zerolog/log"
 	"github.com/urfave/cli/v2"