1 files changed, 1 insertions, 12 deletions
diff --git a/common/connectionbase.cpp b/common/connectionbase.cpp
index b399884..5dadf7d 100644
--- a/common/connectionbase.cpp
+++ b/common/connectionbase.cpp
@@ -66,7 +66,7 @@ void ConnectionBase::got_data(uint8_t* data, std::size_t bytes) {
 		m->deserialize(data, bytes);
 	}
 	
-	recv_queue.push(m);
+	got_message(m);
 	
 	request_data(4);
 }
@@ -85,17 +85,6 @@ void ConnectionBase::send(const Message::p& msg) {
 	}
 }
 
-Message::p ConnectionBase::recv() {
-	if(recv_queue.empty()) {
-		return Message::p();
-	}
-	
-	Message::p msg = recv_queue.front();
-	recv_queue.pop();
-	
-	return msg;
-}
-
 ConnectionBase::ConnectionBase() {
 	pending_size = 0;
 }