diff --git a/crates/ingress-dispatcher/src/dispatcher.rs b/crates/ingress-dispatcher/src/dispatcher.rs
index dcc0e2a84..6c4d905f8 100644
--- a/crates/ingress-dispatcher/src/dispatcher.rs
+++ b/crates/ingress-dispatcher/src/dispatcher.rs
@@ -20,8 +20,7 @@ use restate_bifrost::Bifrost;
 use restate_core::metadata;
 use restate_core::network::MessageHandler;
 use restate_node_protocol::codec::Targeted;
-use restate_node_protocol::ingress::{IngressCorrelationId, IngressMessage};
-use restate_node_protocol::RpcMessage;
+use restate_node_protocol::ingress::IngressMessage;
 use restate_storage_api::deduplication_table::DedupInformation;
 use restate_types::identifiers::{InvocationId, PartitionKey, WithPartitionKey};
 use restate_types::ingress::InvocationResponseCorrelationIds;
diff --git a/crates/ingress-dispatcher/src/lib.rs b/crates/ingress-dispatcher/src/lib.rs
index b9354f55f..078e0fb11 100644
--- a/crates/ingress-dispatcher/src/lib.rs
+++ b/crates/ingress-dispatcher/src/lib.rs
@@ -11,7 +11,6 @@
 use bytes::Bytes;
 use bytestring::ByteString;
 use restate_core::metadata;
-pub use restate_node_protocol::ingress::IngressCorrelationId;
 use restate_schema_api::subscription::{EventReceiverServiceType, Sink, Subscription};
 use restate_types::identifiers::{
     partitioner, IdempotencyId, InvocationId, PartitionKey, ServiceId, WithPartitionKey,
diff --git a/crates/node-protocol/src/ingress.rs b/crates/node-protocol/src/ingress.rs
index 6774530ff..92fad60a1 100644
--- a/crates/node-protocol/src/ingress.rs
+++ b/crates/node-protocol/src/ingress.rs
@@ -13,7 +13,6 @@ use serde::{Deserialize, Serialize};
 
 use crate::common::TargetName;
 use crate::define_message;
-use crate::RpcMessage;
 
 #[derive(
     Debug,