()
| 1932 | |
| 1933 | #[tokio::test(flavor = "multi_thread")] |
| 1934 | async fn test_session_dead_letters_empty() { |
| 1935 | let agent = Agent::from_config(test_config()).await.unwrap(); |
| 1936 | let qc = SessionQueueConfig::default().with_dlq(Some(100)); |
| 1937 | let opts = SessionOptions::new().with_queue_config(qc); |
| 1938 | let session = agent |
| 1939 | .session("/tmp/test-workspace-dlq", Some(opts)) |
| 1940 | .unwrap(); |
| 1941 | let dead = session.dead_letters().await; |
| 1942 | assert!(dead.is_empty()); |
| 1943 | } |
| 1944 | |
| 1945 | #[tokio::test(flavor = "multi_thread")] |
| 1946 | async fn test_session_queue_metrics_disabled() { |
nothing calls this directly
no test coverage detected