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

NO-JIRA fix errant test directory

This commit is contained in:
Justin Bertram 2020-03-09 09:18:33 -05:00
parent a60cb229dc
commit ec958d7d27
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompWebSocketTest.java
View File

@ -28,11 +28,10 @@ import org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory
import org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants; import org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants;
import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.ActiveMQServers; import org.apache.activemq.artemis.core.server.ActiveMQServers;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
public class StompWebSocketTest extends ActiveMQTestBase { public class StompWebSocketTest extends StompTestBase {
private ActiveMQServer server; private ActiveMQServer server;
@ -59,19 +58,27 @@ public class StompWebSocketTest extends ActiveMQTestBase {
* @return * @return
* @throws Exception * @throws Exception
*/ */
private ActiveMQServer createServer() throws Exception { @Override
protected ActiveMQServer createServer() throws Exception {
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();
params.put(TransportConstants.PROTOCOLS_PROP_NAME, StompProtocolManagerFactory.STOMP_PROTOCOL_NAME); params.put(TransportConstants.PROTOCOLS_PROP_NAME, StompProtocolManagerFactory.STOMP_PROTOCOL_NAME);
params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_STOMP_PORT + 1); params.put(TransportConstants.PORT_PROP_NAME, TransportConstants.DEFAULT_STOMP_PORT + 1);
TransportConfiguration stompTransport = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params); TransportConfiguration stompTransport = new TransportConfiguration(NettyAcceptorFactory.class.getName(), params);
Configuration config = createBasicConfig().addAcceptorConfiguration(stompTransport).addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName())).addQueueConfiguration(new CoreQueueConfiguration().setAddress(getQueueName()).setName(getQueueName()).setDurable(false)); Configuration config = createBasicConfig()
.addAcceptorConfiguration(stompTransport)
.addAcceptorConfiguration(new TransportConfiguration(InVMAcceptorFactory.class.getName()))
.setPersistenceEnabled(isPersistenceEnabled())
.addQueueConfiguration(new CoreQueueConfiguration()
.setAddress(getQueueName())
.setName(getQueueName())
.setDurable(false));
server = addServer(ActiveMQServers.newActiveMQServer(config)); server = addServer(ActiveMQServers.newActiveMQServer(config));
return server; return server;
} }
protected String getQueueName() { protected static String getQueueName() {
return "/queue/test"; return "/queue/test";
} }
} }