From dffd126edb5f164e8365a6208e74b55c92c2ba39 Mon Sep 17 00:00:00 2001 From: Dimitris Kalathas Date: Sun, 26 Feb 2023 15:23:25 +0200 Subject: [PATCH 1/2] nothing --- .../com/jss/camel/components/rest/RestDsl.java | 17 ++++++++++++++--- .../routes/AddRoutesAtRuntimeTest.java | 6 +++--- 2 files changed, 17 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/jss/camel/components/rest/RestDsl.java b/src/main/java/com/jss/camel/components/rest/RestDsl.java index 11f9f04..9c65d23 100644 --- a/src/main/java/com/jss/camel/components/rest/RestDsl.java +++ b/src/main/java/com/jss/camel/components/rest/RestDsl.java @@ -32,13 +32,24 @@ public void configure() throws Exception { rest("/api") .consumes("application/json").produces("application/json") - .post("/connection").type(ConnectionDto.class).to("direct:make-connection"); + .post("/connection").type(ConnectionDto.class).to("direct:make-connection") + .delete("/delete").to("direct:delete-connection"); from("direct:make-connection") .process(this::makeConnection); + + from("direct:delete-connection") + .process(this::makeDelete); } + public void makeDelete(Exchange exchange) throws Exception { + System.out.println(getContext().getRoutes()); + getContext().removeRoute("myRoute"); + + } + + public void makeConnection(Exchange exchange) throws Exception { ConnectionDto dto = exchange.getMessage().getBody(ConnectionDto.class); connectionProvider.setCurrentConnection(dto); @@ -48,10 +59,10 @@ public void makeConnection(Exchange exchange) throws Exception { System.out.println(myConnection.toString()); String rabbit_uri = String.format("rabbitmq:%s?hostname=%s&portNumber=%s&username=%s&password=%s&queue=%s&routingKey=%s&autoDelete=false", - dto.getRabbitExchange(), dto.getRabbitHost(), dto.getRabbitPort(), dto.getUsername(), dto.getPassword(), dto.getQueue(), dto.getRouting_key()); + dto.getRabbitExchange(), dto.getRabbitHost(), dto.getRabbitPort(), dto.getUsername(), dto.getPassword(), dto.getQueue(), dto.getRouting_key()); String mosquitto_uri = String.format("paho:%s?brokerUrl=tcp://%s:%s", - dto.getTopic(), dto.getMosquittoHost(), dto.getMosquittoPort()); + dto.getTopic(), dto.getMosquittoHost(), dto.getMosquittoPort()); CamelContext context = getContext(); context.addRoutes(new AddRoutesAtRuntimeTest.MyDynamcRouteBuilder(context, rabbit_uri, mosquitto_uri)); diff --git a/src/main/java/com/jss/camel/components/routes/AddRoutesAtRuntimeTest.java b/src/main/java/com/jss/camel/components/routes/AddRoutesAtRuntimeTest.java index 690aca1..69e651a 100644 --- a/src/main/java/com/jss/camel/components/routes/AddRoutesAtRuntimeTest.java +++ b/src/main/java/com/jss/camel/components/routes/AddRoutesAtRuntimeTest.java @@ -38,12 +38,12 @@ public MyDynamcRouteBuilder(CamelContext context, String from, String to) { @Override public void configure() throws Exception { from(from) - //.log(LoggingLevel.ERROR, "Before Enrichment: ${body}") .unmarshal().json(JsonLibrary.Jackson, SensorDto.class) .process(this::enrichSensorDto) - //.log(LoggingLevel.ERROR, "After Enrichment: ${body}") + .routeId("myRoute") .marshal().json(JsonLibrary.Jackson, SensorDto.class) - .to(to); + .to(to) + .end(); } private void enrichSensorDto(Exchange exchange) { From fd8291a36104f9135f88db4ed2e8a51a4ec3801a Mon Sep 17 00:00:00 2001 From: Dimitris Kalathas Date: Sun, 26 Feb 2023 15:31:30 +0200 Subject: [PATCH 2/2] nothing --- src/main/java/com/jss/camel/components/rest/RestDsl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/jss/camel/components/rest/RestDsl.java b/src/main/java/com/jss/camel/components/rest/RestDsl.java index 9c65d23..f6a7a25 100644 --- a/src/main/java/com/jss/camel/components/rest/RestDsl.java +++ b/src/main/java/com/jss/camel/components/rest/RestDsl.java @@ -9,6 +9,7 @@ import java.util.Objects; +import static com.jss.config.CamelConfiguration.RABBIT_URI; import static org.apache.camel.Exchange.HTTP_RESPONSE_CODE; import static org.springframework.http.HttpStatus.NOT_FOUND; @@ -37,7 +38,9 @@ public void configure() throws Exception { from("direct:make-connection") - .process(this::makeConnection); + .toF(RABBIT_URI,"no","no"); + fromF(RABBIT_URI,"no","no") + .to() from("direct:delete-connection") .process(this::makeDelete);