1 6 7 package org.jfox.jms.connector; 8 9 import javax.jms.Destination ; 10 import javax.jms.JMSException ; 11 import javax.jms.Queue ; 12 import javax.jms.TemporaryQueue ; 13 import javax.jms.TemporaryTopic ; 14 import javax.jms.Topic ; 15 16 import org.jfox.ioc.connector.Container; 17 import org.jfox.jms.message.JMSMessage; 18 19 24 25 public interface JMSContainer extends Container { 26 27 public boolean auth(String userName, String password) throws JMSException ; 28 29 public Queue createQueue(java.lang.String queueName) throws JMSException ; 30 31 public Topic createTopic(String topicName) throws JMSException ; 32 33 public TemporaryQueue createTemporaryQueue() throws JMSException ; 34 35 public TemporaryTopic createTemporaryTopic() throws JMSException ; 36 37 public void registerConnection(String clientId, Object conn) throws JMSException ; 38 39 public void unregisterConnection(String clientId) throws JMSException ; 40 41 public boolean isConnectionRegistered(String clientId); 42 43 50 public void registerSession(String connectionId, String sessionId) throws JMSException ; 51 52 public void sendMessage(JMSMessage msg) throws JMSException ; 53 54 public void sendMessageBatch(JMSMessage[] messages) throws JMSException ; 55 56 public JMSMessage receiveMessage(String clientId, String sessionId, String consumerId, long timeout) throws JMSException ; 57 58 public void registerConsumer(String connectionId, 59 String sessionId, 60 String consumerId, 61 Destination destination) throws JMSException ; 62 63 public void setConsumerAsync(String clientId, 64 String sessionId, 65 String consumerId, 66 boolean async) throws JMSException ; 67 68 public void startConnection(String clientId) throws JMSException ; 69 70 public void stopConnection(String clientId) throws JMSException ; 71 72 public void acknowledge(String clientId, String sessionId, String consumerId, String messageId) throws JMSException ; 73 74 public void closeSession(String clientId, String sessionId) throws JMSException ; 75 } 76 | Popular Tags |