diff --git a/Framework/Core/include/Framework/ChannelInfo.h b/Framework/Core/include/Framework/ChannelInfo.h
index 1f4bd8bc9e90e..530f3fba49c29 100644
--- a/Framework/Core/include/Framework/ChannelInfo.h
+++ b/Framework/Core/include/Framework/ChannelInfo.h
@@ -97,6 +97,7 @@ struct ForwardChannelInfo {
 
 struct ForwardChannelState {
   TimesliceId oldestForChannel = {0};
+  int64_t droppedMessages = 0;
 };
 
 } // namespace o2::framework
diff --git a/Framework/Core/src/SendingPolicy.cxx b/Framework/Core/src/SendingPolicy.cxx
index e2c00104a8951..ab166bd8a688e 100644
--- a/Framework/Core/src/SendingPolicy.cxx
+++ b/Framework/Core/src/SendingPolicy.cxx
@@ -174,7 +174,7 @@ std::vector<ForwardingPolicy> ForwardingPolicy::createDefaultPolicies()
             .forward = [](fair::mq::Parts& parts, ChannelIndex channelIndex, ServiceRegistryRef registry) {
               auto &proxy = registry.get<FairMQDeviceProxy>();
               auto *channel = proxy.getForwardChannel(channelIndex);
-              OutputChannelState& state = proxy.getOutputChannelState(channelIndex);
+              ForwardChannelState& state = proxy.getForwardChannelState(channelIndex);
               auto timeout = 1000;
               if (state.droppedMessages > 0) {
                 timeout = 0;