sqs

Is your feature request related to a problem? Please describe.
I would like to know how Brighter reacts if it receives messages from other systems.

Describe the solution you'd like
Would like to know if you can rely on default behavior or if any additional message headers are needed

Problem

There are some unused and wrongly implemented metadata in RocketMQ.

Describe the bug
Remove the warning moving await from mocha.opts.

DeprecationWarning: Configuration via mocha.opts is DEPRECATED and will be removed from a future version of Mocha. Use RC files or package.json instead.

We have often see developer telling us the problems going on with WPA and then the first way to debug the issue is by going through WPA kubernetes logs for the queue to find what is going on. We should logs events for all the important thing that goes on with the WPA object.

Reasons:

1. Easy to debug.
2. Developer who does have access to wpa logs but has access to their WPA object can tro

Additionally, it would be good if we could reuse the ReplaceOneModel and UpdateOneModel from the sink signatures,
where currently they are expecting a Tuple2[Bson, Bson] for the updates, and a Tuple2[Bson, Document], we could create a case class respectively to wrap those values in a more idiomatic way.
i.e

case class ReplaceOne[Doc](filter: Bson, replacement: Doc) {
 def to