Queue.Pull() and Transaction.Receive() do not return immediately when the queue is empty and the waitingSecond = 0

[francotiveron]

F# code excerpt

        let sw = Stopwatch()
        let q = Queue.Queue(queue, clientId, url, Log, WaitTimeSecondsQueueMessages = 0) 
        sw.Start()
        let pu = q.Pull(1, 0)
        sw.Stop()
        Log.d sw.ElapsedMilliseconds

The printout is always > 1000 when the queue is empty. I would expect to be 0 (edited)

[kubemq]

What are the parameters you are sending on the pull ? Auto Ack is true ? the default is false,

…

On Mon, Jan 3, 2022 at 8:46 AM Franco Tiveron ***@***.***> wrote: F# code excerpt let sw = Stopwatch() let q = Queue.Queue(queue, clientId, url, Log, WaitTimeSecondsQueueMessages = 0) sw.Start() let pu = q.Pull(1, 0) sw.Stop() Log.d sw.ElapsedMilliseconds The printout is always > 1000 when the queue is empty. I would expect to be 0 (edited) — Reply to this email directly, view it on GitHub <#8>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AK5WGXC2TIOFXGS3USOTG3TUUFA33ANCNFSM5LET63WQ> . Triage notifications on the go with GitHub Mobile for iOS <https://apps.apple.com/app/apple-store/id1477376905?ct=notification-email&mt=8&pt=524675> or Android <https://play.google.com/store/apps/details?id=com.github.android&referrer=utm_campaign%3Dnotification-email%26utm_medium%3Demail%26utm_source%3Dgithub>. You are receiving this because you are subscribed to this thread.Message ID: ***@***.***>

[francotiveron]

The Pull method has only 2 parameters

Pull(maxPullMessages: int, waitTimeoutSeconds: int)

What is Auto Ack? there is no mention in the .NET SDK

There is an entire namespace QueueStream in the SDK , but no documentation and not examples in the cookbook. Maybe you intent that one. Are there examples on how to use it outside of the cookbook repo?

[francotiveron]

@kubemq I downloaded the repo and made some tests using the QueueStream API (see code below).

The result is the same, WaitTimeout 0 is not honoured, response never comes back quicker than 1s, regardless the value of AutoAck

let queue = "q-1"
let url = "localhost:50000"

let w = QueueStream(url, "writer")

let m1 = Message(
    Queue = queue
    , Body = Tools.Converter.ToByteArray "message-1"
    , Metadata = "meta-1"
) 

let sendRequest = SendRequest(ResizeArray([m1]))

let sendResponse = w.Send(sendRequest).Result

let r = QueueStream(url, "reader")

let pollRequest = PollRequest(Queue = queue, WaitTimeout = 0, MaxItems = 1, AutoAck = true)

let sw = Stopwatch()
sw.Start()
let pollResponse = r.Poll(pollRequest).Result
sw.Stop()

[kubemq]

Please use the QueueStream implementation