diff --git a/broker/src/main/java/io/moquette/spi/impl/DebugUtils.java b/broker/src/main/java/io/moquette/spi/impl/DebugUtils.java
index 4c403275..2a029fa8 100644
--- a/broker/src/main/java/io/moquette/spi/impl/DebugUtils.java
+++ b/broker/src/main/java/io/moquette/spi/impl/DebugUtils.java
@@ -25,16 +25,7 @@ import java.nio.ByteBuffer;
*/
class DebugUtils {
- static String payload2Str(ByteBuffer content) {
- byte[] b = new byte[content.remaining()];
- content.mark();
- content.get(b);
- content.reset();
- return new String(b);
- }
-
static String payload2Str(ByteBuf content) {
- // byte[] b = new byte[content.readableBytes()];
- return new String(content.copy().array());
+ return new String(content.copy ().array());
}
}
diff --git a/distribution/pom.xml b/distribution/pom.xml
index f4eb75a9..8b8214ca 100644
--- a/distribution/pom.xml
+++ b/distribution/pom.xml
@@ -21,12 +21,6 @@
${project.version}
-
- ${project.groupId}
- moquette-netty-parser
- ${project.version}
-
-
org.slf4j
slf4j-api
diff --git a/netty_parser/pom.xml b/netty_parser/pom.xml
deleted file mode 100644
index 08d49f91..00000000
--- a/netty_parser/pom.xml
+++ /dev/null
@@ -1,147 +0,0 @@
-
-
- 4.0.0
-
- ../
- moquette-parent
- io.moquette
- 0.10-SNAPSHOT
-
-
- moquette-netty-parser
- jar
- Moquette - Netty Parser
-
-
- UTF-8
- io.moquette.moquette-netty-parser
-
-
-
-
- io.netty
- netty-common
- ${netty.version}
-
-
-
- io.netty
- netty-buffer
- ${netty.version}
-
-
-
- io.netty
- netty-transport
- ${netty.version}
-
-
-
- io.netty
- netty-handler
- ${netty.version}
-
-
-
- org.slf4j
- slf4j-api
- 1.6.4
-
-
-
- org.slf4j
- slf4j-log4j12
- 1.6.4
- test
-
-
-
- junit
- junit
- 4.8.2
- test
-
-
-
-
- org.mockito
- mockito-core
- 1.9.0
- test
-
-
-
- org.hdrhistogram
- HdrHistogram
- 2.1.2
- test
-
-
-
- org.eclipse.paho
- org.eclipse.paho.client.mqttv3
- 1.1.0
- test
-
-
-
- org.eclipse.jetty.toolchain
- jetty-perf-helper
- 1.0.5
- test
-
-
-
-
-
-
-
-
-
-
-
-
-
- org.apache.maven.plugins
- maven-surefire-plugin
-
-
- io/moquette/parser/netty/TestUtils.java
- io/moquette/parser/netty/TestUtils$*
-
-
-
-
-
-
- maven-jar-plugin
-
-
- ${project.build.outputDirectory}/META-INF/MANIFEST.MF
-
-
-
-
- org.apache.felix
- maven-bundle-plugin
-
-
- bundle-manifest
- process-classes
-
- manifest
-
-
-
-
-
-
-
-
-
- bintray
- https://api.bintray.com/maven/${bintray.repo}/${bintray.package}
-
-
-
diff --git a/netty_parser/src/main/java/io/moquette/parser/commons/Constants.java b/netty_parser/src/main/java/io/moquette/parser/commons/Constants.java
deleted file mode 100644
index 87a27f02..00000000
--- a/netty_parser/src/main/java/io/moquette/parser/commons/Constants.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- * Copyright (c) 2012-2017 The original author or authorsgetRockQuestions()
- * ------------------------------------------------------
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * and Apache License v2.0 which accompanies this distribution.
- *
- * The Eclipse Public License is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * The Apache License v2.0 is available at
- * http://www.opensource.org/licenses/apache2.0.php
- *
- * You may elect to redistribute this code under either of these licenses.
- */
-package io.moquette.parser.commons;
-
-import java.io.File;
-
-/**
- * Contains some useful constants.
- */
-public class Constants {
- public static final int DEFAULT_CONNECT_TIMEOUT = 10;
-
-}
diff --git a/netty_parser/src/main/java/io/moquette/parser/netty/ConnAckDecoder.java b/netty_parser/src/main/java/io/moquette/parser/netty/ConnAckDecoder.java
deleted file mode 100644
index 1f807ff0..00000000
--- a/netty_parser/src/main/java/io/moquette/parser/netty/ConnAckDecoder.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package io.moquette.parser.netty;
-
-import io.netty.buffer.ByteBuf;
-import io.netty.util.AttributeMap;
-import java.util.List;
-import io.moquette.parser.proto.messages.ConnAckMessage;
-
-/**
- *
- * @author andrea
- */
-class ConnAckDecoder extends DemuxDecoder {
-
- @Override
- void decode(AttributeMap ctx, ByteBuf in, List