Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-21 01:15:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-510 create queue only on route

Browse Source
This commit is contained in:
jbertram 2016-04-29 12:04:14 -05:00 committed by Andy Taylor
parent 882b8edbd8
commit d1a687a98f
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
View File

@ -298,13 +298,8 @@ public class ActiveMQSession implements QueueSession, TopicSession {
if (jbd != null) {
ClientSession.AddressQuery response = session.addressQuery(jbd.getSimpleAddress());
if (!response.isExists()) {
if (response.isAutoCreateJmsQueues()) {
session.createQueue(jbd.getSimpleAddress(), jbd.getSimpleAddress(), true);
}
else {
throw new InvalidDestinationException("Destination " + jbd.getName() + " does not exist");
}
if (!response.isExists() && !response.isAutoCreateJmsQueues()) {
throw new InvalidDestinationException("Destination " + jbd.getName() + " does not exist");
}
connection.addKnownDestination(jbd.getSimpleAddress());

9
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/AutoCreateJmsQueueTest.java
View File

@ -66,6 +66,9 @@ public class AutoCreateJmsQueueTest extends JMSTestBase {
}
connection.close();
// make sure the JMX control was created for the JMS queue
assertNotNull(server.getManagementService().getResource("jms.queue.test"));
}
@Test
@ -110,10 +113,12 @@ public class AutoCreateJmsQueueTest extends JMSTestBase {
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
javax.jms.Queue queue = ActiveMQJMSClient.createQueue("test");
MessageProducer producer = session.createProducer(queue);
TextMessage mess = session.createTextMessage("msg");
try {
MessageProducer producer = session.createProducer(queue);
Assert.fail("Creating a producer here should throw a JMSSecurityException");
producer.send(mess);
Assert.fail("Sending a message here should throw a JMSSecurityException");
}
catch (Exception e) {
Assert.assertTrue(e instanceof JMSSecurityException);