Move message struct definition to hub

hub/hub.go

@@ -13,6 +13,10 @@ type (
 		subscribers []*Subscription
 		lock        sync.Mutex
 	}
+	Message struct {
+		Queue   string
+		Message []byte
+	}
 )
 
 func New(st *storage.Storage) *Hub {

hub/subscription.go

@@ -6,10 +6,6 @@ type (
 		result chan Message
 		done   chan struct{}
 	}
-	Message struct {
-		Queue   string
-		Message []byte
-	}
 )
 
 func NewSubscription(queues []string) *Subscription {