From 1752e116e3cf16cadae37ca55a265f36c7fc2804 Mon Sep 17 00:00:00 2001
From: Dennis Klein <d.klein@gsi.de>
Date: Fri, 1 Mar 2019 15:49:38 +0100
Subject: [PATCH] Fix initialization of inproc queues

---
 fairmq/ofi/Socket.cxx | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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);