modify

Helius

2021-04-02 1ac6fa11ef63570afcda9db21997b1c8b09f22e9

 src/main/java/com/xcong/excoin/rabbit/consumer/FollowConsumer.java

@@ -16,7 +16,7 @@
 **/
@Slf4j
@Component
@ConditionalOnProperty(prefix = "app", name = "rabbit-consumer1", havingValue = "true")
@ConditionalOnProperty(prefix = "app", name = "rabbit-consumer", havingValue = "true")
public class FollowConsumer {

    @Autowired
@@ -26,6 +26,8 @@
    public void addFollowOrder(Message message, Channel channel) {
        String content = new String(message.getBody());
        log.info("==收到跟单下单消息 : {}", content);
        followOrderOperationService.addFollowerOrder(Long.parseLong(content));
        synchronized (this) {
            followOrderOperationService.addFollowerOrder(Long.parseLong(content));
        }
    }
}