diff --git a/lib/utils/message-buffer.hpp b/lib/utils/message-buffer.hpp
index 8d751bff..a876ff68 100644
--- a/lib/utils/message-buffer.hpp
+++ b/lib/utils/message-buffer.hpp
@@ -8,6 +8,7 @@ namespace advss {
 template<class T> class MessageBuffer {
 public:
 	bool Empty();
+	void Clear();
 	void AppendMessage(const T &);
 	std::optional<T> ConsumeMessage();
 
@@ -22,6 +23,12 @@ template<class T> inline bool MessageBuffer<T>::Empty()
 	return _buffer.empty();
 }
 
+template<class T> inline void MessageBuffer<T>::Clear()
+{
+	std::lock_guard<std::mutex> lock(_mutex);
+	_buffer.clear();
+}
+
 template<class T> inline void MessageBuffer<T>::AppendMessage(const T &message)
 {
 	std::lock_guard<std::mutex> lock(_mutex);