|
|
@ -40,8 +40,7 @@ public class SubscriptionEndpoint {
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceId - Device Identifier
|
|
|
|
* @param message - String Message which needs to send to peer
|
|
|
|
* @param message - Status code for web-socket close.
|
|
|
|
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public void onMessage(Session session, String message, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
public void onMessage(Session session, String message, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
("deviceId") String deviceId) {
|
|
|
|
("deviceId") String deviceId) {
|
|
|
@ -71,7 +70,7 @@ public class SubscriptionEndpoint {
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceId - Device Identifier
|
|
|
|
* @param deviceId - Device Identifier
|
|
|
|
* @param message - Message which needs to send to peer
|
|
|
|
* @param message - Byte Message which needs to send to peer
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public void onMessage(Session session, byte[] message, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
public void onMessage(Session session, byte[] message, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
("deviceId") String deviceId) {
|
|
|
|
("deviceId") String deviceId) {
|
|
|
@ -96,7 +95,7 @@ public class SubscriptionEndpoint {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Web socket onClose - Handle socket connection close
|
|
|
|
* Web socket onClose use to handle socket connection close
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceType - DeviceType
|
|
|
@ -116,12 +115,12 @@ public class SubscriptionEndpoint {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Web socket onError - Handle socket connection error
|
|
|
|
* Web socket onError use to handle socket connection error
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param session - Registered session.
|
|
|
|
* @param session - Registered session.
|
|
|
|
|
|
|
|
* @param throwable - Web socket exception
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceType - DeviceType
|
|
|
|
* @param deviceId - Device Identifier
|
|
|
|
* @param deviceId - Device Identifier
|
|
|
|
* @param throwable - Status code for web-socket close.
|
|
|
|
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public void onError(Session session, Throwable throwable, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
public void onError(Session session, Throwable throwable, @PathParam("deviceType") String deviceType, @PathParam
|
|
|
|
("deviceId") String deviceId) {
|
|
|
|
("deviceId") String deviceId) {
|
|
|
|