diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
index 3dc2c601..8d64f434 100644
--- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
+++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java
@@ -516,7 +516,7 @@ public class DatabaseStore {
                 statement.setTimestamp(index++, new Timestamp(message.getServerTimestamp()));
                 statement.setInt(index++, message.getContent().getType());
                 String to = message.getToUser();
-                if (!StringUtil.isNullOrEmpty(message.getToUser())) {
+                if (StringUtil.isNullOrEmpty(message.getToUser())) {
                     if (message.getToList()!= null && message.getToList().size() == 1) {
                         to = message.getToList().get(0);
                     }