ARTEMIS-2659 Fixing auto created queues leading to journal errors

This was causing the queue to be removed right before the server being stopped, leading to exceptions about the journal being stopped.
This commit is contained in:
Clebert Suconic 2020-04-08 12:42:36 -04:00
parent f78fe47548
commit ee29b4be10
2 changed files with 0 additions and 11 deletions

View File

@ -86,10 +86,6 @@ public class AmqpLargeMessageTest extends AmqpClientTestSupport {
params.put("maxFrameSize", FRAME_SIZE);
}
@Override
protected void createAddressAndQueues(ActiveMQServer server) throws Exception {
}
@Override
protected void addAdditionalAcceptors(ActiveMQServer server) throws Exception {
server.getConfiguration().addAcceptorConfiguration("tcp", "tcp://localhost:61616");

View File

@ -39,7 +39,6 @@ import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.IntStream;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.utils.Wait;
import org.apache.qpid.jms.JmsConnectionFactory;
import org.junit.Test;
@ -48,12 +47,6 @@ import static org.hamcrest.CoreMatchers.is;
public class TopicDurableTests extends JMSClientTestSupport {
@Override
protected void createAddressAndQueues(ActiveMQServer server) throws Exception {
// do not create unnecessary queues
}
@Test
public void testMessageDurableSubscription() throws Exception {
JmsConnectionFactory connectionFactory = new JmsConnectionFactory(getBrokerQpidJMSConnectionURI() + "?jms.clientID=jmsTopicClient");