refactor: convert message body to string

Author: lugomez29

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java

@@ -90,11 +90,8 @@ public Sinks.Many<Command<Long>> listener() {
 
         private DomainCommandHandler<Long> handle(Sinks.Many<Command<Long>> listener) {
             return command -> fromRunnable(() -> {
-//                    out.println("Received at: " + System.currentTimeMillis()/1000);
                 try {
-//                        out.println("internal: " + Thread.currentThread().getName());
                     TimeUnit.MILLISECONDS.sleep(750);
-//                        out.println("Handled at: " + System.currentTimeMillis()/1000);
                     listener.emitNext(command, Sinks.EmitFailureHandler.FAIL_FAST);
                 } catch (InterruptedException ignored) {
                 }

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java

@@ -91,11 +91,8 @@ public Sinks.Many<Command<Long>> listener() {
 
         private DomainCommandHandler<Long> handle(Sinks.Many<Command<Long>> listener) {
             return command -> {
-//                out.println("Received at: " + System.currentTimeMillis()/1000);
                 try {
-//                    out.println("internal: " + Thread.currentThread().getName());
                     TimeUnit.MILLISECONDS.sleep(750);
-//                    out.println("Handled at: " + System.currentTimeMillis()/1000);
                     listener.emitNext(command, Sinks.EmitFailureHandler.FAIL_FAST);
                 } catch (InterruptedException e) {
                 }

async/async-commons/src/main/java/org/reactivecommons/async/commons/DLQDiscardNotifier.java

@@ -13,7 +13,6 @@
 import org.reactivecommons.async.commons.exceptions.MessageConversionException;
 import reactor.core.publisher.Mono;
 
-import java.util.Arrays;
 import java.util.logging.Level;
 
 import static java.lang.String.format;
@@ -54,7 +53,7 @@ private Mono<Void> notify(Message message) {
     private Mono<Void> notifyUnreadableMessage(Message message, MessageConversionException e) {
         String bodyString;
         try {
-            bodyString = Arrays.toString(message.getBody());
+            bodyString = new String(message.getBody());
         } catch (Exception ex) {
             bodyString = "Opaque binary Message, unable to decode: " + ex.getMessage();
         }