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

Class TestClientMessageProcessorHandler

java.lang.Object

io.github.lunasaw.gbproxy.test.handler.TestClientMessageProcessorHandler

All Implemented Interfaces:

MessageRequestHandler

@Component
public class TestClientMessageProcessorHandler
extends Object
implements MessageRequestHandler

测试专用的Client消息处理器Handler 用于验证客户端MESSAGE请求的处理流程

Constructor Summary

Constructors

Constructor	Description
TestClientMessageProcessorHandler()

Method Summary

Modifier and Type	Method	Description
void	broadcastNotify(DeviceBroadcastNotify broadcastNotify)	处理语音广播通知
<T> void	deviceControl(T deviceControlBase)	处理设备控制命令
ConfigDownloadResponse	getConfigDownloadResponse(String userId, String configType)	获取设备配置查询应答
DeviceAlarmNotify	getDeviceAlarmNotify(DeviceAlarmQuery deviceAlarmQuery)	获取设备告警通知
DeviceConfigResponse	getDeviceConfigResponse(DeviceConfigDownload deviceConfigDownload)	获取设备配置响应
DeviceInfo	getDeviceInfo(String userId)	获取设备信息 DeviceInfo
DeviceResponse	getDeviceItem(String userId)	获取设备通道信息
PresetQueryResponse	getDevicePresetQueryResponse(PresetQuery presetQuery)	获取设备预置位查询应答
DeviceRecord	getDeviceRecord(DeviceRecordQuery deviceRecordQuery)	获取设备录像信息 DeviceRecord
DeviceStatus	getDeviceStatus(String userId)	获取设备状态信息 DeviceStatus
MobilePositionNotify	getMobilePositionNotify(MobilePositionQuery mobilePositionQuery)	处理设备移动位置通知
PresetQueryResponse	getPresetQueryResponse(String userId)	获取设备预置位信息
static DeviceAlarmNotify	getReceivedAlarm()
static DeviceResponse	getReceivedCatalog()
static DeviceConfigResponse	getReceivedDeviceConfig()
static DeviceInfo	getReceivedDeviceInfo()
static DeviceRecord	getReceivedDeviceRecord()
static DeviceStatus	getReceivedDeviceStatus()
static DeviceKeepLiveNotify	getReceivedKeepalive()
static MobilePositionNotify	getReceivedMobilePosition()
static PresetQueryResponse	getReceivedPresetQuery()
static boolean	hasReceivedAlarm()
static boolean	hasReceivedCatalog()
static boolean	hasReceivedDeviceConfig()
static boolean	hasReceivedDeviceInfo()
static boolean	hasReceivedDeviceRecord()
static boolean	hasReceivedDeviceStatus()
static boolean	hasReceivedKeepalive()
static boolean	hasReceivedMobilePosition()
static boolean	hasReceivedPresetQuery()
static void	resetTestState()
void	updateCatalog(DeviceResponse catalog)
void	updateDeviceAlarm(DeviceAlarmNotify deviceAlarmNotify)
void	updateDeviceConfig(DeviceConfigResponse deviceConfigResponse)
void	updateDeviceInfo(DeviceInfo deviceInfo)
void	updateDeviceRecord(DeviceRecord deviceRecord)
void	updateDeviceStatus(DeviceStatus deviceStatus)
void	updateMobilePosition(MobilePositionNotify mobilePositionNotify)
void	updatePresetQuery(PresetQueryResponse response)
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	waitForKeepalive(long timeout, TimeUnit unit)
static boolean	waitForMobilePosition(long timeout, TimeUnit unit)
static boolean	waitForPresetQuery(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Details

TestClientMessageProcessorHandler

public TestClientMessageProcessorHandler()

Method Details

getDeviceRecord

public DeviceRecord getDeviceRecord(DeviceRecordQuery deviceRecordQuery)

Description copied from interface: MessageRequestHandler

获取设备录像信息 DeviceRecord

Specified by:

getDeviceRecord in interface MessageRequestHandler

Parameters:

deviceRecordQuery - 设备录像查询

Returns:

DeviceRecord 设备录像信息

getDeviceStatus

public DeviceStatus getDeviceStatus(String userId)

Description copied from interface: MessageRequestHandler

获取设备状态信息 DeviceStatus

Specified by:

getDeviceStatus in interface MessageRequestHandler

Parameters:

userId - 设备Id

Returns:

DeviceStatus 设备状态信息

getDeviceInfo

public DeviceInfo getDeviceInfo(String userId)

Description copied from interface: MessageRequestHandler

获取设备信息 DeviceInfo

Specified by:

getDeviceInfo in interface MessageRequestHandler

Parameters:

userId - 设备Id

Returns:

DeviceInfo 设备信息

getDeviceItem

public DeviceResponse getDeviceItem(String userId)

Description copied from interface: MessageRequestHandler

获取设备通道信息

Specified by:

getDeviceItem in interface MessageRequestHandler

Parameters:

userId - 设备Id

Returns:

DeviceResponse 设备通道信息

broadcastNotify

public void broadcastNotify(DeviceBroadcastNotify broadcastNotify)

Description copied from interface: MessageRequestHandler

处理语音广播通知

Specified by:

broadcastNotify in interface MessageRequestHandler

Parameters:

broadcastNotify - 广播通知

getDeviceAlarmNotify

public DeviceAlarmNotify getDeviceAlarmNotify(DeviceAlarmQuery deviceAlarmQuery)

Description copied from interface: MessageRequestHandler

获取设备告警通知

Specified by:

getDeviceAlarmNotify in interface MessageRequestHandler

Parameters:

deviceAlarmQuery - 告警查询

Returns:

DeviceAlarmNotify 告警通知

getDeviceConfigResponse

public DeviceConfigResponse getDeviceConfigResponse(DeviceConfigDownload deviceConfigDownload)

Description copied from interface: MessageRequestHandler

获取设备配置响应

Specified by:

getDeviceConfigResponse in interface MessageRequestHandler

Parameters:

deviceConfigDownload - 配置下载查询

Returns:

DeviceConfigResponse 配置响应

deviceControl

public <T> void deviceControl(T deviceControlBase)

Description copied from interface: MessageRequestHandler

处理设备控制命令

Specified by:

deviceControl in interface MessageRequestHandler

Parameters:

deviceControlBase - 设备控制基础信息

getDevicePresetQueryResponse

public PresetQueryResponse getDevicePresetQueryResponse(PresetQuery presetQuery)

Description copied from interface: MessageRequestHandler

获取设备预置位查询应答

Specified by:

getDevicePresetQueryResponse in interface MessageRequestHandler

Returns:

预置位查询应答

getPresetQueryResponse

public PresetQueryResponse getPresetQueryResponse(String userId)

Description copied from interface: MessageRequestHandler

获取设备预置位信息

Specified by:

getPresetQueryResponse in interface MessageRequestHandler

Parameters:

userId - 设备Id

Returns:

设备预置位应答

updatePresetQuery

public void updatePresetQuery(PresetQueryResponse response)

waitForPresetQuery

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

Throws:

InterruptedException

hasReceivedPresetQuery

public static boolean hasReceivedPresetQuery()

getReceivedPresetQuery

public static PresetQueryResponse getReceivedPresetQuery()

getConfigDownloadResponse

public ConfigDownloadResponse getConfigDownloadResponse(String userId,
 String configType)

Description copied from interface: MessageRequestHandler

获取设备配置查询应答

Specified by:

getConfigDownloadResponse in interface MessageRequestHandler

Parameters:

userId - 设备Id

configType - 配置类型

Returns:

设备配置查询应答

getMobilePositionNotify

public MobilePositionNotify getMobilePositionNotify(MobilePositionQuery mobilePositionQuery)

Description copied from interface: MessageRequestHandler

处理设备移动位置通知

Specified by:

getMobilePositionNotify in interface MessageRequestHandler

updateMobilePosition

public void updateMobilePosition(MobilePositionNotify mobilePositionNotify)

updateDeviceAlarm

public void updateDeviceAlarm(DeviceAlarmNotify deviceAlarmNotify)

updateDeviceStatus

public void updateDeviceStatus(DeviceStatus deviceStatus)

updateDeviceInfo

public void updateDeviceInfo(DeviceInfo deviceInfo)

updateDeviceRecord

public void updateDeviceRecord(DeviceRecord deviceRecord)

updateDeviceConfig

public void updateDeviceConfig(DeviceConfigResponse deviceConfigResponse)

updateCatalog

public void updateCatalog(DeviceResponse catalog)

waitForMobilePosition

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

Throws:

InterruptedException

hasReceivedMobilePosition

public static boolean hasReceivedMobilePosition()

getReceivedMobilePosition

public static MobilePositionNotify getReceivedMobilePosition()

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()

waitForDeviceStatus

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

Throws:

InterruptedException

hasReceivedDeviceStatus

public static boolean hasReceivedDeviceStatus()

getReceivedDeviceStatus

public static DeviceStatus getReceivedDeviceStatus()

waitForDeviceInfo

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

Throws:

InterruptedException

hasReceivedDeviceInfo

public static boolean hasReceivedDeviceInfo()

getReceivedDeviceInfo

public static DeviceInfo getReceivedDeviceInfo()

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()

waitForCatalog

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

Throws:

InterruptedException

hasReceivedCatalog

public static boolean hasReceivedCatalog()

getReceivedCatalog

public static DeviceResponse getReceivedCatalog()