diff --git a/nmmsender.cc b/nmmsender.cc
new file mode 100644
index 0000000..5e244d1
--- /dev/null
+++ b/nmmsender.cc
@@ -0,0 +1,108 @@
+#include "nmmsender.hh"
+#include "comboaddress.hh"
+#include "swrappers.hh"
+#include "sclasses.hh"
+#include <random>
+#include "navmon.hh"
+#include <algorithm>
+
+using namespace std;
+
+void NMMSender::sendTCPThread(Destination* d)
+{
+  struct NameError{};
+  for(;;) {
+    ComboAddress chosen;
+    try {
+      vector<ComboAddress> addrs;
+      for(;;) {
+        addrs=resolveName(d->dst, true, true);
+        if(!addrs.empty())
+          break;
+          
+        cerr<<humanTimeNow()<<" Unable to resolve "<<d->dst<<", sleeping and trying again later"<<endl;
+        throw NameError();
+      }
+          
+      std::random_device rng;
+      std::mt19937 urng(rng());
+      std::shuffle(addrs.begin(), addrs.end(), urng);
+
+      for(auto& addr: addrs)  {
+        if(!addr.sin4.sin_port)
+          addr.sin4.sin_port = ntohs(29603);
+        chosen=addr;
+        Socket s(addr.sin4.sin_family, SOCK_STREAM);
+        SocketCommunicator sc(s);
+        sc.setTimeout(3);
+        sc.connect(addr);
+        if (d_debug) { cerr<<humanTimeNow()<<" Connected to "<<d->dst<<" on "<<addr.toStringWithPort()<<endl; }
+        for(;;) {
+          std::string msg;
+          {
+            std::lock_guard<std::mutex> mut(d->mut);
+            if(!d->queue.empty()) {
+              msg = d->queue.front();
+            }
+          }
+          if(!msg.empty()) {
+            sc.writen(msg);
+            std::lock_guard<std::mutex> mut(d->mut);
+            d->queue.pop_front();
+          }
+          else usleep(100000);
+        }
+      }
+    }
+    catch(NameError&) {
+      {
+        std::lock_guard<std::mutex> mut(d->mut);
+        if (d_debug) { cerr<<humanTimeNow()<<" There are now "<<d->queue.size()<<" messages queued for "<<d->dst<<endl; }
+      }
+      sleep(30);
+    }
+    catch(std::exception& e) {
+      if (d_debug) { cerr<<humanTimeNow()<<" Sending thread for "<<d->dst<<" via "<<chosen.toStringWithPort()<<" had error: "<<e.what()<<endl; }
+      {
+        std::lock_guard<std::mutex> mut(d->mut);
+        if (d_debug) { cerr<<humanTimeNow()<<" There are now "<<d->queue.size()<<" messages queued for "<<d->dst<<endl; }
+      }
+      sleep(1);
+    }
+    catch(...) {
+      if (d_debug) { cerr<<humanTimeNow()<<" Sending thread for "<<d->dst <<" via "<<chosen.toStringWithPort()<<" had error"; }
+      {
+        std::lock_guard<std::mutex> mut(d->mut);
+        if (d_debug) { cerr<<"There are now "<<d->queue.size()<<" messages queued for "<<d->dst<<" via "<<chosen.toStringWithPort()<<endl; }
+      }
+      sleep(1);
+    }
+  }
+}
+
+
+void NMMSender::emitNMM(const NavMonMessage& nmm)
+{
+  for(auto& d : d_dests) {
+    d->emitNMM(nmm);
+  }
+}
+
+void NMMSender::Destination::emitNMM(const NavMonMessage& nmm)
+{
+  string out;
+  nmm.SerializeToString(& out);
+  string msg("bert");
+  
+  uint16_t len = htons(out.size());
+  msg.append((char*)&len, 2);
+  msg.append(out);
+
+  if(!dst.empty()) {
+    std::lock_guard<std::mutex> l(mut);
+    queue.push_back(msg);
+  }
+  else
+    writen2(fd, msg.c_str(), msg.size());
+}
+
diff --git a/nmmsender.hh b/nmmsender.hh
new file mode 100644
index 0000000..de482d8
--- /dev/null
+++ b/nmmsender.hh
@@ -0,0 +1,53 @@
+#pragma once
+#include <string>
+#include <deque>
+#include <atomic>
+#include "navmon.pb.h"
+#include <thread>
+#include <mutex>
+
+class NMMSender
+{
+  struct Destination
+  {
+    int fd{-1};
+    std::string dst;
+    std::string fname;
+
+    std::deque<std::string> queue;
+    std::mutex mut;
+    void emitNMM(const NavMonMessage& nmm);
+  };
+  
+public:
+  void addDestination(int fd)
+  {
+    auto d = std::make_unique<Destination>();
+    d->fd = fd;
+    d_dests.push_back(std::move(d));
+  }
+  void addDestination(const std::string& dest)
+  {
+    auto d = std::make_unique<Destination>();
+    d->dst = dest;
+    d_dests.push_back(std::move(d));
+  }
+
+  void launch()
+  {
+    for(auto& d : d_dests) {
+      if(!d->dst.empty()) {
+        std::thread t(&NMMSender::sendTCPThread, this, d.get());
+        t.detach();
+      }
+    }
+  }
+  
+  void sendTCPThread(Destination* d);
+
+  void emitNMM(const NavMonMessage& nmm);
+  bool d_debug{false};
+private:
+
+  std::vector<std::unique_ptr<Destination>> d_dests;
+};