File tree Expand file tree Collapse file tree 2 files changed +8
-5
lines changed
Expand file tree Collapse file tree 2 files changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -66,7 +66,8 @@ func main() {
6666 publisher.WithPublisherID (" publisher_id" ),
6767 publisher.WithMiddlewares (
6868 middleware.HelloWorldMiddlewareExecuteBeforePublisher (),
69- middleware.HelloWorldMiddlewareExecuteAfterPublisher ()),
69+ middleware.HelloWorldMiddlewareExecuteAfterPublisher (),
70+ ),
7071 )
7172
7273 publisherChannel , err := rmqConn.Channel ()
@@ -88,7 +89,8 @@ func main() {
8889 consumerChannel,
8990 consumer.WithMiddlewares (
9091 middleware.HelloWorldMiddlewareExecuteAfterInboundMessageHandler (),
91- middleware.HelloWorldMiddlewareExecuteBeforeInboundMessageHandler ()),
92+ middleware.HelloWorldMiddlewareExecuteBeforeInboundMessageHandler (),
93+ ),
9294 consumer.WithQueueName (" consumer_queue" ),
9395 consumer.WithConsumerID (" consumer_id" ),
9496 consumer.WithBatchMessageSize (1 ),
@@ -138,7 +140,6 @@ func handler() goqueue.InboundMessageHandlerFunc {
138140 return m.Ack (ctx)
139141 }
140142}
141-
142143```
143144
144145## Contribution
Original file line number Diff line number Diff line change @@ -39,7 +39,8 @@ func main() {
3939 publisher .WithPublisherID ("publisher_id" ),
4040 publisher .WithMiddlewares (
4141 middleware .HelloWorldMiddlewareExecuteBeforePublisher (),
42- middleware .HelloWorldMiddlewareExecuteAfterPublisher ()),
42+ middleware .HelloWorldMiddlewareExecuteAfterPublisher (),
43+ ),
4344 )
4445
4546 publisherChannel , err := rmqConn .Channel ()
@@ -61,7 +62,8 @@ func main() {
6162 consumerChannel ,
6263 consumer .WithMiddlewares (
6364 middleware .HelloWorldMiddlewareExecuteAfterInboundMessageHandler (),
64- middleware .HelloWorldMiddlewareExecuteBeforeInboundMessageHandler ()),
65+ middleware .HelloWorldMiddlewareExecuteBeforeInboundMessageHandler (),
66+ ),
6567 consumer .WithQueueName ("consumer_queue" ),
6668 consumer .WithConsumerID ("consumer_id" ),
6769 consumer .WithBatchMessageSize (1 ),
You can’t perform that action at this time.
0 commit comments