refactor.

lichao

2021-03-30 8cbb55f3066f71f5a4328193414d4555c87e96be

 src/pubsub.cpp

@@ -18,17 +18,17 @@
#include "pubsub.h"
#include <chrono>
#include "bh_util.h"
#include "defs.h"

namespace bhome_shm {

using namespace std::chrono_literals;
const MQId kBusQueueId = boost::uuids::string_generator()("01234567-89ab-cdef-8349-1234567890ff");
const int kMaxWorker = 16;
using namespace bhome_msg;

BusManager::BusManager(SharedMemory &shm):
shm_(shm),
busq_(kBusQueueId, shm, 1000),
busq_(kBHBusQueueId, shm, 1000),
run_(false)
{
}