Loading src/main/java/es/redmic/commandslib/commands/CommandHandler.java +1 −1 Original line number Diff line number Diff line Loading @@ -61,7 +61,7 @@ public abstract class CommandHandler implements ApplicationEventPublisherAware { if (future != null) { future.complete(ex);// future.complete(ex); } else { logger.info("Petición asíncrona no resgistrada"); logger.warn("Petición asíncrona no resgistrada para sessionId: " + sessionId); } return; }); Loading src/main/java/es/redmic/commandslib/gateway/CommandGateway.java +1 −2 Original line number Diff line number Diff line Loading @@ -21,7 +21,6 @@ public class CommandGateway implements ApplicationListener<BrokerEvent> { protected KafkaTemplate<String, Event> kafkaTemplate; public CommandGateway() { logger.info("Arrancando command gateway"); } @Override Loading @@ -31,7 +30,7 @@ public class CommandGateway implements ApplicationListener<BrokerEvent> { String topic = brokerEvent.getTopic(); logger.info("sending payload='{}' to topic='{}'", evt, topic); logger.debug("sending payload='{}' to topic='{}'", evt, topic); ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, evt.getAggregateId(), evt); Loading Loading
src/main/java/es/redmic/commandslib/commands/CommandHandler.java +1 −1 Original line number Diff line number Diff line Loading @@ -61,7 +61,7 @@ public abstract class CommandHandler implements ApplicationEventPublisherAware { if (future != null) { future.complete(ex);// future.complete(ex); } else { logger.info("Petición asíncrona no resgistrada"); logger.warn("Petición asíncrona no resgistrada para sessionId: " + sessionId); } return; }); Loading
src/main/java/es/redmic/commandslib/gateway/CommandGateway.java +1 −2 Original line number Diff line number Diff line Loading @@ -21,7 +21,6 @@ public class CommandGateway implements ApplicationListener<BrokerEvent> { protected KafkaTemplate<String, Event> kafkaTemplate; public CommandGateway() { logger.info("Arrancando command gateway"); } @Override Loading @@ -31,7 +30,7 @@ public class CommandGateway implements ApplicationListener<BrokerEvent> { String topic = brokerEvent.getTopic(); logger.info("sending payload='{}' to topic='{}'", evt, topic); logger.debug("sending payload='{}' to topic='{}'", evt, topic); ListenableFuture<SendResult<String, Event>> future = kafkaTemplate.send(topic, evt.getAggregateId(), evt); Loading