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 #3150

This commit is contained in:
Clebert Suconic 2020-05-28 16:38:26 -04:00
parent 30f1329edb 0443128b81
commit 8921bd4bbb
2 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java
View File

@ -1041,7 +1041,7 @@ public class ServerSessionImpl implements ServerSession, FailureListener {
server.checkQueueCreationLimit(getUsername()); server.checkQueueCreationLimit(getUsername());
server.createSharedQueue(queueConfiguration); server.createSharedQueue(queueConfiguration.setUser(getUsername()));
} }
@Deprecated @Deprecated

18
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/jms2client/SharedConsumerTest.java
View File

@ -25,6 +25,7 @@ import java.util.Random;
import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.postoffice.Binding; import org.apache.activemq.artemis.core.postoffice.Binding;
import org.apache.activemq.artemis.core.postoffice.impl.LocalQueueBinding;
import org.apache.activemq.artemis.tests.util.JMSTestBase; import org.apache.activemq.artemis.tests.util.JMSTestBase;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -68,6 +69,23 @@ public class SharedConsumerTest extends JMSTestBase {
} }
} }
@Test
public void sharedDurableSubUser() throws Exception {
try (JMSContext context = cf.createContext("foo", "bar")) {
context.createSharedDurableConsumer(topic1, "mySharedCon");
boolean found = false;
for (Binding binding : server.getPostOffice().getBindingsForAddress(SimpleString.toSimpleString(topic1.getTopicName())).getBindings()) {
found = true;
assertTrue(binding instanceof LocalQueueBinding);
assertEquals("mySharedCon", ((LocalQueueBinding)binding).getQueue().getName().toString());
assertNotNull(((LocalQueueBinding)binding).getQueue().getUser());
assertEquals("foo", ((LocalQueueBinding)binding).getQueue().getUser().toString());
}
assertTrue(found);
}
}
@Test @Test
public void sharedDurableUnsubscribeNewTopic() throws Exception { public void sharedDurableUnsubscribeNewTopic() throws Exception {
context = cf.createContext(); context = cf.createContext();