diff --git a/lib/src/main/java/com/logentries/logger/AsyncLoggingWorker.java b/lib/src/main/java/com/logentries/logger/AsyncLoggingWorker.java
index b01e101..285c055 100644
--- a/lib/src/main/java/com/logentries/logger/AsyncLoggingWorker.java
+++ b/lib/src/main/java/com/logentries/logger/AsyncLoggingWorker.java
@@ -342,8 +342,11 @@ public void run() {
                             }
 
                             if (message != null) {
-                                this.leClient.write(Utils.formatMessage(message.replace("\n", LINE_SEP_REPLACER),
-                                        logHostName, useHttpPost));
+                                if(sendRawLogMessage){
+                                    this.leClient.write(Utils.formatMessage(message.replace("\n", LINE_SEP_REPLACER),logHostName, useHttpPost));
+                                }else{
+                                    this.leClient.write(message.replace("\n", LINE_SEP_REPLACER));
+                                }
                                 message = null;
                             }