Compare commits
1 commit
e5cf6d291a
...
52616e6a6a
Author | SHA1 | Date | |
---|---|---|---|
52616e6a6a |
3 changed files with 6 additions and 5 deletions
|
@ -22,12 +22,11 @@ public class ConnectionWebsocketHandler extends JsonWebsocketHandler {
|
|||
protected void handleTextMessage(WebSocketSession session, TextMessage message) {
|
||||
try{
|
||||
String payload = message.getPayload();
|
||||
switch ( objectMapper.readTree(payload).get("$id").asText().toLowerCase()) {
|
||||
case "requestconnectiontoken" -> handleRequestConnectionToken(session, payload);
|
||||
switch ( objectMapper.readTree(payload).get("$id").asText()) {
|
||||
case RequestConnectionTokenMessage.MESSAGE_ID -> handleRequestConnectionToken(session, payload);
|
||||
default -> this.closeSession(session, CloseStatus.BAD_DATA);
|
||||
}
|
||||
} catch (Exception exception) {
|
||||
System.out.println(exception.getMessage());
|
||||
} catch (Exception ignored) {
|
||||
this.closeSession(session, CloseStatus.BAD_DATA);
|
||||
}
|
||||
}
|
||||
|
|
|
@ -8,6 +8,8 @@ import lombok.*;
|
|||
@Data
|
||||
@NotNull
|
||||
public class RequestConnectionTokenMessage {
|
||||
public static final String MESSAGE_ID = "RequestConnectionToken";
|
||||
|
||||
@JsonProperty("$id")
|
||||
private String messageId;
|
||||
private Channel channel;
|
||||
|
|
|
@ -7,7 +7,7 @@ info:
|
|||
Because of the limitations of Async API, we expect that the actual json,
|
||||
which is send as payload to always contain a field called `$id` with
|
||||
the corresponding `messageId`. <br>
|
||||
The `messageId` should be handled case insensitive.
|
||||
The `messageId` should be handled case sensitive.
|
||||
defaultContentType: application/json
|
||||
servers:
|
||||
localhost:
|
||||
|
|
Loading…
Add table
Reference in a new issue