diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 1d902dbb..8422f203 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2207,6 +2207,10 @@ public class MemoryMessagesStore implements IMessagesStore { builder.setExtra(userInfo.getExtra()); } if((flag & Update_User_Name) > 0) { + if(StringUtil.isNullOrEmpty(userInfo.getName())) { + LOG.error("Modify user info failure, name not exist!"); + return ErrorCode.INVALID_PARAMETER; + } builder.setName(userInfo.getName()); } builder.setUpdateDt(System.currentTimeMillis());