Skip to content

Commit f22a61f

Browse files
committed
adjust position message
1 parent 8ecc208 commit f22a61f

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/main/java/telraam/logic/positioner/PositionSender.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,16 +4,22 @@
44
import telraam.websocket.WebSocketMessageSingleton;
55

66
import java.util.List;
7+
import java.util.Map;
78

89
public class PositionSender {
910
private final WebSocketMessage<List<Position>> message = new WebSocketMessage<>();
11+
private final String name;
1012

1113
public PositionSender(String name) {
12-
this.message.setTopic("position_" + name);
14+
this.message.setTopic("position");
15+
this.name = name;
1316
}
1417

1518
public void send(List<Position> positions) {
16-
this.message.setData(positions);
19+
Map<String, Object> data = Map.of(
20+
"positioner", this.name,
21+
"positions", positions
22+
);
1723
WebSocketMessageSingleton.getInstance().sendToAll(this.message);
1824
}
1925

0 commit comments

Comments
 (0)