Fix properties used by queue worker and add concurrent function invocation - Githubissues

openfaas / nats-queue-worker

Queue-worker for OpenFaaS with NATS Streaming

https://docs.openfaas.com/reference/async/

MIT License

129 stars 59 forks source link

Fix properties used by queue worker and add concurrent function invocation #94

Closed matthiashanel closed 4 years ago

matthiashanel commented 4 years ago

Expected Behaviour

The queue worker uses nats as queue. Because of that some options don't quite fit:

Current Behaviour

durable name is optional
durable is created with StartWithLastReceived
because of the blocking nature of the callback
- Max In flight is not as use-full.
- Messages are processed sequentially.

Possible Solution

durable name can be derived from the subject name
durable is created with DeliverAllAvailable
process max in flight many messages concurrently
- this would require specifying manual ack as well.

Your Environment

This is a result of code inspection.