Skip to content

C
cloud-platform
Commit d173e718 authored by 周健威's avatar 周健威
Browse files
Options

添加固定等待时间

parent 156a42db
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mqhandler/RefundMQHandler.java
View file @ d173e718
...@@ -38,6 +38,11 @@ public class RefundMQHandler { ...@@ -38,6 +38,11 @@ public class RefundMQHandler {
*/ */
@RabbitListener(queues = ORDER_DEPOSIT_REFUND_QUEUE) @RabbitListener(queues = ORDER_DEPOSIT_REFUND_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) { public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
try {
Thread.sleep(5000L);
}catch (Exception e) {
log.error(e.getMessage(), e);
}
ExecutorService executorService = Executors.newCachedThreadPool(); ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(new Runnable() { executorService.execute(new Runnable() {
@Override @Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment