[rhmessaging-commits] rhmessaging commits: r4004 - store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb.
Author: rgemmell
Date: 2010-06-02 11:36:13 -0400 (Wed, 02 Jun 2010)
New Revision: 4004
Modified:
store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
Log:
Add some additional debug logging
Modified:
store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
===================================================================
---
store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2010-06-02
14:22:52 UTC (rev 4003)
+++
store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2010-06-02
15:36:13 UTC (rev 4004)
@@ -1112,11 +1112,11 @@
try
{
- _deliveryDb.put(tx, key, value);
if (_log.isDebugEnabled())
{
- _log.debug("Enqueuing message " + messageId + " on queue
" + name + "[Transaction" + tx + "]");
+ _log.debug("Enqueuing message " + messageId + " on queue
" + name + " [Transaction" + tx + "]");
}
+ _deliveryDb.put(tx, key, value);
}
catch (DatabaseException e)
{
@@ -1190,10 +1190,13 @@
*/
public void commitTran(StoreContext context) throws AMQException
{
- // _log.debug("public void commitTran(StoreContext context = " +
context + "): called");
-
com.sleepycat.je.Transaction tx = (com.sleepycat.je.Transaction)
context.getPayload();
+ if (_log.isDebugEnabled())
+ {
+ _log.debug("public void commitTran(StoreContext context = " +
context + "): called with [Transaction" + tx + "]");
+ }
+
if (tx == null)
{
throw new AMQException("Fatal internal error: transactional context is
empty at commitTran");