I need to implement manual get of one message (and not subscribe to push) . with node.amqp this would be with channel get
But rabbot does not expose channel. I think I can get to channel using
let channel = rabbit.getQueue(queueName).lastQueue.channel
But this is quite cumbersome. Is this the correct way to do this? is there another way to implement the "pull" message use case?
My use case:
Multiple consumers from one queue
Early ack for long running job (Because don't want to handle channel disconnections, since unacked messages would go to another work and start another task for the same message)
I don't want the the consumer/worker to get another message until it finishes processing the first one
I don't want to be stack in a "nack" loop pushing back messages to the queue while processing the main task
From what I understand, I don't see a way to implement this in a "push" (startSubscribe) scenario - but I need a "pull" scenario
I need to implement manual get of one message (and not subscribe to push) . with node.amqp this would be with channel get
But rabbot does not expose channel. I think I can get to channel using
But this is quite cumbersome. Is this the correct way to do this? is there another way to implement the "pull" message use case?
My use case:
From what I understand, I don't see a way to implement this in a "push" (startSubscribe) scenario - but I need a "pull" scenario
Thanks!