The user could create an AMQP Message specifically for streams and the publisher should publish such message
const message = createAmqpMessage({ body: "Hello World!", annotations: { "x-stream-filter-value": "invoices" }})
const publishResult = await publisher.publish(message)