1 22 package org.jboss.mq.server.jmx; 23 24 import java.util.Hashtable ; 25 import java.util.List ; 26 27 import javax.management.MBeanRegistration ; 28 import javax.management.MBeanServer ; 29 import javax.management.NotificationFilter ; 30 import javax.management.NotificationListener ; 31 import javax.management.ObjectName ; 32 33 import org.w3c.dom.Element ; 34 35 42 public class Queue 43 implements MBeanRegistration , QueueMBean 44 { 45 private org.jboss.jms.server.destination.Queue delegate; 46 47 public Queue() 48 { 49 delegate = new org.jboss.jms.server.destination.Queue(); 50 } 51 public Queue(boolean createProgramatically) 52 { 53 delegate = new org.jboss.jms.server.destination.Queue(createProgramatically); 54 } 55 56 public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) 57 { 58 delegate.addNotificationListener(listener, filter, handback); 59 } 60 61 64 public void create() throws Exception 65 { 66 delegate.create(); 67 } 68 69 72 public void destroy() 73 { 74 delegate.destroy(); 75 } 76 77 80 public int getDownCacheSize() 81 { 82 return delegate.getDownCacheSize(); 83 } 84 85 88 public int getFullSize() 89 { 90 return delegate.getFullSize(); 91 } 92 93 96 public String getJNDIName() 97 { 98 return delegate.getJNDIName(); 99 } 100 101 104 public int getMessageCount() throws Exception 105 { 106 return delegate.getMessageCount(); 107 } 108 109 112 public String getName() 113 { 114 return delegate.getName(); 115 } 116 117 120 public int getPageSize() 121 { 122 return delegate.getPageSize(); 123 } 124 125 128 public ObjectName getServerPeer() 129 { 130 return delegate.getServerPeer(); 131 } 132 133 public ObjectName getServiceName() 134 { 135 return delegate.getServiceName(); 136 } 137 138 141 public boolean isCreatedProgrammatically() 142 { 143 return delegate.isCreatedProgrammatically(); 144 } 145 146 149 public List listMessages(String arg0) throws Exception 150 { 151 return delegate.listMessages(arg0); 152 } 153 154 157 public void removeAllMessages() throws Exception 158 { 159 delegate.removeAllMessages(); 160 } 161 162 165 public void setDownCacheSize(int arg0) 166 { 167 delegate.setDownCacheSize(arg0); 168 } 169 170 173 public void setFullSize(int arg0) 174 { 175 delegate.setFullSize(arg0); 176 } 177 178 181 public void setJNDIName(String arg0) 182 { 183 delegate.setJNDIName(arg0); 184 } 185 186 189 public void setPageSize(int arg0) 190 { 191 delegate.setPageSize(arg0); 192 } 193 194 197 public void setSecurityConfig(Element arg0) throws Exception 198 { 199 delegate.setSecurityConfig(arg0); 200 } 201 public void setSecurityConf(Element arg0) throws Exception 202 { 203 delegate.setSecurityConfig(arg0); 204 } 205 206 public void setSecurityManager(ObjectName arg0) 207 { 208 } 210 211 214 public void setServerPeer(ObjectName arg0) 215 { 216 delegate.setServerPeer(arg0); 217 } 218 public void setDestinationManager(ObjectName arg0) throws Exception 219 { 220 ObjectName peer = new ObjectName ("jboss.messaging:service=ServerPeer"); 221 delegate.setServerPeer(peer); 222 } 223 224 227 public void start() throws Exception 228 { 229 delegate.start(); 230 } 231 232 235 public void stop() 236 { 237 delegate.stop(); 238 } 239 240 public void setMessageCounterHistoryDayLimit(int arg0) 241 { 242 } 244 245 public ObjectName getExpiryDestination() 246 { 247 return null; 248 } 249 public void setExpiryDestination(ObjectName destination) 250 { 251 System.err.println("There is no ExpiryDestination currently"); 252 } 253 254 public String toString() 255 { 256 return delegate.toString(); 257 } 258 259 public void postDeregister() 260 { 261 delegate.postDeregister(); 262 } 263 public void postRegister(Boolean registrationDone) 264 { 265 delegate.postRegister(registrationDone); 266 } 267 public void preDeregister() throws Exception 268 { 269 delegate.preDeregister(); 270 } 271 public ObjectName preRegister(MBeanServer server, ObjectName name) 272 throws Exception 273 { 274 return delegate.preRegister(server, name); 275 } 276 } 277 | Popular Tags |