humidity demo
This commit is contained in:
@@ -28,6 +28,9 @@ public class PublishNewTaskEventAdapter implements NewTaskEventPort {
|
||||
@Value("${executor.humidity.uri}")
|
||||
private String server3;
|
||||
|
||||
@Value("${executor.humidity.demo.uri}")
|
||||
private String server4;
|
||||
|
||||
Logger logger = Logger.getLogger(PublishNewTaskEventAdapter.class.getName());
|
||||
|
||||
/**
|
||||
@@ -84,6 +87,22 @@ public class PublishNewTaskEventAdapter implements NewTaskEventPort {
|
||||
} catch (IOException e) {
|
||||
logger.log(Level.SEVERE, e.getLocalizedMessage(), e);
|
||||
}
|
||||
|
||||
HttpClient client4 = HttpClient.newHttpClient();
|
||||
HttpRequest request4 = HttpRequest.newBuilder()
|
||||
.uri(URI.create(server4 + "/newtask/" + event.taskType.getValue()))
|
||||
.GET()
|
||||
.build();
|
||||
|
||||
|
||||
try {
|
||||
client4.send(request4, HttpResponse.BodyHandlers.ofString());
|
||||
} catch (InterruptedException e) {
|
||||
logger.log(Level.SEVERE, e.getLocalizedMessage(), e);
|
||||
Thread.currentThread().interrupt();
|
||||
} catch (IOException e) {
|
||||
logger.log(Level.SEVERE, e.getLocalizedMessage(), e);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
@@ -2,6 +2,7 @@ server.port=8082
|
||||
executor.robot.uri=http://127.0.0.1:8084
|
||||
executor.computation.uri=http://127.0.0.1:8085
|
||||
executor.humidity.uri=http://127.0.0.1:8087
|
||||
executor.humidity.demo.uri=http://127.0.0.1:8088
|
||||
auction.house.uri=http://127.0.0.1:8086
|
||||
task.list.uri=http://127.0.0.1:8081
|
||||
# mqtt.broker.uri=tcp://localhost:1883
|
||||
|
Reference in New Issue
Block a user