| | |
| | | package com.whyc.webSocket; |
| | | |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.dto.paramter.BattScrapPar; |
| | | import com.whyc.service.BattScrapService; |
| | | import com.whyc.util.ActionUtil; |
| | |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |
| | | session.getBasicRemote().sendObject(service.searchByCondition(battScrapPar.getPageNum(),battScrapPar.getPageSize(),battScrapPar.getBattScrap())); |
| | | Response response = service.searchByCondition(battScrapPar.getPageNum(), battScrapPar.getPageSize(), battScrapPar.getBattScrap()); |
| | | session.getBasicRemote().sendObject(response); |
| | | } |
| | | threadFlagMap.put(thread.getId(),false); |
| | | } |