diff --git a/modem/command_message_send.py b/modem/command_message_send.py
index 4915cf5e..36e92ae0 100644
--- a/modem/command_message_send.py
+++ b/modem/command_message_send.py
@@ -4,6 +4,7 @@ import base64
 from queue import Queue
 from arq_session_iss import ARQSessionISS
 from message_p2p import MessageP2P
+from arq_data_type_handler import ARQDataTypeHandler
 
 class SendMessageCommand(TxCommand):
     """Command to send a P2P message using an ARQ transfer session
@@ -14,10 +15,12 @@ class SendMessageCommand(TxCommand):
         self.message = MessageP2P.from_api_params(origin, apiParams)
 
     def transmit(self, modem):
+        data, data_type = self.arq_data_type_handler.prepare(self.message.to_payload, 'p2pmsg_lzma')
         iss = ARQSessionISS(self.config, modem, 
                             self.message.destination, 
-                            self.message.to_payload(), 
-                            self.state_manager)
+                            data,
+                            self.state_manager,
+                            data_type)
         
         self.state_manager.register_arq_iss_session(iss)
         iss.start()