Author: norman
Date: Sun Jan 9 19:18:33 2011
New Revision: 1057003
URL: http://svn.apache.org/viewvc?rev=1057003&view=rev
Log:
Some more work on make the queue content browsable via jmx. See JAMES-1180
Modified:
james/server/trunk/queue-api/src/main/java/org/apache/james/queue/api/MailQueueManagementMBean.java
james/server/trunk/queue-library/src/main/java/org/apache/james/queue/library/MailQueueManagement.java
Modified:
james/server/trunk/queue-api/src/main/java/org/apache/james/queue/api/MailQueueManagementMBean.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/queue-api/src/main/java/org/apache/james/queue/api/MailQueueManagementMBean.java?rev=1057003&r1=1057002&r2=1057003&view=diff
==============================================================================
---
james/server/trunk/queue-api/src/main/java/org/apache/james/queue/api/MailQueueManagementMBean.java
(original)
+++
james/server/trunk/queue-api/src/main/java/org/apache/james/queue/api/MailQueueManagementMBean.java
Sun Jan 9 19:18:33 2011
@@ -18,6 +18,10 @@
****************************************************************/
package org.apache.james.queue.api;
+import java.util.List;
+
+import javax.management.openmbean.CompositeData;
+
public interface MailQueueManagementMBean {
@@ -63,4 +67,12 @@ public interface MailQueueManagementMBea
*/
public long removeWithRecipient(String address) throws Exception;
+ /**
+ * Allow to browse the content of the queue
+ *
+ * @return data
+ * @throws Exception
+ */
+ public List<CompositeData> browse() throws Exception;
+
}
Modified:
james/server/trunk/queue-library/src/main/java/org/apache/james/queue/library/MailQueueManagement.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/queue-library/src/main/java/org/apache/james/queue/library/MailQueueManagement.java?rev=1057003&r1=1057002&r2=1057003&view=diff
==============================================================================
---
james/server/trunk/queue-library/src/main/java/org/apache/james/queue/library/MailQueueManagement.java
(original)
+++
james/server/trunk/queue-library/src/main/java/org/apache/james/queue/library/MailQueueManagement.java
Sun Jan 9 19:18:33 2011
@@ -18,13 +18,19 @@
****************************************************************/
package org.apache.james.queue.library;
+import java.util.ArrayList;
+import java.util.List;
+
import javax.management.NotCompliantMBeanException;
import javax.management.StandardMBean;
+import javax.management.openmbean.CompositeData;
import org.apache.james.queue.api.MailQueueManagementMBean;
import org.apache.james.queue.api.ManageableMailQueue;
import org.apache.james.queue.api.MailQueue.MailQueueException;
+import org.apache.james.queue.api.ManageableMailQueue.MailQueueIterator;
import org.apache.james.queue.api.ManageableMailQueue.Type;
+import org.apache.mailet.Mail;
/**
*
@@ -112,4 +118,24 @@ public class MailQueueManagement extends
return -1;
}
}
+
+ /*
+ * (non-Javadoc)
+ * @see org.apache.james.queue.api.MailQueueManagementMBean#browse()
+ */
+ public List<CompositeData> browse() throws Exception {
+ MailQueueIterator it = queue.browse();
+ List<CompositeData> data = new ArrayList<CompositeData>();
+ while(it.hasNext()) {
+ Mail m = it.next();
+
+ //TODO implement me!
+
+ }
+ it.close();
+ // TODO Auto-generated method stub
+ return data;
+ }
+
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
