mqtt transport v2

Signed-off-by: Wei Liu <[email protected]>

Author: skeeey

pkg/cloudevents/generic/options/v2/mqtt/transport_test.go

@@ -76,6 +76,11 @@ func setupTestBroker(t *testing.T) (*mochimqtt.Server, func()) {
 	time.Sleep(100 * time.Millisecond)
 
 	cleanup := func() {
+		// Add a delay before broker shutdown to ensure all MQTT client operations
+		// complete. This prevents a race condition where broker shutdown tries to
+		// close listener clients while client deletion is still in progress, which
+		// can cause a deadlock in the mochi-mqtt server's client management.
+		time.Sleep(200 * time.Millisecond)
 		if err := broker.Close(); err != nil {
 			t.Logf("failed to close broker: %v", err)
 		}