Is it possible to generate a new event like queue.purged whenever a queue is purged by the user?. The event can include information like who purged the queue, at what time, number of messages purged, vhost name of the queue.

    <table tableName="pms_brand">
        <generatedKey column="id" sqlStatement="MySql" identity="true"/>
        <!-- 对应表中每一个类型为text的列 -->
        <columnOverride column="brand_story" jdbcType="VARCHAR"/>
    </table>

如下：

databaseChangeLog:
  - changeSet: # 对应一个 ChangeSet 对象
      id: 0 # ChangeSet 编号
      author: calm # 作者
      comment: 空 # 备注

评论的属性是 comment，而不是comments，虽然表DATABASECHANGELOG 中相应的字段叫COMMENTS，正常的记录效果如下：

This tutorial could cover two common solutions to sending large messages through RabbitMQ:

• Compressing the message body
• Saving the data in an external store, and retrieving when the message is consumed

(fyi @kjnilsson)

In the web UI, While Clicking one of the Worker Name, WebUI does not take to the respective page rather it is unresponsive.

**Worker Name | Status | Active | Processed | Failed | Succeeded | Retried | Load Average
celery@abc.com| online | 0 | 2 | 0 | 2 | 0 | 0.06, 0.1, 0.09
celery@bcd.com| online | 0 | 3 | 0

Currently if machinery is misconfigured for the connection to AMQP it will run indefinitely at a exponential backoff. It will be easier for users to detect failure in a production application if the application is allowed to exit out on failures that are not likely going to be recoverable.

There is a lot of supported AMQP features but documentation is missing. People keep asking how to use this library using github issues but this way is no go.

Would be nice to have a brief summary about all main features and use cases in some "Read the docs" style documentation.

Here are things I would like to have documented:

Exchange types and how to declare them:

• simple direct

Reading the documentation for the Consume method in the AQMP module.

I came across this (I think in reference to the nolocal parameter):

It's advisable to use separate connections for Channel.Publish and
Channel.Consume so not to have TCP pushback on publishing affect the
ability to consume messages, so this parameter is here mo

https://pika.readthedocs.io/en/stable/examples/tornado_consumer.html

Running this example throwed TypeError (exchange must be a str or unicode str). And this is caused by the sequence of positional arguments.

def setup_exchange(self, exchange_name):
        """Setup the exchange on RabbitMQ by invoking the Exchange.Declare RPC
        command. When it is complete, the on_exch

We use http_server as input and http_client as one of outputs (for a part of message batch). In case when there is some error coming from http_client, benthos starts to retry this error message indefinitely (#415). However most significant, is that it stops accepting other, normal messages.

Here is the log when I first try to send message which causes http_client to get 500 error, and

我看到可以通过Prometheus搭建监控环境，如果有图文，更容易理解．

Currently, you are not able to use middleware per handler in "clean way" (you can still manually wrap the handler function, or have separated router).

It would be nice to be able to add middleware per handler.

As a good reference point, you can use chi router: https://github.com/go-chi/chi

In commit: celery/kombu@5780f1e
support for queues already defined in Amazon SQS was added.

However, simply by following the instructions at https://docs.celeryproject.org/en/latest/getting-started/brokers/sqs.html and Getting Started page, I must say that I'm still not able to process any message (it's not an issue with credentials or

The docs for Symfony Bundle should be more explicit about extension tags when using different consume commands. I'm referring to https://php-enqueue.github.io/bundle/consumption_extension/#consumption-extension

When using the "enqueue:transport:consume" command a consumption extension needs to be registered with the tag enqueue.transport.consumption_extension (while docs currently only mentio

In documentation about sagas there is this thing about storing saga-id into event metadata. It looks intuitive but it doesn't work out of the box :-(. I would like to make it work. Here is how:

1. from PublishAsync pass sagaId and saga type name into ICommandBus.PublishAsync()
2. overload ICommandBus.PublishAsync() so it takes an extra argument eventMetadata
3. pass event metadata to IAggregate

This isn't really an issue, this is just a request

I am trying to learn how to build microservices with CQRS, ES, reactive programming and messaging, I have a good understanding of the theoretical part but there isn't much hands-on examples about this subject.
Reactive Trader Cloud is the most complete app that I could find which implements all these concepts (and much more), I am