1 22 package org.jboss.mq.il; 23 import javax.jms.Destination ; 24 import javax.jms.Queue ; 25 import javax.jms.TemporaryQueue ; 26 import javax.jms.TemporaryTopic ; 27 import javax.jms.Topic ; 28 29 import org.jboss.mq.AcknowledgementRequest; 30 import org.jboss.mq.ConnectionToken; 31 import org.jboss.mq.DurableSubscriptionID; 32 import org.jboss.mq.SpyDestination; 33 import org.jboss.mq.SpyMessage; 34 import org.jboss.mq.TransactionRequest; 35 36 45 public interface ServerIL 46 { 47 48 54 public ServerIL cloneServerIL() throws Exception ; 55 56 60 void setConnectionToken(org.jboss.mq.ConnectionToken newConnectionToken) throws java.lang.Exception ; 61 68 public String getID() 69 throws Exception ; 70 71 78 public TemporaryTopic getTemporaryTopic(ConnectionToken dc) 79 throws Exception ; 80 81 88 public TemporaryQueue getTemporaryQueue(ConnectionToken dc) 89 throws Exception ; 90 91 97 public void connectionClosing(ConnectionToken dc) 98 throws Exception ; 99 100 110 public void checkID(String ID) 111 throws Exception ; 112 113 120 public void addMessage(ConnectionToken dc, SpyMessage message) 121 throws Exception ; 122 123 131 public Queue createQueue(ConnectionToken dc, String dest) 132 throws Exception ; 133 134 142 public Topic createTopic(ConnectionToken dc, String dest) 143 throws Exception ; 144 145 152 public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) 153 throws Exception ; 154 155 162 public void transact(ConnectionToken dc, TransactionRequest t) 163 throws Exception ; 164 165 172 public void acknowledge(ConnectionToken dc, AcknowledgementRequest item) 173 throws Exception ; 174 175 184 public SpyMessage[] browse(ConnectionToken dc, Destination dest, String selector) 185 throws Exception ; 186 187 196 public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait) 197 throws Exception ; 198 199 206 public void setEnabled(ConnectionToken dc, boolean enabled) 207 throws Exception ; 208 209 216 public void unsubscribe(ConnectionToken dc, int subscriptionId) 217 throws Exception ; 218 219 225 public void destroySubscription(ConnectionToken dc,DurableSubscriptionID id) 226 throws Exception ; 227 228 239 public String checkUser(String userName, String password) 240 throws Exception ; 241 242 252 public String authenticate(String userName, String password) 253 throws Exception ; 254 255 256 257 262 void subscribe(org.jboss.mq.ConnectionToken dc, org.jboss.mq.Subscription s) 263 throws java.lang.Exception ; 264 265 272 public void ping(ConnectionToken dc, long clientTime) 273 throws Exception ; 274 275 } | Popular Tags |