diff options
| author |   vvarvate <vv00489503@techmahindra.com> | 2022-09-06 18:34:41 +0530 |
|---|---|---|
| committer |   Lukasz Rajewski <lukasz.rajewski@t-mobile.pl> | 2022-10-13 22:01:12 +0000 |
| commit | 6e2a9f94f63c57786fd9b6d4ba5f53cb66f7f5e2 (patch) | |
| tree | 88ec82e291de14861ddc39e7b7f900a272b3e96f /ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java | |
| parent | b5050799014b831a89d09078ce09829458da9339 (diff) | |
RAN-Sim Updates for SON Use Case Kohn Release
Enhancement of RAN-Sim Controller to support A1-based action
Issue-ID: INT-2130
Signed-off-by: vvarvate <vv00489503@techmahindra.com>
Change-Id: Ibeeb93a97582ca3712af11e2204a46c6a66dcb81
Diffstat (limited to 'ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java')
| -rw-r--r-- | ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java index f8928e9..68ccb28 100644 --- a/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java +++ b/ransim/ransimctrlr/RANSIM-CTRLR/src/main/java/org/onap/ransim/websocket/server/RansimWebSocketServer.java @@ -37,6 +37,7 @@ import org.onap.ransim.websocket.model.DeviceData; import org.onap.ransim.websocket.model.DeviceDataDecoder; import org.onap.ransim.websocket.model.DeviceDataEncoder; import org.onap.ransim.websocket.model.MessageTypes; +import org.onap.ransim.websocket.model.ResponsetoRanapp; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; @@ -142,7 +143,18 @@ public class RansimWebSocketServer { } else if (message.getType().equals(MessageTypes.HC_TO_RC_SLICE_PROFILE_DEL)) { log.info("Delete SliceProfile message received"); rscServices.handleSliceProfileDeleteFromSdnr(message.getMessage(), session, ipPort); - } + } else if (message.getType().equals(MessageTypes.APP_TO_RC_CONNECTION)){ + log.info(message.getMessage()); + } else if (message.getType().equals(MessageTypes.APP_TO_RC_KAFKA_MSG)) { + log.info(message.getMessage()); + ResponsetoRanapp ws_msgtoranapp=rscServices.sendPayloadtoHC(message.getMessage(),ipPort,session); + DeviceData devicedata=new DeviceData(); + devicedata.setMessage(ws_msgtoranapp.toString()); + devicedata.setType(MessageTypes.APP_TO_RC_KAFKA_MSG); + log.info(String.format("Sending Output Payload to "+ipPort+" Server")); + sendMessage(devicedata,session); + + } } } } catch (Exception e) { |