mon/MonClient: use generic Messenger factory

Signed-off-by: Sage Weil <sage@redhat.com>
(cherry picked from commit e55cb1f68ae1a04cc5d281bea57ee79ef4a8af38)

diff --git a/src/mon/MonClient.cc b/src/mon/MonClient.cc
index 3a6dda46a92340d5b55a5e8c1c025a874e691566..1bbd4675fac66661fcf77864893cf05377932fd7 100644 (file)
--- a/src/mon/MonClient.cc
+++ b/src/mon/MonClient.cc
@@ -12,7 +12,7 @@
  * 
  */
 
-#include "msg/SimpleMessenger.h"
+#include "msg/Messenger.h"
 #include "messages/MMonGetMap.h"
 #include "messages/MMonGetVersion.h"
 #include "messages/MMonGetVersionReply.h"
@@ -114,11 +114,11 @@ int MonClient::get_monmap_privately()
   Mutex::Locker l(monc_lock);
 
   bool temp_msgr = false;
-  SimpleMessenger* smessenger = NULL;
+  Messenger* smessenger = NULL;
   if (!messenger) {
-    messenger = smessenger = new SimpleMessenger(cct,
-                                                 entity_name_t::CLIENT(-1),
-                                                 "temp_mon_client", getpid());
+    messenger = smessenger = Messenger::create(cct,
+                                              entity_name_t::CLIENT(-1),
+                                              "temp_mon_client", getpid());
     messenger->add_dispatcher_head(this);
     smessenger->start();
     temp_msgr = true;
@@ -213,9 +213,9 @@ int MonClient::ping_monitor(const string &mon_id, string *result_reply)
 
   MonClientPinger *pinger = new MonClientPinger(cct, result_reply);
 
-  Messenger *smsgr = new SimpleMessenger(cct,
-                                         entity_name_t::CLIENT(-1),
-                                         "temp_ping_client", getpid());
+  Messenger *smsgr = Messenger::create(cct,
+                                      entity_name_t::CLIENT(-1),
+                                      "temp_ping_client", getpid());
   smsgr->add_dispatcher_head(pinger);
   smsgr->start();