update spec to use amqp server

cloudamqp · Jun 19, 2024 · 400106b · 400106b
1 parent f73243e
commit 400106b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/spec/storage_spec.cr b/spec/storage_spec.cr
@@ -101,8 +101,9 @@ describe LavinMQ::DurableQueue do
 
   it "handles files with few extra bytes" do
     queue_name = Random::Secure.hex(10)
-    with_vhost("test_vhost") do |vhost|
-      with_channel(vhost: vhost.name) do |ch|
+    with_amqp_server do |s|
+      vhost = s.vhosts.create("test_vhost")
+      with_channel(s, vhost: vhost.name) do |ch|
         q = ch.queue(queue_name)
         queue = vhost.queues[queue_name].as(LavinMQ::DurableQueue)
         mfile = queue.@msg_store.@segments.first_value