@Test public void testSendToQueueFailsIfNotAnonymousPublisher() throws JMSException { JmsPoolConnection connection = (JmsPoolConnection) cf.createTopicConnection(); QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); Queue queue = session.createTemporaryQueue(); QueueSender sender = session.createSender(queue); try { sender.send(session.createTemporaryQueue(), session.createTextMessage()); fail("Should not be able to send to alternate destination"); } catch (UnsupportedOperationException ex) {} }
@Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException { super.send(queue, message, deliveryMode, priority, timeToLine); }
JmsPoolQueueSender extends JmsPoolMessageProducer implements QueueSender, AutoCloseable { @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException { super.send(queue, message, deliveryMode, priority, timeToLine); } }
JmsPoolQueueSender extends JmsPoolMessageProducer implements QueueSender, AutoCloseable { @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException { super.send(queue, message, deliveryMode, priority, timeToLine); } JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount); }
JmsPoolQueueSender extends JmsPoolMessageProducer implements QueueSender, AutoCloseable { @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException { super.send(queue, message, deliveryMode, priority, timeToLine); } JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount); @Override void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine); @Override void send(Queue queue, Message message); @Override Queue getQueue(); @Override String toString(); QueueSender getQueueSender(); }
JmsPoolQueueSender extends JmsPoolMessageProducer implements QueueSender, AutoCloseable { @Override public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine) throws JMSException { super.send(queue, message, deliveryMode, priority, timeToLine); } JmsPoolQueueSender(JmsPoolSession session, QueueSender messageProducer, Destination destination, AtomicInteger refCount); @Override void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLine); @Override void send(Queue queue, Message message); @Override Queue getQueue(); @Override String toString(); QueueSender getQueueSender();  }