@Test(timeout = 10000) public void testExplicitProducerThrowsIAEWhenNullCompletionListenerIsProvided() throws Exception { Destination dest = new MockJMSQueue("explicitDestination"); JmsPoolConnection connection = (JmsPoolConnection) cf.createQueueConnection(); Session session = connection.createSession(); MessageProducer producer = session.createProducer(dest); Message message = session.createMessage(); try { producer.send(message, null); fail("Expected exception not thrown"); } catch (IllegalArgumentException iae) { } try { producer.send(message, Message.DEFAULT_DELIVERY_MODE, Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE, null); fail("Expected exception not thrown"); } catch (IllegalArgumentException iae) { } }
@Override public void send(Message message) throws JMSException { send(message, deliveryMode, priority, timeToLive); }
JmsPoolMessageProducer implements MessageProducer, AutoCloseable { @Override public void send(Message message) throws JMSException { send(message, deliveryMode, priority, timeToLive); } }
JmsPoolMessageProducer implements MessageProducer, AutoCloseable { @Override public void send(Message message) throws JMSException { send(message, deliveryMode, priority, timeToLive); } JmsPoolMessageProducer(JmsPoolSession session, MessageProducer messageProducer, Destination destination, AtomicInteger refCount); }
JmsPoolMessageProducer implements MessageProducer, AutoCloseable { @Override public void send(Message message) throws JMSException { send(message, deliveryMode, priority, timeToLive); } JmsPoolMessageProducer(JmsPoolSession session, MessageProducer messageProducer, Destination destination, AtomicInteger refCount); @Override void close(); @Override void send(Message message); @Override void send(Message message, int deliveryMode, int priority, long timeToLive); @Override void send(Destination destination, Message message); @Override void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive); @Override void send(Message message, CompletionListener listener); @Override void send(Message message, int deliveryMode, int priority, long timeToLive, CompletionListener listener); @Override void send(Destination destination, Message message, CompletionListener listener); @Override void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, CompletionListener listener); @Override Destination getDestination(); @Override int getDeliveryMode(); @Override void setDeliveryMode(int deliveryMode); @Override boolean getDisableMessageID(); @Override void setDisableMessageID(boolean disableMessageID); @Override boolean getDisableMessageTimestamp(); @Override void setDisableMessageTimestamp(boolean disableMessageTimestamp); @Override int getPriority(); @Override void setPriority(int priority); @Override long getTimeToLive(); @Override void setTimeToLive(long timeToLive); @Override long getDeliveryDelay(); @Override void setDeliveryDelay(long deliveryDelay); @Override String toString(); MessageProducer getMessageProducer(); boolean isAnonymousProducer(); AtomicInteger getRefCount(); MessageProducer getDelegate(); Destination getDelegateDestination(); }
JmsPoolMessageProducer implements MessageProducer, AutoCloseable { @Override public void send(Message message) throws JMSException { send(message, deliveryMode, priority, timeToLive); } JmsPoolMessageProducer(JmsPoolSession session, MessageProducer messageProducer, Destination destination, AtomicInteger refCount); @Override void close(); @Override void send(Message message); @Override void send(Message message, int deliveryMode, int priority, long timeToLive); @Override void send(Destination destination, Message message); @Override void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive); @Override void send(Message message, CompletionListener listener); @Override void send(Message message, int deliveryMode, int priority, long timeToLive, CompletionListener listener); @Override void send(Destination destination, Message message, CompletionListener listener); @Override void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, CompletionListener listener); @Override Destination getDestination(); @Override int getDeliveryMode(); @Override void setDeliveryMode(int deliveryMode); @Override boolean getDisableMessageID(); @Override void setDisableMessageID(boolean disableMessageID); @Override boolean getDisableMessageTimestamp(); @Override void setDisableMessageTimestamp(boolean disableMessageTimestamp); @Override int getPriority(); @Override void setPriority(int priority); @Override long getTimeToLive(); @Override void setTimeToLive(long timeToLive); @Override long getDeliveryDelay(); @Override void setDeliveryDelay(long deliveryDelay); @Override String toString(); MessageProducer getMessageProducer(); boolean isAnonymousProducer(); AtomicInteger getRefCount(); MessageProducer getDelegate(); Destination getDelegateDestination();  }