MQ整合
This commit is contained in:
parent
1c7c41ccdf
commit
46382e9160
@ -4,7 +4,6 @@ import cn.hutool.core.util.ObjectUtil;
|
||||
import com.qiuguo.iot.data.entity.user.UserRoomEntity;
|
||||
import com.qiuguo.iot.data.request.user.UserRoomRequest;
|
||||
import com.qiuguo.iot.data.service.user.UserRoomService;
|
||||
import com.qiuguo.iot.user.api.rabbit.MyProducer;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.hswebframework.web.api.crud.entity.PagerResult;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
@ -24,9 +23,6 @@ public class RoomAdminController {
|
||||
@Resource
|
||||
private UserRoomService roomService;
|
||||
|
||||
@Resource
|
||||
private MyProducer myProducer;
|
||||
|
||||
//新增
|
||||
@PostMapping("/save/room")
|
||||
public Mono<Void> roomSave(@RequestBody UserRoomEntity room) {
|
||||
@ -56,10 +52,4 @@ public class RoomAdminController {
|
||||
public Mono<PagerResult<UserRoomEntity>> getFamily(@RequestBody UserRoomRequest resp) {
|
||||
return roomService.selectUserRoomsByRequest(resp);
|
||||
}
|
||||
|
||||
@GetMapping("/text")
|
||||
public String text() {
|
||||
myProducer.sendMessage("hello world");
|
||||
return "hello world";
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user