|
1
45 package org.exolab.jms.server.net;
46
47 import java.rmi.RemoteException  ;
48 import java.util.Vector ;
49
50 import org.exolab.jms.net.orb.ORB;
51 import org.exolab.jms.net.orb.UnicastObject;
52 import org.exolab.jms.server.AdminConnection;
53 import org.exolab.jms.server.AdminConnection;
54
55
56
64 public class JmsAdminConnectionImpl
65 extends UnicastObject
66 implements RemoteJmsAdminConnectionIfc {
67
68
71 protected AdminConnection _connection;
72
73
80 protected JmsAdminConnectionImpl(AdminConnection connection, ORB orb)
81 throws RemoteException {
82 super(orb, null, true);
83 if (connection == null) {
84 throw new IllegalArgumentException ("Argument connection is null");
85 }
86
87 _connection = connection;
88 }
89
90 public boolean addDurableConsumer(String topic, String name)
92 throws RemoteException {
93 return _connection.addDurableConsumer(topic, name);
94 }
95
96 public boolean removeDurableConsumer(String name)
98 throws RemoteException {
99 return _connection.removeDurableConsumer(name);
100 }
101
102 public boolean durableConsumerExists(String name)
104 throws RemoteException {
105 return _connection.durableConsumerExists(name);
106 }
107
108
109 public boolean unregisterConsumer(String name)
111 throws RemoteException {
112 return _connection.unregisterConsumer(name);
113 }
114
115 public boolean isConnected(String name)
117 throws RemoteException {
118 return _connection.isConnected(name);
119 }
120
121 public Vector getAllDestinations()
123 throws RemoteException {
124 return _connection.getAllDestinations();
125 }
126
127 public boolean addDestination(String destination, Boolean queue)
129 throws RemoteException {
130 return _connection.addDestination(destination, queue);
131 }
132
133 public int getDurableConsumerMessageCount(String topic, String name)
135 throws RemoteException {
136 return _connection.getDurableConsumerMessageCount(topic, name);
137 }
138
139 public int getQueueMessageCount(String queue)
141 throws RemoteException {
142 return _connection.getQueueMessageCount(queue);
143 }
144
145 public Vector getDurableConsumers(String topic)
147 throws RemoteException {
148 return _connection.getDurableConsumers(topic);
149 }
150
151 public boolean removeDestination(String name)
153 throws RemoteException {
154 return _connection.removeDestination(name);
155 }
156
157 public boolean destinationExists(String name)
159 throws RemoteException {
160 return _connection.destinationExists(name);
161 }
162
163 public int purgeMessages()
165 throws RemoteException {
166 return _connection.purgeMessages();
167 }
168
169 public void stopServer()
171 throws RemoteException {
172 _connection.stopServer();
173 }
174
175 public boolean addUser(String username, String password)
177 throws RemoteException {
178 return _connection.addUser(username, password);
179 }
180
181 public boolean changePassword(String username, String password)
183 throws RemoteException {
184 return _connection.changePassword(username, password);
185 }
186
187 public boolean removeUser(String username) throws RemoteException {
189 return _connection.removeUser(username);
190 }
191
192 public Vector getAllUsers() throws RemoteException {
194 return _connection.getAllUsers();
195 }
196
197 }
198
199
200
201 |
Popular Tags |
Java API By Example, From Geeks To Geeks.