| | |
|---|
| | | import com.xcong.excoin.configurations.RabbitMqConfig; |
|---|
| | | import com.xcong.excoin.modules.station.model.GateStatsEvent; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
|---|
| | | import org.springframework.amqp.rabbit.connection.CorrelationData; |
|---|
| | | import org.springframework.amqp.rabbit.core.RabbitTemplate; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | * JAR 侧 — 统一消息发送器（心跳 / ACK / 策略事件 / Stats） |
|---|
| | | */ |
|---|
| | | @Slf4j |
|---|
| | | @ConditionalOnProperty(name = "app.gate.enabled", havingValue = "true", matchIfMissing = true) |
|---|
| | | @Component |
|---|
| | | public class StatsEventProducer { |
|---|
| | | |
|---|
