| | |
|---|
| | | log.info("初始化OSS配置成功"); |
|---|
| | | log.info("通道: {} 监听中......", "OSS"); |
|---|
| | | // 项目初始化设置一次即可 |
|---|
| | | QueueUtils.subscribeBlockingQueue("OSS", (String ossId) -> { |
|---|
| | | // 观察接收时间 |
|---|
| | | log.info("通道: {}, 收到数据: {}", "OSS", ossId); |
|---|
| | | SysOssVo vo = ossMapper.selectVoById(ossId); |
|---|
| | | client.delete( vo.getUrl()); |
|---|
| | | ossMapper.deleteById(Long.valueOf(ossId)); |
|---|
| | | // QueueUtils.subscribeBlockingQueue("OSS", (String ossId) -> { |
|---|
| | | // // 观察接收时间 |
|---|
| | | // log.info("通道: {}, 收到数据: {}", "OSS", ossId); |
|---|
| | | // SysOssVo vo = ossMapper.selectVoById(ossId); |
|---|
| | | // client.delete( vo.getUrl()); |
|---|
| | | // ossMapper.deleteById(Long.valueOf(ossId)); |
|---|
| | | // try { |
|---|
| | | // HttpUtils.sendDeleteRequest(boundary.getLocalhost() + "/resource/synchronization/delete",ossId); |
|---|
| | | // HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete",ossId); |
|---|
| | | // } catch (IOException e) { |
|---|
| | | // throw new RuntimeException(e); |
|---|
| | | // } |
|---|
| | | }); |
|---|
| | | // }); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
