@TestPropertySource(properties = { //
"server.ssl.key-store=./config/keystore.jks", //
"app.webclient.trust-store=./config/truststore.jks", //
@TestPropertySource(properties = { //
"server.ssl.key-store=./config/keystore.jks", //
"app.webclient.trust-store=./config/truststore.jks", //
"app.configuration-filepath=./src/test/resources/test_application_configuration.json", //
"app.ecs-base-url=https://localhost:8434" //
})
class IntegrationWithEcs {
"app.configuration-filepath=./src/test/resources/test_application_configuration.json", //
"app.ecs-base-url=https://localhost:8434" //
})
class IntegrationWithEcs {
- private void createInformationJobInEcs() {
- String url = ecsBaseUrl() + "/data-consumer/v1/info-jobs/jobId";
+ private String jobUrl(String jobId) {
+ return ecsBaseUrl() + "/data-consumer/v1/info-jobs/" + jobId;
+ }
+
+ private void createInformationJobInEcs(String jobId) {
- restClient().putForEntity(url, body).block();
+ restClient().putForEntity(jobUrl(jobId), body).block();
+ }
+
+ private void deleteInformationJobInEcs(String jobId) {
+ restClient().delete(jobUrl(jobId)).block();
void testWholeChain() throws Exception {
await().untilAsserted(() -> assertThat(producerRegstrationTask.isRegisteredInEcs()).isTrue());
void testWholeChain() throws Exception {
await().untilAsserted(() -> assertThat(producerRegstrationTask.isRegisteredInEcs()).isTrue());
await().untilAsserted(() -> assertThat(results.receivedBodies.size()).isEqualTo(2));
assertThat(results.receivedBodies.get(0)).isEqualTo("DmaapResponse1");
await().untilAsserted(() -> assertThat(results.receivedBodies.size()).isEqualTo(2));
assertThat(results.receivedBodies.get(0)).isEqualTo("DmaapResponse1");
synchronized (this) {
// logger.warn("**************** Keeping server alive! " +
// this.applicationConfig.getLocalServerHttpPort());
synchronized (this) {
// logger.warn("**************** Keeping server alive! " +
// this.applicationConfig.getLocalServerHttpPort());