diff --git a/source/adios2/engine/dataman/DataManReader.cpp b/source/adios2/engine/dataman/DataManReader.cpp
index 2e5c8f1477..04504982cd 100644
--- a/source/adios2/engine/dataman/DataManReader.cpp
+++ b/source/adios2/engine/dataman/DataManReader.cpp
@@ -29,10 +29,6 @@ DataManReader::DataManReader(IO &io, const std::string &name,
     helper::GetParameter(m_IO.m_Parameters, "Port", m_Port);
     helper::GetParameter(m_IO.m_Parameters, "Timeout", m_Timeout);
     helper::GetParameter(m_IO.m_Parameters, "Verbose", m_Verbosity);
-    helper::GetParameter(m_IO.m_Parameters, "RendezvousReaderCount",
-                         m_RendezvousReaderCount);
-    helper::GetParameter(m_IO.m_Parameters, "RendezvousMilliseconds",
-                         m_RendezvousMilliseconds);
     helper::GetParameter(m_IO.m_Parameters, "DoubleBuffer", m_DoubleBuffer);
 
     m_ZmqRequester.OpenRequester(m_Timeout, m_ReceiverBufferSize);
@@ -74,6 +70,8 @@ DataManReader::DataManReader(IO &io, const std::string &name,
     }
     m_SubscriberThread = std::thread(&DataManReader::SubscriberThread, this);
 
+    m_ZmqRequester.Request("Ready", 5, address);
+
     if (m_Verbosity >= 5)
     {
         std::cout << "DataManReader::DataManReader() Rank " << m_MpiRank
diff --git a/source/adios2/engine/dataman/DataManReader.h b/source/adios2/engine/dataman/DataManReader.h
index 07f9450476..4fae4690b5 100644
--- a/source/adios2/engine/dataman/DataManReader.h
+++ b/source/adios2/engine/dataman/DataManReader.h
@@ -40,8 +40,6 @@ class DataManReader : public Engine
     std::string m_IPAddress;
     int m_Port = 50001;
     int m_Timeout = 5;
-    int m_RendezvousReaderCount = 1;
-    int m_RendezvousMilliseconds = 1000;
     int m_Verbosity = 0;
     bool m_DoubleBuffer = true;
 
diff --git a/source/adios2/engine/dataman/DataManWriter.cpp b/source/adios2/engine/dataman/DataManWriter.cpp
index 81a22c27f2..2b9f1237c0 100644
--- a/source/adios2/engine/dataman/DataManWriter.cpp
+++ b/source/adios2/engine/dataman/DataManWriter.cpp
@@ -32,8 +32,6 @@ DataManWriter::DataManWriter(IO &io, const std::string &name,
     helper::GetParameter(m_IO.m_Parameters, "Verbose", m_Verbosity);
     helper::GetParameter(m_IO.m_Parameters, "RendezvousReaderCount",
                          m_RendezvousReaderCount);
-    helper::GetParameter(m_IO.m_Parameters, "RendezvousMilliseconds",
-                         m_RendezvousMilliseconds);
     helper::GetParameter(m_IO.m_Parameters, "DoubleBuffer", m_DoubleBuffer);
 
     if (m_IPAddress.empty())
@@ -77,6 +75,8 @@ DataManWriter::DataManWriter(IO &io, const std::string &name,
     addJson["ControlAddresses"] = caVec;
     m_AllAddresses = addJson.dump() + '\0';
 
+    m_DataPublisher.OpenPublisher(m_DataAddress, m_Timeout, m_DoubleBuffer);
+
     if (m_RendezvousReaderCount == 0)
     {
         m_ReplyThread = std::thread(&DataManWriter::ReplyThread, this,
@@ -87,11 +87,6 @@ DataManWriter::DataManWriter(IO &io, const std::string &name,
         ReplyThread(m_ControlAddress, m_RendezvousReaderCount);
     }
 
-    m_DataPublisher.OpenPublisher(m_DataAddress, m_Timeout, m_DoubleBuffer);
-
-    std::this_thread::sleep_for(
-        std::chrono::milliseconds(m_RendezvousMilliseconds));
-
     if (m_Verbosity >= 5)
     {
         std::cout << "DataManWriter::DataManWriter() Rank " << m_MpiRank
@@ -202,6 +197,10 @@ void DataManWriter::ReplyThread(const std::string &address, const int times)
             if (r == "Address")
             {
                 replier.SendReply(m_AllAddresses.data(), m_AllAddresses.size());
+            }
+            else if (r == "Ready")
+            {
+                replier.SendReply("OK", 2);
                 ++count;
             }
         }
diff --git a/source/adios2/engine/dataman/DataManWriter.h b/source/adios2/engine/dataman/DataManWriter.h
index 2019fd81c7..ec945c4d7f 100644
--- a/source/adios2/engine/dataman/DataManWriter.h
+++ b/source/adios2/engine/dataman/DataManWriter.h
@@ -42,7 +42,6 @@ class DataManWriter : public Engine
     std::string m_IPAddress;
     int m_Port = 50001;
     int m_RendezvousReaderCount = 1;
-    int m_RendezvousMilliseconds = 1000;
     int m_Timeout = 5;
     int m_Verbosity = 0;
     bool m_DoubleBuffer = false;