#343 async_client::try_consume_message_until taking single parameter …

…fails to compile

CHANGELOG.md

@@ -8,6 +8,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 
 ## [Version 1.3.0](https://github.com/eclipse/paho.mqtt.cpp/compare/v1.2.0..v1.3.0) - (2023-12-29)
 
+- Fixed building and using library as DLL on Windows with MSVC
 - Updated License to Eclipse Public License v2.0
 - Updated create and connect options to better deal with MQTT protocol version
 - Defaulting connect version to v5 if specified in create options.

src/mqtt/async_client.h

@@ -795,7 +795,7 @@ class async_client : public virtual iasync_client
 	template <class Clock, class Duration>
 	const_message_ptr try_consume_message_until(const std::chrono::time_point<Clock,Duration>& absTime) {
 		const_message_ptr msg;
-		que_->try_get_until(msg, absTime);
+		que_->try_get_until(&msg, absTime);
 		return msg;
 	}
 

test/unit/test_async_client.cpp

@@ -979,3 +979,9 @@ TEST_CASE("async_client unsubscribe many topics 3 args failure", "[client]")
 	REQUIRE(MQTTASYNC_DISCONNECTED == return_code);
 }
 
+TEST_CASE("async_client consumer timeout", "[client]")
+{
+	// This just compiling shows #343 fixed.
+	async_client client{GOOD_SERVER_URI, CLIENT_ID};
+	client.try_consume_message_until(std::chrono::steady_clock::now());
+}