@@ -20,13 +20,14 @@ A lightweight transactional message bus on top of RabbitMQ supporting:
20204 ) Publisher confirms
21215 ) [ Reliable messaging] ( https://github.com/wework/grabbit/blob/master/docs/OUTBOX.md ) and local service transactivity via Transaction Outbox pattern
22226 ) Deadlettering
23+ 7 ) [ Structured logging] ( https://github.com/wework/grabbit/blob/master/docs/LOGGING.md )
2324
2425Planned:
2526
26271 ) Deduplication of inbound messages
2728
2829## Stable release
29- the v1.x branch contains the latest stable releases of grabbit and one should track that branch to get point and minor release updates.
30+ the v1.x branch contains the latest stable releases of grabbit and one should track that branch to get point and minor release updates.
3031
3132## Supported transactional resources
32331 ) MySql > 8.0 (InnoDB)
@@ -78,8 +79,8 @@ Register a command handler
7879``` Go
7980
8081
81- handler := func (invocation gbus.Invocation , message *gbus.BusMessage ) error
82- cmd , ok := message.Payload .(SomeCommand)
82+ handler := func (invocation gbus.Invocation , message *gbus.BusMessage ) error {
83+ cmd , ok := message.Payload .(* SomeCommand)
8384 if ok {
8485 fmt.Printf (" handler invoked with message %v " , cmd)
8586 return nil
@@ -96,7 +97,7 @@ Register an event handler
9697
9798
9899eventHandler := func (invocation gbus.Invocation , message *gbus.BusMessage ) {
99- evt , ok := message.Payload .(SomeEvent)
100+ evt , ok := message.Payload .(* SomeEvent)
100101 if ok {
101102 fmt.Printf (" handler invoked with event %v " , evt)
102103 return nil
0 commit comments