Skip to content

Commit

Permalink
add rabbit mq
Browse files Browse the repository at this point in the history
  • Loading branch information
thorrester committed Sep 24, 2024
1 parent b3efa14 commit de42531
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions tests/rabbitmq_integration.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ use scouter_server::sql::postgres::PostgresClient;
mod test_utils;

#[tokio::test]
#[ignore]
async fn test_api_with_rabbitmq() {
// setup resources
let pool = test_utils::setup_db(true).await.unwrap();
Expand All @@ -13,8 +12,8 @@ async fn test_api_with_rabbitmq() {
let startup = startup_rabbitmq(pool.clone());

match startup.await {
Ok(_) => println!("Successfully started kafka"),
Err(e) => println!("Error starting kafka: {:?}", e),
Ok(_) => println!("Successfully started rabbitmq consumer"),
Err(e) => println!("Error starting rabbitmq consumer: {:?}", e),
}

tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
Expand Down

0 comments on commit de42531

Please sign in to comment.