fixes

pagopa · May 23, 2024 · 5ef8b5f · 5ef8b5f
1 parent ab09099
commit 5ef8b5f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/it/gov/pagopa/wispconverter/servicebus/RTConsumer.java b/src/main/java/it/gov/pagopa/wispconverter/servicebus/RTConsumer.java
@@ -44,7 +44,7 @@ public class RTConsumer {
     private ServiceBusProcessorClient receiverClient;
 
     @EventListener(ApplicationReadyEvent.class)
-    public void refreshCache() {
+    public void initializeClient() {
         if(receiverClient!=null){
             log.info("[Scheduled] Starting RTConsumer {}", ZonedDateTime.now());
             receiverClient.start();
@@ -73,6 +73,7 @@ public void preDestroy(){
 
     public void processMessage(ServiceBusReceivedMessageContext context) {
         ServiceBusReceivedMessage message = context.getMessage();
+        log.info("Processing "+message.getMessageId());
         try{
             String cosmosId = new String(message.getBody().toBytes());
             String station = message.getSubject();