package demo.mq;

import org.apache.rocketmq.spring.core.RocketMQTemplate;

public class WalletDeductProducer {
  private RocketMQTemplate rocketMQTemplate;

  public void send(WalletDeductReq req) {
    rocketMQTemplate.syncSend(CapitalMqConstants.TOPIC + ":" + CapitalMqConstants.TAG_WALLET_DEDUCT, req);
  }
}