diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/filter/TableParameterListenerEventFilter.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/filter/TableParameterListenerEventFilter.java index d3be3b3d..7a49d798 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/filter/TableParameterListenerEventFilter.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/filter/TableParameterListenerEventFilter.java @@ -17,19 +17,30 @@ import java.util.Map; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import com.expedia.apiary.extensions.receiver.common.event.ListenerEvent; - import com.expediagroup.beekeeper.core.model.LifecycleEventType; @Component public class TableParameterListenerEventFilter implements ListenerEventFilter { + private static final Logger log = LoggerFactory.getLogger(TableParameterListenerEventFilter.class); + @Override public boolean isFiltered(ListenerEvent listenerEvent, LifecycleEventType lifecycleEventType) { Map tableParameters = listenerEvent.getTableParameters(); + // Log the table params + if (tableParameters != null && !tableParameters.isEmpty()) { + log.info("Processing table parameters for event: {}", tableParameters); + log.debug("Detailed table parameters: {}", tableParameters); + } else { + log.info("No table parameters found for event."); + } + if (tableParameters == null) { return true; } @@ -37,3 +48,4 @@ public boolean isFiltered(ListenerEvent listenerEvent, LifecycleEventType lifecy return !Boolean.parseBoolean(tableParameters.get(lifecycleEventType.getTableParameterName())); } } +