| | |
|---|
| | | @Override |
|---|
| | | public boolean stop(String app, String streamId) { |
|---|
| | | StreamPushItem streamPushItem = streamPushMapper.selectOne(app, streamId); |
|---|
| | | gbStreamService.sendCatalogMsg(streamPushItem, CatalogEvent.DEL); |
|---|
| | | if (streamPushItem != null) { |
|---|
| | | gbStreamService.sendCatalogMsg(streamPushItem, CatalogEvent.DEL); |
|---|
| | | } |
|---|
| | | |
|---|
| | | platformGbStreamMapper.delByAppAndStream(app, streamId); |
|---|
| | | gbStreamMapper.del(app, streamId); |
|---|
| | |
|---|
| | | // 存储数据到stream_push表 |
|---|
| | | streamPushMapper.addAll(streamPushItems); |
|---|
| | | List<StreamPushItem> streamPushItemForGbStream = streamPushItems.stream() |
|---|
| | | .filter(streamPushItem-> streamPushItem.getId() != null) |
|---|
| | | .filter(streamPushItem-> streamPushItem.getGbId() != null) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | // 存储数据到gb_stream表， id会返回到streamPushItemForGbStream里 |
|---|
| | | if (streamPushItemForGbStream.size() > 0) { |
|---|
