update submodules to latest pre-release (#170)

update submodules to latest pre-release

Co-authored-by: Dengke Tang <dengket@amazon.com>

Author: TingDaoK

aws-common-runtime/aws-c-auth

@@ -1096,12 +1096,8 @@ PyObject *aws_py_mqtt_client_connection_resubscribe_existing_topics(PyObject *se
         /* C will not be invoking the python callback */
         Py_DECREF(suback_callback);
 
-        /* Don't raise a Python exception if error is AWS_ERROR_MQTT_NO_TOPICS_FOR_RESUBSCRIBE.
-         * This is a harmless error, we'll just return None instead of a msg_id */
         int aws_err = aws_last_error();
-        if (aws_err == AWS_ERROR_MQTT_NO_TOPICS_FOR_RESUBSCRIBE) {
-            Py_RETURN_NONE;
-        } else {
+        if (aws_err) {
             PyErr_SetAwsLastError();
             return NULL;
         }

aws-common-runtime/aws-c-common

@@ -143,14 +143,29 @@ def on_message(**kwargs):
         connection.disconnect().result(TIMEOUT)
 
     def test_on_message(self):
-        connection = self._test_connection()
+        config = Config.get()
+        elg = EventLoopGroup()
+        resolver = DefaultHostResolver(elg)
+        bootstrap = ClientBootstrap(elg, resolver)
+
+        tls_opts = TlsContextOptions.create_client_with_mtls(config.cert, config.key)
+        tls = ClientTlsContext(tls_opts)
+
+        client = Client(bootstrap, tls)
+        connection = Connection(
+            client=client,
+            client_id=create_client_id(),
+            host_name=config.endpoint,
+            port=8883)
         received = Future()
 
         def on_message(**kwargs):
             received.set_result(kwargs)
 
+        # on_message for connection has to be set before connect, or possible race will happen
         connection.on_message(on_message)
 
+        connection.connect().result(TIMEOUT)
         # subscribe without callback
         subscribed, packet_id = connection.subscribe(self.TEST_TOPIC, QoS.AT_LEAST_ONCE)
         subscribed.result(TIMEOUT)