|
1
22 package org.jboss.mq.server.jmx;
23
24 import java.util.Hashtable  ;
25 import java.util.List ;
26
27 import javax.jms.InvalidSelectorException ;
28 import javax.management.MBeanRegistration ;
29 import javax.management.MBeanServer ;
30 import javax.management.ObjectName ;
31
32 import org.w3c.dom.Element ;
33
34
41 public class Topic
42 implements MBeanRegistration , TopicMBean
43 {
44 private org.jboss.jms.server.destination.Topic delegate;
45
46 public Topic()
47 {
48 delegate = new org.jboss.jms.server.destination.Topic();
49 }
50 public Topic(boolean createProgramatically)
51 {
52 delegate = new org.jboss.jms.server.destination.Topic(createProgramatically);
53 }
54
55
58 public void create() throws Exception
59 {
60 delegate.create();
61 }
62
63
66 public void destroy()
67 {
68 delegate.destroy();
69 }
70
71
74 public int getDownCacheSize()
75 {
76 return delegate.getDownCacheSize();
77 }
78
79
82 public int getFullSize()
83 {
84 return delegate.getFullSize();
85 }
86
87
90 public String getJNDIName()
91 {
92 return delegate.getJNDIName();
93 }
94
95
98 public List getMessagesFromNonDurableSub(org.jboss.messaging.core.local.Topic arg0,
99 long arg1, String arg2) throws InvalidSelectorException
100 {
101 return delegate.getMessagesFromNonDurableSub(arg0, arg1, arg2);
102 }
103
104
107 public String getName()
108 {
109 return delegate.getName();
110 }
111
112
115 public int getPageSize()
116 {
117 return delegate.getPageSize();
118 }
119
120
123 public MBeanServer getServer()
124 {
125 return delegate.getServer();
126 }
127
128
131 public ObjectName getServerPeer()
132 {
133 return delegate.getServerPeer();
134 }
135
136
139 public boolean isCreatedProgrammatically()
140 {
141 return delegate.isCreatedProgrammatically();
142 }
143
144
147 public List listMessagesDurableSub(String arg0, String arg1, String arg2) throws Exception
148 {
149 return delegate.listMessagesDurableSub(arg0, arg1, arg2);
150 }
151
152
155 public List listMessagesNonDurableSub(long arg0, String arg1) throws Exception
156 {
157 return delegate.listMessagesNonDurableSub(arg0, arg1);
158 }
159
160
163 public String listSubscriptionsAsText() throws Exception
164 {
165 return delegate.listSubscriptionsAsText();
166 }
167
168
171 public String listSubscriptionsAsText(boolean arg0) throws Exception
172 {
173 return delegate.listSubscriptionsAsText(arg0);
174 }
175
176
179 public void removeAllMessages() throws Exception
180 {
181 delegate.removeAllMessages();
182 }
183
184
187 public void setDownCacheSize(int arg0)
188 {
189 delegate.setDownCacheSize(arg0);
190 }
191
192
195 public void setFullSize(int arg0)
196 {
197 delegate.setFullSize(arg0);
198 }
199
200
203 public void setJNDIName(String arg0)
204 {
205 delegate.setJNDIName(arg0);
206 }
207
208
211 public void setPageSize(int arg0)
212 {
213 delegate.setPageSize(arg0);
214 }
215
216
219 public void setSecurityConfig(Element arg0) throws Exception
220 {
221 delegate.setSecurityConfig(arg0);
222 }
223
226 public void setSecurityConf(Element arg0) throws Exception
227 {
228 delegate.setSecurityConfig(arg0);
229 }
230
231
234 public void setSecurityManager(ObjectName arg0)
235 {
236 }
238
239
242 public void setServerPeer(ObjectName arg0)
243 {
244 delegate.setServerPeer(arg0);
245 }
246
249 public void setDestinationManager(ObjectName arg0) throws Exception
250 {
251 ObjectName peer = new ObjectName ("jboss.messaging:service=ServerPeer");
252 delegate.setServerPeer(peer);
253 }
254
255
258 public void start() throws Exception
259 {
260 delegate.start();
261 }
262
263
266 public void stop()
267 {
268 delegate.stop();
269 }
270
271
274 public int subscriptionCount() throws Exception
275 {
276 return delegate.subscriptionCount();
277 }
278
279
282 public int subscriptionCount(boolean arg0) throws Exception
283 {
284 return delegate.subscriptionCount(arg0);
285 }
286
287 public ObjectName getExpiryDestination()
288 {
289 return null;
290 }
291 public void setExpiryDestination(ObjectName destination)
292 {
293 System.err.println("There is no ExpiryDestination currently");
294 }
295
296 public String toString()
297 {
298 return delegate.toString();
299 }
300
301 public void postDeregister()
302 {
303 delegate.postDeregister();
304 }
305 public void postRegister(Boolean registrationDone)
306 {
307 delegate.postRegister(registrationDone);
308 }
309 public void preDeregister() throws Exception
310 {
311 delegate.preDeregister();
312 }
313 public ObjectName preRegister(MBeanServer server, ObjectName name)
314 throws Exception
315 {
316 return delegate.preRegister(server, name);
317 }
318 }
319 |
Popular Tags |
Java API By Example, From Geeks To Geeks.