Merge pull request #44 from JuliaComputing/tan/misc

add missing send_confirm_select method

Author: tanmaykm

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"

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
 # ----------------------------------------