diff --git a/rust/phoenix-channel/src/lib.rs b/rust/phoenix-channel/src/lib.rs
index fa6a0627d..410f838b0 100644
--- a/rust/phoenix-channel/src/lib.rs
+++ b/rust/phoenix-channel/src/lib.rs
@@ -342,20 +342,12 @@ where
                     };
 
                     match message.payload {
-                        Payload::Message(msg) => match message.reference {
-                            None => {
-                                return Poll::Ready(Ok(Event::InboundMessage {
-                                    topic: message.topic,
-                                    msg,
-                                }));
-                            }
-                            Some(reference) => {
-                                return Poll::Ready(Ok(Event::InboundReq {
-                                    req_id: InboundRequestId(reference),
-                                    req: msg,
-                                }))
-                            }
-                        },
+                        Payload::Message(msg) => {
+                            return Poll::Ready(Ok(Event::InboundMessage {
+                                topic: message.topic,
+                                msg,
+                            }))
+                        }
                         Payload::Reply(Reply::Error { reason }) => {
                             return Poll::Ready(Ok(Event::ErrorResponse {
                                 topic: message.topic,
@@ -527,11 +519,6 @@ pub enum Event<TInboundMsg, TOutboundRes> {
         topic: String,
         msg: TInboundMsg,
     },
-    /// The server sent us a request and is expecting a response.
-    InboundReq {
-        req_id: InboundRequestId,
-        req: TInboundMsg,
-    },
     Disconnect(String),
 }
 
diff --git a/rust/relay/src/main.rs b/rust/relay/src/main.rs
index 6a7f33af9..4d7ab1118 100644
--- a/rust/relay/src/main.rs
+++ b/rust/relay/src/main.rs
@@ -523,9 +523,7 @@ where
                     tracing::debug!(target: "relay", "Heartbeat sent to portal");
                     continue;
                 }
-                Some(Poll::Ready(Ok(
-                    Event::InboundMessage { msg: (), .. } | Event::InboundReq { req: (), .. },
-                )))
+                Some(Poll::Ready(Ok(Event::InboundMessage { msg: (), .. })))
                 | Some(Poll::Pending)
                 | None => {}
             }