fix printout (#121)

teragrep · Apr 8, 2024 · 5a8d258 · 5a8d258
1 parent 57cca98
commit 5a8d258
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/main/java/com/teragrep/rlp_03/EventLoop.java b/src/main/java/com/teragrep/rlp_03/EventLoop.java
@@ -135,7 +135,7 @@ else if (selectionKey.isConnectable()) {
                     connectionContext.handleEvent(selectionKey);
                 }
                 catch (CancelledKeyException cke) {
-                    LOGGER.warn("SocketPoll.poll CancelledKeyException caught: {}", cke.getMessage());
+                    LOGGER.warn("SocketPoll.poll CancelledKeyException caught: <{}>", cke.getMessage());
                     connectionContext.close();
                 }
             }
@@ -153,7 +153,7 @@ public void close() {
             selector.close();
         }
         catch (IOException ioException) {
-            LOGGER.warn("selector close threw", ioException);
+            LOGGER.warn("Selector.close() threw <{}>", ioException.getMessage(), ioException);
         }
     }
 

diff --git a/src/main/java/com/teragrep/rlp_03/ListenContext.java b/src/main/java/com/teragrep/rlp_03/ListenContext.java
@@ -133,7 +133,7 @@ public void handleEvent(SelectionKey selectionKey) {
         }
         catch (CancelledKeyException cke) {
             // thrown by accessing cancelled SelectionKey
-            LOGGER.warn("SocketPoll.poll CancelledKeyException caught: {}", cke.getMessage());
+            LOGGER.warn("SocketPoll.poll CancelledKeyException caught <{}>", cke.getMessage());
             try {
                 selectionKey.channel().close();
             }

diff --git a/src/main/java/com/teragrep/rlp_03/client/Client.java b/src/main/java/com/teragrep/rlp_03/client/Client.java
@@ -75,7 +75,7 @@ public CompletableFuture<AbstractMap.SimpleEntry<String, byte[]>> transmit(Strin
         int txn = txnCounter.incrementAndGet();
         relpFrameTX.setTransactionNumber(txn);
         if (transactions.containsKey(txn)) {
-            throw new IllegalStateException("already pending txn <" + txn + ">");
+            throw new IllegalStateException("Already existing txn <" + txn + "> used.");
         }
         CompletableFuture<AbstractMap.SimpleEntry<String, byte[]>> future = new CompletableFuture<>();
         transactions.put(txn, future);