Skip to content

Commit

Permalink
ARTEMIS-4346: move stomp test client to artemis-test-support systest …
Browse files Browse the repository at this point in the history
…helper module
  • Loading branch information
gemmellr authored and jbertram committed Jul 5, 2023
1 parent cb9e1fe commit 5b86f8d
Show file tree
Hide file tree
Showing 17 changed files with 7 additions and 5 deletions.
7 changes: 7 additions & 0 deletions tests/artemis-test-support/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,13 @@
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>artemis-stomp-protocol</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<!-- This should be the only dependency not at 'provided' scope, for now -->
<dependency>
<groupId>org.apache.activemq</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import org.apache.activemq.artemis.core.protocol.stomp.Stomp;
import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.artemis.utils.collections.ConcurrentHashSet;
import org.apache.activemq.transport.netty.NettyTransport;
import org.apache.activemq.transport.netty.NettyTransportFactory;
Expand Down Expand Up @@ -91,8 +90,6 @@ public AbstractStompClientConnection(URI uri) throws Exception {
transport.setTransportListener(new StompTransportListener());
transport.connect();

Wait.waitFor(() -> transport.isConnected(), 1000);

if (!transport.isConnected()) {
throw new RuntimeException("Could not connect transport");
}
Expand All @@ -112,8 +109,6 @@ public AbstractStompClientConnection(URI uri, boolean autoConnect) throws Except
if (autoConnect) {
transport.connect();

Wait.waitFor(() -> transport.isConnected(), 1000);

if (!transport.isConnected()) {
throw new RuntimeException("Could not connect transport");
}
Expand Down

0 comments on commit 5b86f8d

Please sign in to comment.