diff --git a/internal/controllers/tickets/tickets.go b/internal/controllers/tickets/tickets.go
index 78edfd5..57d35fb 100644
--- a/internal/controllers/tickets/tickets.go
+++ b/internal/controllers/tickets/tickets.go
@@ -13,6 +13,7 @@ import (
 	"github.com/gofiber/fiber/v2"
 	"go.uber.org/zap"
 	"gopkg.in/telebot.v3"
+  "encoding/json"
 )
 
 type Deps struct {
@@ -555,7 +556,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
 			if err := t.dal.WatchMessages(ctx, ticketID,
 				func(message model.Message) error {
 					if !message.System {
-						output <- message
+            msg,_:=json.Marshal(message)
+						output <- msg
 					}
 
 					//if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {
@@ -577,7 +579,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
 			go func() {
 
 				if err := t.dal.YieldMessages(ctx, ticketID, func(message model.Message) error {
-					output <- message
+            msg,_:=json.Marshal(message)
+					output <- msg
 
 					//if err := h.dal.SetShown(ctx, message.ID, sess.User); err != nil {
 					//	fmt.Println("2", err)
@@ -593,7 +596,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
 
 				if err := t.dal.WatchMessages(ctx, ticketID,
 					func(message model.Message) error {
-						output <- message
+            msg,_:=json.Marshal(message)
+						output <- msg
 
 						//if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {
 						//	fmt.Println("3", err)
@@ -637,7 +641,8 @@ func (t *TicketController) Subscribe(ctx context.Context) chan interface{} {
 				if err := t.dal.WatchMessages(ctx, ticketID,
 					func(message model.Message) error {
 						if !message.System {
-							output <- message
+            msg,_:=json.Marshal(message)
+							output <- msg
 						}
 
 						//if err := h.dal.SetShown(ctx, message.ID, sess.Session); err != nil {