diff --git a/lib/content_views/messages_page.dart b/lib/content_views/messages_page.dart
index 0412971..e843f60 100644
--- a/lib/content_views/messages_page.dart
+++ b/lib/content_views/messages_page.dart
@@ -1,3 +1,5 @@
+import 'dart:convert';
+
 import 'package:flutter/material.dart';
 import 'package:flutter_chat_ui/flutter_chat_ui.dart';
 import 'package:flutter_chat_types/flutter_chat_types.dart' as types;
@@ -105,7 +107,9 @@ class _MessagesPageState extends State<MessagesPage> {
       MyApp.isarInstance.messages.putSync(message);
     });
 
-    MqttCore.instance.publishPayloadMessage('mssg', message.toJson());
+    var json = jsonEncode(message.toJson());
+
+    MqttCore.instance.publishText('/appserver/to_server/100/1/104400/set_location', jsonEncode(message.toJson()));
 
     _messages.insert(0, types.TextMessage(
       author: _user,
diff --git a/lib/tools/mqtt_core.dart b/lib/tools/mqtt_core.dart
index 5a37202..ed6c642 100644
--- a/lib/tools/mqtt_core.dart
+++ b/lib/tools/mqtt_core.dart
@@ -198,7 +198,7 @@ class MqttCore {
             break;
 
           case "mssg":
-            //_messageMessageReceived(payloadData);
+            _messageMessageReceived(payload);
             break;
 
           default:
@@ -297,7 +297,7 @@ class MqttCore {
     _sendSyncMessage();
   }
 
-  void _messageMessageReceived(Map<String, dynamic> payloadData) async {
+  void _messageMessageReceived(payloadData) async {
     var newMessage = await Message.mergeFromJson(payloadData);
 
     await MyApp.isarInstance.writeTxn(() async {