DeleteMessage


1   /**
2    *
3    * Licensed to the Apache Software Foundation (ASF) under one or more
4    * contributor license agreements.  See the NOTICE file distributed with
5    * this work for additional information regarding copyright ownership.
6    * The ASF licenses this file to You under the Apache License, Version 2.0
7    * (the "License"); you may not use this file except in compliance with
8    * the License.  You may obtain a copy of the License at
9    *
10   * http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
17   */
18  package org.apache.activemq.web.controller;
19  
20  import org.apache.activemq.broker.jmx.QueueViewMBean;
21  import org.apache.activemq.web.BrokerFacade;
22  import org.apache.activemq.web.DestinationFacade;
23  import org.springframework.web.servlet.ModelAndView;
24  import org.springframework.web.servlet.mvc.Controller;
25  
26  import javax.servlet.http.HttpServletRequest  ;
27  import javax.servlet.http.HttpServletResponse  ;
28  
29  /**
30   * @version $Revision: 516117 $
31   */
32  public class DeleteMessage extends DestinationFacade implements Controller {
33      private String   messageId;
34  
35      public DeleteMessage(BrokerFacade brokerFacade) {
36          super(brokerFacade);
37      }
38  
39      public ModelAndView handleRequest(HttpServletRequest   request, HttpServletResponse   response) throws Exception   {
40          if (messageId != null) {
41              QueueViewMBean queueView = getQueue();
42              if (queueView != null) {
43                  System.out.println("#### removing message: " + messageId);
44                  queueView.removeMessage(messageId);
45              }
46              else {
47                  System.out.println("#### NO QUEUE!");
48              }
49          }
50          return redirectToBrowseView();
51      }
52  
53      public String   getMessageId() {
54          return messageId;
55      }
56  
57      public void setMessageId(String   messageId) {
58          this.messageId = messageId;
59      }
60  
61      protected QueueViewMBean getQueue() throws Exception   {
62          String   name = getPhysicalDestinationName();
63          System.out.println("####?looking up queue: " + name);
64          return getBrokerFacade().getQueue(name);
65      }
66  }
67
A to Z: JavaDoc & Examples Daily Java News & Articles Open Source Projects Open Source Codes Free Computer Books Remove Frame
Popular Tags