diff options
| author | PradeepKiruvale <pradeepkumar.kj@softwareag.com> | 2022-02-24 10:50:09 +0530 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-24 10:50:09 +0530 |
| commit | 4c4419400fdec8ed05a311ddc5790831f926ce07 (patch) | |
| tree | b1e191cd2b307c72ecee95a2c4e2a09897737eb8 /crates/core | |
| parent | cae66180e676c5cc1cc94ee576c725d4df0858c5 (diff) | |
[870] wait till messages synced (#904)
Diffstat (limited to 'crates/core')
| -rw-r--r-- | crates/core/tedge_mapper/src/c8y/tests.rs | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/crates/core/tedge_mapper/src/c8y/tests.rs b/crates/core/tedge_mapper/src/c8y/tests.rs index aaca2009..b300bf0f 100644 --- a/crates/core/tedge_mapper/src/c8y/tests.rs +++ b/crates/core/tedge_mapper/src/c8y/tests.rs @@ -370,7 +370,6 @@ async fn c8y_mapper_alarm_mapping_to_smartrest() { c8y_mapper.abort(); } - #[tokio::test(flavor = "multi_thread", worker_threads = 2)] #[serial] async fn c8y_mapper_syncs_pending_alarms_on_startup() { @@ -381,6 +380,10 @@ async fn c8y_mapper_syncs_pending_alarms_on_startup() { // Start the C8Y Mapper let c8y_mapper = start_c8y_mapper(broker.port).await.unwrap(); + let mut internal_messages = broker + .messages_published_on("c8y-internal/alarms/critical/temperature_alarm") + .await; + let _ = broker .publish_with_opts( "tedge/alarms/critical/temperature_alarm", @@ -399,6 +402,15 @@ async fn c8y_mapper_syncs_pending_alarms_on_startup() { ) .await; + // Wait till the message get synced to internal topic + mqtt_tests::assert_received_all_expected( + &mut internal_messages, + TEST_TIMEOUT_MS, + &["Temperature very high"], + ) + .await; + + // stop the mapper c8y_mapper.abort(); //Publish a new alarm while the mapper is down @@ -425,7 +437,7 @@ async fn c8y_mapper_syncs_pending_alarms_on_startup() { // .unwrap(); // Restart the C8Y Mapper - let _ = start_c8y_mapper(broker.port).await.unwrap(); + let c8y_mapper = start_c8y_mapper(broker.port).await.unwrap(); // Ignored until the rumqttd broker bug that doesn't handle empty retained messages // Expect the previously missed clear temperature alarm message |