Merge pull request #67 from SCS-ASSE-FS21-Group1/renaming-executors
Renaming executors
This commit is contained in:
commit
33ab37c661
|
@ -9,9 +9,9 @@
|
||||||
<relativePath/> <!-- lookup parent from repository -->
|
<relativePath/> <!-- lookup parent from repository -->
|
||||||
</parent>
|
</parent>
|
||||||
<groupId>ch.unisg</groupId>
|
<groupId>ch.unisg</groupId>
|
||||||
<artifactId>executorbase</artifactId>
|
<artifactId>executor-base</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
<name>executorbase</name>
|
<name>executor-base</name>
|
||||||
<description>Demo project for Spring Boot</description>
|
<description>Demo project for Spring Boot</description>
|
||||||
<properties>
|
<properties>
|
||||||
<java.version>11</java.version>
|
<java.version>11</java.version>
|
||||||
|
|
|
@ -9,9 +9,9 @@
|
||||||
<relativePath/> <!-- lookup parent from repository -->
|
<relativePath/> <!-- lookup parent from repository -->
|
||||||
</parent>
|
</parent>
|
||||||
<groupId>ch.unisg</groupId>
|
<groupId>ch.unisg</groupId>
|
||||||
<artifactId>executorcomputation</artifactId>
|
<artifactId>executor-computation</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
<name>executorcomputation</name>
|
<name>executor-computation</name>
|
||||||
<description>Demo project for Spring Boot</description>
|
<description>Demo project for Spring Boot</description>
|
||||||
<properties>
|
<properties>
|
||||||
<java.version>11</java.version>
|
<java.version>11</java.version>
|
||||||
|
@ -42,7 +42,7 @@
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>ch.unisg</groupId>
|
<groupId>ch.unisg</groupId>
|
||||||
<artifactId>executorbase</artifactId>
|
<artifactId>executor-base</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
<scope>compile</scope>
|
<scope>compile</scope>
|
||||||
</dependency>
|
</dependency>
|
|
@ -9,9 +9,9 @@
|
||||||
<relativePath/> <!-- lookup parent from repository -->
|
<relativePath/> <!-- lookup parent from repository -->
|
||||||
</parent>
|
</parent>
|
||||||
<groupId>ch.unisg</groupId>
|
<groupId>ch.unisg</groupId>
|
||||||
<artifactId>executorrobot</artifactId>
|
<artifactId>executor-robot</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
<name>executorrobot</name>
|
<name>executor-robot</name>
|
||||||
<description>Demo project for Spring Boot</description>
|
<description>Demo project for Spring Boot</description>
|
||||||
<properties>
|
<properties>
|
||||||
<java.version>11</java.version>
|
<java.version>11</java.version>
|
||||||
|
@ -42,7 +42,7 @@
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>ch.unisg</groupId>
|
<groupId>ch.unisg</groupId>
|
||||||
<artifactId>executorbase</artifactId>
|
<artifactId>executor-base</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
|
@ -23,7 +23,7 @@ public class ExecutorRemovedEventListenerMqttAdapter extends ExecutorEventMqttLi
|
||||||
// representation that makes sense in the context of your application.
|
// representation that makes sense in the context of your application.
|
||||||
JsonNode data = new ObjectMapper().readTree(payload);
|
JsonNode data = new ObjectMapper().readTree(payload);
|
||||||
|
|
||||||
String executorId = data.get("executorURI").asText();
|
String executorId = data.get("executorUri").asText();
|
||||||
|
|
||||||
ExecutorRemovedEvent executorRemovedEvent = new ExecutorRemovedEvent(
|
ExecutorRemovedEvent executorRemovedEvent = new ExecutorRemovedEvent(
|
||||||
new ExecutorURI(executorId));
|
new ExecutorURI(executorId));
|
||||||
|
|
|
@ -34,8 +34,6 @@ public class PublishNewTaskEventAdapter implements NewTaskEventPort {
|
||||||
@Override
|
@Override
|
||||||
public void publishNewTaskEvent(NewTaskEvent event) {
|
public void publishNewTaskEvent(NewTaskEvent event) {
|
||||||
|
|
||||||
System.out.println(server2);
|
|
||||||
|
|
||||||
// HttpClient client = HttpClient.newHttpClient();
|
// HttpClient client = HttpClient.newHttpClient();
|
||||||
// HttpRequest request = HttpRequest.newBuilder()
|
// HttpRequest request = HttpRequest.newBuilder()
|
||||||
// .uri(URI.create(server + "/newtask/" + event.taskType.getValue()))
|
// .uri(URI.create(server + "/newtask/" + event.taskType.getValue()))
|
||||||
|
|
Loading…
Reference in New Issue
Block a user