This commit is contained in:
okx-code
2025-10-07 05:20:38 +01:00
parent 711871dd01
commit e23d222d5d

View File

@@ -54,6 +54,7 @@ public class RabbitHandler {
}
};
try {
logger.info("Starting listen");
String queue = incomingChannel.queueDeclare().getQueue();
incomingChannel.queueBind(queue, incomingQueue, KiraGateway.PROXY_SERVER_NAME);
incomingChannel.basicConsume(queue, true, deliverCallback, consumerTag -> {