浏览代码

fix mqtt

tags/v0.8.5^2
yk 2 年前
父节点
当前提交
9593ed9498
共有 1 个文件被更改,包括 2 次插入4 次删除
  1. +2
    -4
      xueyi-api/xueyi-api-system/src/main/java/com/xueyi/system/api/digitalmans/feign/RemoteDigitalmanMqttService.java

+ 2
- 4
xueyi-api/xueyi-api-system/src/main/java/com/xueyi/system/api/digitalmans/feign/RemoteDigitalmanMqttService.java 查看文件

@@ -4,11 +4,9 @@ import com.xueyi.common.core.constant.basic.SecurityConstants;
import com.xueyi.common.core.constant.basic.ServiceConstants;
import com.xueyi.system.api.organize.feign.factory.RemoteUserFallbackFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestParam;

/**
* 一体机mqtt服务
@@ -23,8 +21,8 @@ public interface RemoteDigitalmanMqttService {
public void heartbeat(@RequestBody(required = true) String message);


@GetMapping("/man/api/mqtt/log-upload/{message}")
public void logUpload(@RequestParam(value = "message") String message,@RequestHeader(SecurityConstants.ENTERPRISE_ID) Long enterpriseId, @RequestHeader(SecurityConstants.SOURCE_NAME) String sourceName, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);
@PostMapping("/man/api/mqtt/log-upload")
public void logUpload(@RequestBody(required = true) String message,@RequestHeader(SecurityConstants.ENTERPRISE_ID) Long enterpriseId, @RequestHeader(SecurityConstants.SOURCE_NAME) String sourceName, @RequestHeader(SecurityConstants.FROM_SOURCE) String source);


}

正在加载...
取消
保存