1 21 package com.presumo.jms.client; 22 23 import javax.jms.JMSException ; 24 import javax.jms.QueueConnection ; 25 import javax.jms.QueueSession ; 26 import javax.jms.ConnectionConsumer ; 27 import javax.jms.ServerSessionPool ; 28 import javax.jms.Queue ; 29 import javax.jms.Session ; 30 31 import com.presumo.jms.resources.Resources; 32 import com.presumo.jms.router.Router; 33 import com.presumo.util.log.Logger; 34 import com.presumo.util.log.LoggerFactory; 35 36 39 public class JmsQueueConnection 40 extends JmsConnection implements QueueConnection 41 { 42 43 47 public JmsQueueConnection(Router router) 48 { 49 super(router); 50 } 51 52 public JmsQueueConnection(Router router, String host, int port) 53 throws JMSException 54 { 55 super(router, host, port); 56 } 57 58 62 public synchronized QueueSession 63 createQueueSession(boolean transacted, int acknowledgeMode) 64 throws JMSException 65 { 66 logger.entry("createQueueSession"); 67 68 return null; 80 } 81 82 83 86 public ConnectionConsumer createConnectionConsumer(Queue topic, 87 String messageSelector, 88 ServerSessionPool sessionPool, 89 int maxMessages) 90 throws JMSException 91 { 92 throw new IllegalStateException ("Operation not permited"); 93 } 94 95 96 private static Logger logger = 98 LoggerFactory.getLogger(JmsQueueConnection.class, Resources.getBundle()); 99 101 } 102 103 104 105 | Popular Tags |