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 22:40:33 UTC
[qpid-broker-j] 03/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 7.1.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit d9914f064528ba595dbf71fd9c9c1ec3b78ad6f5
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 4382249..3bf3205 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
@@ -1754,7 +1754,7 @@ public abstract class AbstractQueue<X extends AbstractQueue<X>>
}
txn.commit();
-
+ logOperation(String.format("clearQueue : %s: %d", getName(), count));
return count;
}
@@ -3430,6 +3430,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();
}
@@ -3443,6 +3447,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();
}
@@ -3455,7 +3463,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