修改镜屏topic

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/task/AlarmMirrorTask.java

			String msg = JSON.toJSONString(CommonResponse.ok(resultMap));
			logger.info("实时报警推送镜屏数据: " + msg);
			MirrorManagement.sendData(MirrorManagement.topic_personnel, msg);
			MirrorManagement.sendData(MirrorManagement.TOPIC_ALARM, msg);
		} catch (Exception e) {
			logger.error("实时报警推送镜屏失败: " + e.getMessage());

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/task/LocationMirrorTask.java

			String msg = JSON.toJSONString(CommonResponse.ok(resultMap));
			logger.info("人员定位推送镜屏数据: " + msg);
			MirrorManagement.sendData(MirrorManagement.topic_personnel, msg);
			MirrorManagement.sendData(MirrorManagement.TOPIC_LOCATION, msg);
		} catch (Exception e) {
			logger.error("人员定位推送镜屏失败: " + e.getMessage());

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/task/MirrorManagement.java

 */
public class MirrorManagement {
	private static final Logger logger = LoggerFactory.getLogger(MirrorManagement.class);
	
	// 人员定位topic
	public static final String topic_personnel = "personnel";
	// 船舶定位topic
	public static final String topic_ship = "ship";
	// 定位topic
	public static final String TOPIC_LOCATION = "location";
	// 报警topic
	public static final String TOPIC_ALARM = "alarm";
	public static void sendData(String topic, String msg) {
		logger.debug("推送镜屏数据: topic="+topic+" , data=" + msg);
		
		logger.debug("推送镜屏数据: topic=" + topic + " , data=" + msg);
		if (!EventChannelTool.isExistSubscriber(topic)) {
			// 如果没有订阅 先不管
			return;
		}
		
		// 你发送的内容
		final Publisher publisher = new Publisher(topic);
		PublisherEvent<?> publisherEvent = new PublisherEvent<String>(msg) {