forked from quarkusio/quarkus
-
Notifications
You must be signed in to change notification settings - Fork 3
/
ArtemisProducerTest.java
33 lines (27 loc) · 1.16 KB
/
ArtemisProducerTest.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package io.quarkus.it.artemis;
import javax.ws.rs.core.Response.Status;
import org.apache.activemq.artemis.api.core.client.ClientMessage;
import org.apache.activemq.artemis.api.core.client.ClientSession;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import io.quarkus.artemis.test.ArtemisTestResource;
import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.junit.QuarkusTest;
import io.restassured.RestAssured;
import io.restassured.response.Response;
@QuarkusTest
@QuarkusTestResource(ArtemisTestResource.class)
public class ArtemisProducerTest implements ArtemisHelper {
@Test
public void test() throws Exception {
String body = createBody();
Response response = RestAssured.with().body(body).post("/artemis");
Assertions.assertEquals(Status.NO_CONTENT.getStatusCode(), response.statusCode());
try (ClientSession session = createSession()) {
session.start();
ClientMessage message = session.createConsumer("test-core").receive(1000L);
message.acknowledge();
Assertions.assertEquals(body, message.getBodyBuffer().readString());
}
}
}