You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2020/10/08 21:52:07 UTC
[qpid-broker-j] 01/03: QPID-8472:[Broker-J]Improve operational
logging for operations on queue
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch 8.0.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit 7de904bc5d4ceff419c7e0598e83d95a36a12e13
Author: Dedeepya T <de...@yahoo.co.in>
AuthorDate: Mon Oct 5 14:23:07 2020 +0530
QPID-8472:[Broker-J]Improve operational logging for operations on queue
---
.../java/org/apache/qpid/server/queue/AbstractQueue.java | 14 ++++++++++++--
1 file changed, 12 insertions(+), 2 deletions(-)
diff --git a/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java b/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
index 543ad1f..92cad5a 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
@@ -1826,7 +1826,7 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
}
txn.commit();
-
+ logOperation(String.format("clearQueue : %s: %d", getName(), count));
return count;
}
@@ -3508,6 +3508,10 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
parseSelector(selector),
limit);
_virtualHost.executeTransaction(transaction);
+ logOperation(String.format("moveMessages : %s: %s: %d",
+ getName(),
+ destination.getName(),
+ transaction.getModifiedMessageIds().size()));
return transaction.getModifiedMessageIds();
}
@@ -3521,6 +3525,10 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
parseSelector(selector),
limit);
_virtualHost.executeTransaction(transaction);
+ logOperation(String.format("copyMessages : %s: %s: %d",
+ getName(),
+ destination.getName(),
+ transaction.getModifiedMessageIds().size()));
return transaction.getModifiedMessageIds();
}
@@ -3533,7 +3541,9 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
parseSelector(selector),
limit);
_virtualHost.executeTransaction(transaction);
-
+ logOperation(String.format("deleteMessages : %s: %d",
+ getName(),
+ transaction.getModifiedMessageIds().size()));
return transaction.getModifiedMessageIds();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org