grafana / xk6-amqp

A k6 extension for publishing and consuming messages from queues and exchanges using AMQP 0.9.1.
Apache License 2.0
25 stars 28 forks source link

per-VU connection/connection management #24

Closed swantzter closed 11 months ago

swantzter commented 1 year ago

I'm trying to set up a test where I want to be publishing messages more like our real-life scenarios where say 100 connections are each publishing messages, but Amqp.start() seem to overwrite the connection globally meaning that I'll only be using the connection created by the last call to start?

I'd like to suggest that Amqp.start() returns a connection ID which can then be passed to the various functions to use that connection. For compat I'd suggest that the current behaviour is kept if no connection ID is included in the call