[jboss-cvs] JBoss Messaging SVN: r1542 - branches/Branch_Client_Failover_Experiment/src/main/org/jboss/messaging/core/plugin/postoffice

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2006-11-01 16:08:42 -0500 (Wed, 01 Nov 2006)
New Revision: 1542

Modified:
   branches/Branch_Client_Failover_Experiment/src/main/org/jboss/messaging/core/plugin/postoffice/DefaultPostOffice.java
Log:
Adding output into print method

Modified: branches/Branch_Client_Failover_Experiment/src/main/org/jboss/messaging/core/plugin/postoffice/DefaultPostOffice.java
===================================================================
--- branches/Branch_Client_Failover_Experiment/src/main/org/jboss/messaging/core/plugin/postoffice/DefaultPostOffice.java	2006-11-01 20:50:28 UTC (rev 1541)
+++ branches/Branch_Client_Failover_Experiment/src/main/org/jboss/messaging/core/plugin/postoffice/DefaultPostOffice.java	2006-11-01 21:08:42 UTC (rev 1542)
@@ -631,6 +631,26 @@
                out.println("<tr>");
                out.println("<td>" + entry2.getKey() + "</td><td>" + entry2.getValue()+ "</td><td>" + entry2.getValue().getClass().getName() + "</td>");
                out.println("</tr>");
+
+               if (entry2.getValue() instanceof Binding && ((Binding)entry2.getValue()).getQueue() instanceof PagingFilteredQueue)
+               {
+                   PagingFilteredQueue queue = (PagingFilteredQueue)((Binding)entry2.getValue()).getQueue();
+                   List undelivered = queue.undelivered(null);
+                   if (!undelivered.isEmpty())
+                   {
+                       out.println("<tr><td>List of undelivered messages on Paging</td>");
+
+                       out.println("<td colspan=2><table border=1>");
+                       out.println("<tr><td>Reference#</td><td>Message</td></tr>");
+                       for (Iterator iterUndelivered = undelivered.iterator();iterUndelivered.hasNext();)
+                       {
+                           MessageReference reference = (MessageReference)iterUndelivered.next();
+                           out.println("<tr><td>" + reference.getInMemoryChannelCount() + "</td><td>" + reference.getMessage() +"</td></tr>");
+                       }
+                       out.println("</table></td>");
+                       out.println("</tr>");
+                   }
+               }
                //out.println("   bindingName=" +entry2.getKey() + " value = " + entry2.getValue() + " valueClass=" + entry2.getValue().getClass().getName());
            }
        }