rollback debug changes

th2-net · Jul 8, 2024 · 6b5c84a · 6b5c84a
1 parent 2acea6e
commit 6b5c84a
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/...va/com/exactpro/th2/common/schema/message/impl/rabbitmq/connection/ConnectionManager.java b/...va/com/exactpro/th2/common/schema/message/impl/rabbitmq/connection/ConnectionManager.java
@@ -467,12 +467,7 @@ private void closeConnection(Connection connection, int timeout) {
     public void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body) throws IOException, InterruptedException {
         ChannelHolder holder = getOrCreateChannelFor(PinId.forRoutingKey(exchange, routingKey), publishConnection);
         holder.retryingPublishWithLock(configuration, body,
-                (channel, payload) -> {
-            long start = System.currentTimeMillis();
-            channel.basicPublish(exchange, routingKey, props, payload);
-            long delay = System.currentTimeMillis() - start;
-            LOGGER.error("delay = {}", delay);
-        });
+                (channel, payload) -> channel.basicPublish(exchange, routingKey, props, payload));
     }
 
     public String queueDeclare() throws IOException {
@@ -919,7 +914,7 @@ public void retryingPublishWithLock(ConnectionManagerConfiguration configuration
                     } catch (IOException | ShutdownSignalException e) {
                         var currentValue = iterator.next();
                         var recoveryDelay = currentValue.getDelay();
-                        LOGGER.error("Retrying publishing #{}, waiting for {}ms. Reason: {}", currentValue.getTryNumber(), recoveryDelay, e);
+                        LOGGER.warn("Retrying publishing #{}, waiting for {}ms. Reason: {}", currentValue.getTryNumber(), recoveryDelay, e);
                         TimeUnit.MILLISECONDS.sleep(recoveryDelay);
                         // cleanup after failure
                         publishConfirmationListener.remove(msgSeq);