Package io.github.lunasaw.gbproxy.test.handler

Class TestServerMessageProcessorHandler

java.lang.Object

io.github.lunasaw.gbproxy.test.handler.TestServerMessageProcessorHandler

All Implemented Interfaces:

ServerMessageProcessorHandler

@Component
@Primary
public class TestServerMessageProcessorHandler
extends Object
implements ServerMessageProcessorHandler

测试专用的ServerMessageProcessorHandler实现 用于验证MESSAGE请求的处理流程

Constructor Summary

Constructors

Constructor	Description
TestServerMessageProcessorHandler()

Method Summary

Modifier and Type	Method	Description
FromDevice	getFromDevice()	获取发送设备信息
static DeviceAlarmNotify	getReceivedAlarm()
static DeviceResponse	getReceivedCatalog()
static DeviceConfigResponse	getReceivedDeviceConfig()
static DeviceInfo	getReceivedDeviceInfo()
static DeviceRecord	getReceivedDeviceRecord()
static DeviceStatus	getReceivedDeviceStatus()
static String	getReceivedInvitePlayBackCallId()
static String	getReceivedInvitePlayBackFromUserId()
static String	getReceivedInvitePlayBackSdp()
static String	getReceivedInvitePlayCallId()
static String	getReceivedInvitePlayFromUserId()
static String	getReceivedInvitePlaySdp()
static DeviceKeepLiveNotify	getReceivedKeepalive()	获取接收到的心跳
void	handleMessageError(javax.sip.RequestEvent evt, String errorMessage)	处理MESSAGE请求错误
void	handleMessageRequest(javax.sip.RequestEvent evt, FromDevice fromDevice)	处理MESSAGE请求
static boolean	hasReceivedAlarm()
static boolean	hasReceivedCatalog()
static boolean	hasReceivedDeviceConfig()
static boolean	hasReceivedDeviceInfo()
static boolean	hasReceivedDeviceRecord()
static boolean	hasReceivedDeviceStatus()
static boolean	hasReceivedInvitePlay()
static boolean	hasReceivedInvitePlayBack()
static boolean	hasReceivedKeepalive()	检查是否接收到心跳
void	keepLiveDevice(DeviceKeepLiveNotify deviceKeepLiveNotify)	更新设备心跳信息
static void	resetTestState()
void	updateDeviceAlarm(DeviceAlarmNotify deviceAlarmNotify)	更新报警信息
void	updateDeviceConfig(String userId, DeviceConfigResponse deviceConfigResponse)
void	updateDeviceInfo(String userId, DeviceInfo deviceInfo)	更新设备信息
void	updateDeviceRecord(String userId, DeviceRecord deviceRecord)	更新设备录像
void	updateDeviceResponse(String userId, DeviceResponse deviceResponse)	更新设备通道
void	updateDeviceStatus(String userId, DeviceStatus deviceStatus)
static void	updateInvitePlay(String callId, String sdpContent, String fromUserId)
static void	updateInvitePlayBack(String callId, String sdpContent, String fromUserId)
void	updateMediaStatus(MediaStatusNotify mediaStatusNotify)	更新媒体状态
void	updateMobilePosition(MobilePositionNotify mobilePositionNotify)	更新位置信息
void	updateRemoteAddress(String userId, RemoteAddressInfo remoteAddressInfo)	更新设备地址信息
boolean	validateDevicePermission(javax.sip.RequestEvent evt)	验证设备权限
static boolean	waitForAlarm(long timeout, TimeUnit unit)
static boolean	waitForCatalog(long timeout, TimeUnit unit)
static boolean	waitForDeviceConfig(long timeout, TimeUnit unit)
static boolean	waitForDeviceInfo(long timeout, TimeUnit unit)
static boolean	waitForDeviceRecord(long timeout, TimeUnit unit)
static boolean	waitForDeviceStatus(long timeout, TimeUnit unit)
static boolean	waitForInvitePlay(long timeout, TimeUnit unit)
static boolean	waitForInvitePlayBack(long timeout, TimeUnit unit)
static boolean	waitForKeepalive(long timeout, TimeUnit unit)	等待心跳接收

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TestServerMessageProcessorHandler

