From a5944eb486f714e4af5aeae03928a120822481d9 Mon Sep 17 00:00:00 2001
From: Willem Melching <willem.melching@gmail.com>
Date: Wed, 13 Nov 2019 17:25:39 -0800
Subject: [PATCH] add conflate parameter for SubSocket::create

---
 messaging/messaging.cc  | 7 +++++++
 messaging/messaging.hpp | 1 +
 2 files changed, 8 insertions(+)

diff --git a/messaging/messaging.cc b/messaging/messaging.cc
index 241bcbbc0b2895..61a078b15e4179 100644
--- a/messaging/messaging.cc
+++ b/messaging/messaging.cc
@@ -36,6 +36,13 @@ SubSocket * SubSocket::create(Context * context, std::string endpoint, std::stri
   return s;
 }
 
+SubSocket * SubSocket::create(Context * context, std::string endpoint, std::string address, bool conflate){
+  SubSocket *s = SubSocket::create();
+  s->connect(context, endpoint, address, conflate);
+
+  return s;
+}
+
 PubSocket * PubSocket::create(){
   PubSocket * s;
   if (std::getenv("ZMQ")){
diff --git a/messaging/messaging.hpp b/messaging/messaging.hpp
index 95e34c0d67f4dc..4a9eee315cd64f 100644
--- a/messaging/messaging.hpp
+++ b/messaging/messaging.hpp
@@ -30,6 +30,7 @@ class SubSocket {
   static SubSocket * create();
   static SubSocket * create(Context * context, std::string endpoint);
   static SubSocket * create(Context * context, std::string endpoint, std::string address);
+  static SubSocket * create(Context * context, std::string endpoint, std::string address, bool conflate);
   virtual ~SubSocket(){};
 };