|  |  |  | 
|---|
|  |  |  | package com.genersoft.iot.vmp.media.zlm.dto; | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSONObject; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * hook 订阅工厂 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public static HookSubscribeForStreamChange on_stream_changed(String app, String stream, boolean regist, String scheam, String mediaServerId) { | 
|---|
|  |  |  | HookSubscribeForStreamChange hookSubscribe = new HookSubscribeForStreamChange(); | 
|---|
|  |  |  | JSONObject subscribeKey = new com.alibaba.fastjson.JSONObject(); | 
|---|
|  |  |  | JSONObject subscribeKey = new com.alibaba.fastjson2.JSONObject(); | 
|---|
|  |  |  | subscribeKey.put("app", app); | 
|---|
|  |  |  | subscribeKey.put("stream", stream); | 
|---|
|  |  |  | subscribeKey.put("regist", regist); | 
|---|
|  |  |  | 
|---|
|  |  |  | return hookSubscribe; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public static HookSubscribeForRtpServerTimeout on_rtp_server_timeout(String stream, String ssrc, String mediaServerId) { | 
|---|
|  |  |  | HookSubscribeForRtpServerTimeout hookSubscribe = new HookSubscribeForRtpServerTimeout(); | 
|---|
|  |  |  | JSONObject subscribeKey = new com.alibaba.fastjson2.JSONObject(); | 
|---|
|  |  |  | subscribeKey.put("stream_id", stream); | 
|---|
|  |  |  | subscribeKey.put("ssrc", ssrc); | 
|---|
|  |  |  | subscribeKey.put("mediaServerId", mediaServerId); | 
|---|
|  |  |  | hookSubscribe.setContent(subscribeKey); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return hookSubscribe; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public static HookSubscribeForServerStarted on_server_started() { | 
|---|
|  |  |  | HookSubscribeForServerStarted hookSubscribe = new HookSubscribeForServerStarted(); | 
|---|
|  |  |  | hookSubscribe.setContent(new JSONObject()); | 
|---|