connection

test/Makefile

@@ -1,4 +1,7 @@
-.PHONY:mqchannel
+.PHONY:mqconnection
+mqconnection:mqconnectiontest.cpp ../common/msg.pb.cc ../common/protocol.pb.cc
+	g++ $^ -o $@ -std=c++17 -lgtest -lsqlite3 -lprotobuf -I../third/muduo/include
+
 mqchannel:mqchanneltest.cpp ../common/msg.pb.cc ../common/protocol.pb.cc
 	g++ $^ -o $@ -std=c++17 -lgtest -lsqlite3 -lprotobuf -I../third/muduo/include
 
@@ -27,4 +30,4 @@ mqfiletest:mqfiletest.cpp
 	g++ $^ -o $@ -std=c++17
 .PHONY:clean
 clean:
-	rm mqfiletest dir mqroute mqconsumer mqexchangetest mqmessagetest data mqhosttest -rf
+	rm mqfiletest dir mqroute mqconsumer mqexchangetest mqmessagetest data mqhosttest mqchannel -rf

test/mqchanneltest.cpp

@@ -4,10 +4,10 @@ int main()
 {
     XuMQ::ChannelManager::ptr cmp = std::make_shared<XuMQ::ChannelManager>();
     cmp->openChannel("c1",
-        std::make_shared<XuMQ::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"),
-        std::make_shared<XuMQ::ConsumerManager>(),
-        XuMQ::ProtobufCodecPtr(),
-        muduo::net::TcpConnectionPtr(),
-        XuMQ::threadpool::ptr());
+                     std::make_shared<XuMQ::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"),
+                     std::make_shared<XuMQ::ConsumerManager>(),
+                     XuMQ::ProtobufCodecPtr(),
+                     muduo::net::TcpConnectionPtr(),
+                     XuMQ::threadpool::ptr());
     return 0;
 }

test/mqconnectiontest.cpp

@@ -0,0 +1,13 @@
+#include "../server/connection.hpp"
+
+int main()
+{
+    XuMQ::ConnectionManager::ptr cmp = std::make_shared<XuMQ::ConnectionManager>();
+    cmp->newConnection(std::make_shared<XuMQ::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"),
+                       std::make_shared<XuMQ::ConsumerManager>(),
+                       XuMQ::ProtobufCodecPtr(),
+                       muduo::net::TcpConnectionPtr(),
+                       XuMQ::threadpool::ptr());
+
+    return 0;
+}