Merge pull request #44 from JuliaComputing/tan/misc

add missing send_confirm_select method
JuliaComputing · May 7, 2021 · d7bc69f · d7bc69f · tanmaykm · May 7, 2021
2 parents 28c343c + ed36f9f
commit d7bc69f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/Project.toml b/Project.toml
@@ -3,7 +3,7 @@ uuid = "79c8b4cd-a41a-55fa-907c-fab5288e1383"
 keywords = ["amqpclient", "rabbitmq", "amqp", "amqp-client", "message-queue"]
 license = "MIT"
 desc = "A Julia AMQP (Advanced Message Queuing Protocol) / RabbitMQ Client."
-version = "0.4.1"
+version = "0.4.2"
 
 [deps]
 Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"

diff --git a/src/protocol.jl b/src/protocol.jl
@@ -938,10 +938,12 @@ end
 
 function confirm_select(chan::MessageChannel; nowait::Bool=false, timeout::Int=DEFAULT_TIMEOUT)
     _wait_resp(chan, true, nowait, on_confirm_select_ok, :Confirm, :SelectOk, false, timeout) do
-        send_confirm_select(chan, nowait)
+        send_confirm_select(chan)
     end
 end
 
+send_confirm_select(chan::MessageChannel) = send(chan, TAMQPMethodPayload(:Confirm, :Select, ()))
+
 # ----------------------------------------
 # Confirm end
 # ----------------------------------------