...
|
...
|
@@ -101,7 +101,7 @@ public class RabbitmqCtrl { |
|
|
|
|
|
DEBUG.info("Query the queues of mo {}", request.getMoId());
|
|
|
|
|
|
BaseResponse<PageResponse<QueueInfo>> baseResponse = new BaseResponse();
|
|
|
BaseResponse baseResponse = new BaseResponse();
|
|
|
|
|
|
QueueView oneView = InterVar.queueViewMaps.get(Integer.parseInt(request.getMoId()));
|
|
|
|
...
|
...
|
@@ -123,7 +123,7 @@ public class RabbitmqCtrl { |
|
|
}
|
|
|
}
|
|
|
|
|
|
List<QueueInfo> selectedList = new ArrayList<>();
|
|
|
/*List<QueueInfo> selectedList = new ArrayList<>();
|
|
|
|
|
|
int start = (request.getCurrentPage() - 1) * request.getPageSize();
|
|
|
|
...
|
...
|
@@ -134,9 +134,9 @@ public class RabbitmqCtrl { |
|
|
for (int i = 0; i < realCount; i++) {
|
|
|
|
|
|
selectedList.add(queuesList.get(start + i));
|
|
|
}
|
|
|
}*/
|
|
|
|
|
|
PageResponse<QueueInfo> response = new PageResponse<>();
|
|
|
/*PageResponse<QueueInfo> response = new PageResponse<>();
|
|
|
|
|
|
response.setCurrentPage(request.getCurrentPage());
|
|
|
|
...
|
...
|
@@ -144,11 +144,11 @@ public class RabbitmqCtrl { |
|
|
|
|
|
response.setPageSize(request.getPageSize());
|
|
|
|
|
|
response.setTotalPage(queuesList.size() / request.getPageSize() + 1);
|
|
|
response.setTotalPage(queuesList.size() / request.getPageSize() + 1);*/
|
|
|
|
|
|
response.setRows(selectedList);
|
|
|
/* response.setRows(selectedList);*/
|
|
|
|
|
|
baseResponse.setData(response);
|
|
|
baseResponse.setData(queuesList);
|
|
|
}
|
|
|
|
|
|
return baseResponse;
|
...
|
...
|
|