public TestServerMessageProcessorHandler()

Method Details

handleMessageRequest

public void handleMessageRequest(javax.sip.RequestEvent evt,
 FromDevice fromDevice)

Description copied from interface: ServerMessageProcessorHandler

处理MESSAGE请求

Specified by:

handleMessageRequest in interface ServerMessageProcessorHandler

Parameters:

evt - 请求事件

fromDevice - 发送设备

validateDevicePermission

public boolean validateDevicePermission(javax.sip.RequestEvent evt)

Description copied from interface: ServerMessageProcessorHandler

验证设备权限

Specified by:

validateDevicePermission in interface ServerMessageProcessorHandler

Parameters:

evt - 请求事件

Returns:

是否有权限

getFromDevice

public FromDevice getFromDevice()

Description copied from interface: ServerMessageProcessorHandler

获取发送设备信息

Specified by:

getFromDevice in interface ServerMessageProcessorHandler

Returns:

发送设备

handleMessageError

public void handleMessageError(javax.sip.RequestEvent evt,
 String errorMessage)

Description copied from interface: ServerMessageProcessorHandler

处理MESSAGE请求错误

Specified by:

handleMessageError in interface ServerMessageProcessorHandler

Parameters:

evt - 请求事件

errorMessage - 错误消息

keepLiveDevice

public void keepLiveDevice(DeviceKeepLiveNotify deviceKeepLiveNotify)

Description copied from interface: ServerMessageProcessorHandler

更新设备心跳信息

Specified by:

keepLiveDevice in interface ServerMessageProcessorHandler

updateRemoteAddress

public void updateRemoteAddress(String userId,
 RemoteAddressInfo remoteAddressInfo)

Description copied from interface: ServerMessageProcessorHandler

更新设备地址信息

Specified by:

updateRemoteAddress in interface ServerMessageProcessorHandler

updateDeviceAlarm

public void updateDeviceAlarm(DeviceAlarmNotify deviceAlarmNotify)

Description copied from interface: ServerMessageProcessorHandler

更新报警信息

Specified by:

updateDeviceAlarm in interface ServerMessageProcessorHandler

updateMobilePosition

public void updateMobilePosition(MobilePositionNotify mobilePositionNotify)

Description copied from interface: ServerMessageProcessorHandler

更新位置信息

Specified by:

updateMobilePosition in interface ServerMessageProcessorHandler

updateMediaStatus

public void updateMediaStatus(MediaStatusNotify mediaStatusNotify)

Description copied from interface: ServerMessageProcessorHandler

更新媒体状态

Specified by:

updateMediaStatus in interface ServerMessageProcessorHandler

updateDeviceRecord

public void updateDeviceRecord(String userId,
 DeviceRecord deviceRecord)

Description copied from interface: ServerMessageProcessorHandler

更新设备录像

Specified by:

updateDeviceRecord in interface ServerMessageProcessorHandler

updateDeviceResponse

public void updateDeviceResponse(String userId,
 DeviceResponse deviceResponse)

Description copied from interface: ServerMessageProcessorHandler

更新设备通道

Specified by:

updateDeviceResponse in interface ServerMessageProcessorHandler

updateDeviceInfo

public void updateDeviceInfo(String userId,
 DeviceInfo deviceInfo)

Description copied from interface: ServerMessageProcessorHandler

更新设备信息

Specified by:

updateDeviceInfo in interface ServerMessageProcessorHandler

updateDeviceConfig

public void updateDeviceConfig(String userId,
 DeviceConfigResponse deviceConfigResponse)

Specified by:

updateDeviceConfig in interface ServerMessageProcessorHandler

updateDeviceStatus

