[jboss-cvs] JBoss Messaging SVN: r5472 - trunk/src/main/org/jboss/messaging/core/management/impl.

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

Author: jmesnil
Date: 2008-12-08 07:35:16 -0500 (Mon, 08 Dec 2008)
New Revision: 5472

Modified:
   trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java
Log:
removed unused methods

Modified: trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java	2008-12-08 12:29:32 UTC (rev 5471)
+++ trunk/src/main/org/jboss/messaging/core/management/impl/MessagingServerControl.java	2008-12-08 12:35:16 UTC (rev 5472)
@@ -178,61 +178,6 @@
       return configuration;
    }
 
-   public int expireMessages(final Filter filter, final SimpleString simpleAddress) throws Exception
-   {
-      Binding binding = postOffice.getBinding(simpleAddress);
-      if (binding != null)
-      {
-         Queue queue = binding.getQueue();
-         List<MessageReference> refs = queue.list(filter);
-         
-         //FIXME - what if the refs have been consumed between listing them and expiring them?
-         
-         for (MessageReference ref : refs)
-         {
-            queue.expireMessage(ref.getMessage().getMessageID(), storageManager, postOffice, queueSettingsRepository);
-         }
-         return refs.size();
-      }
-      return 0;
-   }
-
-   public int sendMessagesToDLQ(final Filter filter, final SimpleString simpleAddress) throws Exception
-   {
-      Binding binding = postOffice.getBinding(simpleAddress);
-      if (binding != null)
-      {
-         Queue queue = binding.getQueue();
-         List<MessageReference> refs = queue.list(filter);
-         for (MessageReference ref : refs)
-         {
-            queue.sendMessageToDeadLetterAddress(ref.getMessage().getMessageID(), storageManager, postOffice, queueSettingsRepository);
-         }
-         return refs.size();
-      }
-      return 0;
-   }
-
-   public int changeMessagesPriority(final Filter filter, final byte newPriority, final SimpleString simpleAddress) throws Exception
-   {
-      Binding binding = postOffice.getBinding(simpleAddress);
-      if (binding != null)
-      {
-         Queue queue = binding.getQueue();
-         List<MessageReference> refs = queue.list(filter);
-         for (MessageReference ref : refs)
-         {
-            queue.changeMessagePriority(ref.getMessage().getMessageID(),
-                                        newPriority,
-                                        storageManager,
-                                        postOffice,
-                                        queueSettingsRepository);
-         }
-         return refs.size();
-      }
-      return 0;
-   }
-
    // MessagingServerControlMBean implementation --------------------
 
    //FIXME