Skip to content

Commit

Permalink
remove obsolete spec
Browse files Browse the repository at this point in the history
  • Loading branch information
kickster97 committed Oct 10, 2024
1 parent 0b5ccdb commit c9100cf
Showing 1 changed file with 0 additions and 26 deletions.
26 changes: 0 additions & 26 deletions spec/mqtt/integrations/publish_spec.cr
Original file line number Diff line number Diff line change
Expand Up @@ -27,31 +27,5 @@ module MqttSpecs
end
end
end

it "should put the message in a queue" do
with_server do |server|
with_channel(server) do |ch|
x = ch.exchange("amq.topic", "topic")
q = ch.queue("test")
q.bind(x.name, q.name)

with_client_io(server) do |io|
connect(io)

payload = slice = Bytes[1, 254, 200, 197, 123, 4, 87]
ack = publish(io, topic: "test", payload: payload, qos: 1u8)
ack.should_not be_nil

body = q.get(no_ack: true).try do |v|
s = Slice(UInt8).new(payload.size)
v.body_io.read(s)
s
end
body.should eq(payload)
disconnect(io)
end
end
end
end
end
end

0 comments on commit c9100cf

Please sign in to comment.