[Hyperic-hq-discuss] hq r7099 - trunk/src/org/hyperic/hq/zevents

[<jt...@hy...>]

Author: jtravis
Date: 2007-12-05 15:24:26 -0800 (Wed, 05 Dec 2007)
New Revision: 7099
URL: http://svn.hyperic.org/?view=rev&root=Hyperic+HQ&revision=7099

Modified:
   trunk/src/org/hyperic/hq/zevents/ZeventManager.java
Log:
Add more debugging

Modified: trunk/src/org/hyperic/hq/zevents/ZeventManager.java
===================================================================
--- trunk/src/org/hyperic/hq/zevents/ZeventManager.java	2007-12-05 23:23:42 UTC (rev 7098)
+++ trunk/src/org/hyperic/hq/zevents/ZeventManager.java	2007-12-05 23:24:26 UTC (rev 7099)
@@ -299,11 +299,17 @@
      */
     public void enqueueEventsAfterCommit(List inEvents) {
         final List events = new ArrayList(inEvents);
-        HQApp.getInstance().addTransactionListener(new TransactionListener() {
+        TransactionListener txListener = new TransactionListener() {
             public void afterCommit(boolean success) {
                 try {
-                    if (success)
+                    if (_log.isDebugEnabled()) {
+                        _log.debug("Listener[" + this + "] after tx " + 
+                                   "enqueueing=" + success);
+                    }
+                    
+                    if (success) {
                         enqueueEvents(events);
+                    }
                 } catch(InterruptedException e) {
                     _log.warn("Interrupted while enqueueing events");
                 }
@@ -311,7 +317,13 @@
 
             public void beforeCommit() {
             }
-        });
+        };
+
+        if (_log.isDebugEnabled()) {
+            _log.debug("Listener[" + txListener + "] Enqueueing events: " + 
+                       inEvents);
+        }
+        HQApp.getInstance().addTransactionListener(txListener);
     }
     
     public void enqueueEvent(Zevent event) throws InterruptedException {