Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1323

This commit is contained in:
Clebert Suconic 2017-06-07 10:18:16 -04:00
parent dc9cee2f79 e8fa02bf80
commit 9d5d2d5344
2 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQConnection.java
View File

@ -267,8 +267,6 @@ public class ActiveMQConnection extends ActiveMQConnectionForContextImpl impleme
public ConnectionMetaData getMetaData() throws JMSException { public ConnectionMetaData getMetaData() throws JMSException {
checkClosed(); checkClosed();
justCreated = false;
if (metaData == null) { if (metaData == null) {
metaData = new ActiveMQConnectionMetaData(thisVersion); metaData = new ActiveMQConnectionMetaData(thisVersion);
} }
@ -323,7 +321,6 @@ public class ActiveMQConnection extends ActiveMQConnectionForContextImpl impleme
session.stop(); session.stop();
} }
justCreated = false;
started = false; started = false;
} }

17
tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/ConnectionTest.java
View File

@ -97,6 +97,15 @@ public class ConnectionTest extends JMSTestCase {
connection2.setClientID(clientID); connection2.setClientID(clientID);
} }
@Test
public void testSetClientIdAfterStop() throws Exception {
try (Connection connection = createConnection()) {
connection.stop();
connection.setClientID("clientId");
}
}
@Test @Test
public void testSetClientAfterStart() throws Exception { public void testSetClientAfterStart() throws Exception {
Connection connection = null; Connection connection = null;
@ -174,6 +183,14 @@ public class ConnectionTest extends JMSTestCase {
connection.close(); connection.close();
} }
@Test
public void testSetClientIdAfterGetMetadata() throws Exception {
try (Connection connection = createConnection()) {
connection.getMetaData();
connection.setClientID("clientId");
}
}
/** /**
* Test creation of QueueSession * Test creation of QueueSession
*/ */