diff --git a/fairmq/ofi/Socket.cxx b/fairmq/ofi/Socket.cxx
index 2229c81d..13c36073 100644
--- a/fairmq/ofi/Socket.cxx
+++ b/fairmq/ofi/Socket.cxx
@@ -72,8 +72,8 @@ Socket::Socket(Context& context, const string& type, const string& name, const s
         fSendQueueWrite.set_option(recv_max);
         fRecvQueueRead.set_option(send_max);
         fRecvQueueRead.set_option(recv_max);
-        fSendQueueWrite.set_option(send_max);
-        fSendQueueWrite.set_option(recv_max);
+        fRecvQueueWrite.set_option(send_max);
+        fRecvQueueWrite.set_option(recv_max);
 
         // Setup internal queue
         auto hashed_id = std::hash<std::string>()(fId);