qos2重复bug修复

Author: 1ssqq1lxr

smqttx-core/src/main/java/io/github/quickmsg/core/protocol/PublishProtocol.java

@@ -56,7 +56,7 @@ public void parseProtocol(PublishMessage message, MqttChannel mqttChannel, Conte
                 case EXACTLY_ONCE:
                     mqttChannel.saveQos2Cache(message.getMessageId(), message);
                     mqttChannel.write(MqttMessageUtils.buildPublishRec(message.getMessageId()));
-                    break ;
+                    return ;
                 default:
                     break;
             }

smqttx-integrate/src/test/java/io/github/quickmsg/sql/Test1.java

@@ -52,7 +52,6 @@ public static void main(String[] args) throws InterruptedException {
                         new CacheConfiguration<Integer, Message.Person>()
                                 .setName("myCache")
                                 .setSqlFunctionClasses(MyFunctions.class)
-                                .setCacheMode(CacheMode.LOCAL)
                                 .setIndexedTypes(Integer.class,Message.Person.class));
 //        SqlFieldsQuery sqlFieldsQuery = new SqlFieldsQuery("insert into Person (_key,username,id,age) values (2,'lisi',1,2)").setLocal(true);
 //        cache.query(sqlFieldsQuery);
@@ -74,7 +73,6 @@ public static void main(String[] args) throws InterruptedException {
                         new CacheConfiguration<Integer, Message.Person>()
                                 .setName("myCache2")
                                 .setSqlFunctionClasses(MyFunctions.class)
-                                .setCacheMode(CacheMode.LOCAL)
                                 .setIndexedTypes(Integer.class,Message.Person.class));