Skip to content

Add support for Read with Meatadata in MqttIO #9300

Add support for Read with Meatadata in MqttIO

Add support for Read with Meatadata in MqttIO #9300

GitHub Actions / Test Results succeeded Oct 7, 2024 in 0s

All 16 tests pass, 1 skipped in 12s

17 tests  +17   16 ✅ +16   12s ⏱️ +12s
 1 suites + 1    1 💤 + 1 
 1 files   + 1    0 ❌ ± 0 

Results for commit 64c51a4. ± Comparison against earlier commit f3969be.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 skipped test found

There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

17 tests found

There are 17 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWrite
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoPayloadFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveNoTopicFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testDynamicWriteHaveStaticTopic
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testRead
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadHaveNoTopic
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadNoClientId
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadObject
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReadWithMetadata
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testReceiveWithTimeoutAndNoData
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWrite
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteHaveNoConnectionConfiguration
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteHaveNoTopic
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteWithPayloadFn
org.apache.beam.sdk.io.mqtt.MqttIOTest ‑ testWriteWithTopicFn