public void updateDeviceStatus(String userId,
 DeviceStatus deviceStatus)

Specified by:

updateDeviceStatus in interface ServerMessageProcessorHandler

resetTestState

public static void resetTestState()

waitForKeepalive

public static boolean waitForKeepalive(long timeout,
 TimeUnit unit)
                                throws InterruptedException

等待心跳接收

Throws:

InterruptedException

hasReceivedKeepalive

public static boolean hasReceivedKeepalive()

检查是否接收到心跳

getReceivedKeepalive

public static DeviceKeepLiveNotify getReceivedKeepalive()

获取接收到的心跳

waitForAlarm

public static boolean waitForAlarm(long timeout,
 TimeUnit unit)
                            throws InterruptedException

Throws:

InterruptedException

hasReceivedAlarm

public static boolean hasReceivedAlarm()

getReceivedAlarm

public static DeviceAlarmNotify getReceivedAlarm()

waitForCatalog

public static boolean waitForCatalog(long timeout,
 TimeUnit unit)
                              throws InterruptedException

Throws:

InterruptedException

hasReceivedCatalog

public static boolean hasReceivedCatalog()

getReceivedCatalog

public static DeviceResponse getReceivedCatalog()

waitForDeviceInfo

public static boolean waitForDeviceInfo(long timeout,
 TimeUnit unit)
                                 throws InterruptedException

Throws:

InterruptedException

hasReceivedDeviceInfo

public static boolean hasReceivedDeviceInfo()

getReceivedDeviceInfo

public static DeviceInfo getReceivedDeviceInfo()

waitForDeviceStatus

public static boolean waitForDeviceStatus(long timeout,
 TimeUnit unit)
                                   throws InterruptedException

Throws:

InterruptedException

hasReceivedDeviceStatus

public static boolean hasReceivedDeviceStatus()

getReceivedDeviceStatus

public static DeviceStatus getReceivedDeviceStatus()

waitForDeviceRecord

public static boolean waitForDeviceRecord(long timeout,
 TimeUnit unit)
                                   throws InterruptedException

Throws:

InterruptedException

hasReceivedDeviceRecord

public static boolean hasReceivedDeviceRecord()

getReceivedDeviceRecord

public static DeviceRecord getReceivedDeviceRecord()

waitForDeviceConfig

public static boolean waitForDeviceConfig(long timeout,
 TimeUnit unit)
                                   throws InterruptedException

Throws:

InterruptedException

hasReceivedDeviceConfig

public static boolean hasReceivedDeviceConfig()

getReceivedDeviceConfig

public static DeviceConfigResponse getReceivedDeviceConfig()

waitForInvitePlay

public static boolean waitForInvitePlay(long timeout,
 TimeUnit unit)
                                 throws InterruptedException

Throws:

InterruptedException

hasReceivedInvitePlay

public static boolean hasReceivedInvitePlay()

getReceivedInvitePlayCallId

public static String getReceivedInvitePlayCallId()

getReceivedInvitePlaySdp

public static String getReceivedInvitePlaySdp()

getReceivedInvitePlayFromUserId

public static String getReceivedInvitePlayFromUserId()

waitForInvitePlayBack

public static boolean waitForInvitePlayBack(long timeout,
 TimeUnit unit)
                                     throws InterruptedException

Throws:

InterruptedException

hasReceivedInvitePlayBack

public static boolean hasReceivedInvitePlayBack()

getReceivedInvitePlayBackCallId

public static String getReceivedInvitePlayBackCallId()

getReceivedInvitePlayBackSdp

public static String getReceivedInvitePlayBackSdp()

getReceivedInvitePlayBackFromUserId

public static String getReceivedInvitePlayBackFromUserId()

updateInvitePlay

public static void updateInvitePlay(String callId,
 String sdpContent,
 String fromUserId)

updateInvitePlayBack

public static void updateInvitePlayBack(String callId,
 String sdpContent,
 String fromUserId)