Activity
(fix): Fix panic recovery in consumer.go
(fix): Fix panic recovery in consumer.go
(feat): Add topic and data to error log in publish message
(feat): Add topic and data to error log in publish message
(feat): Refactor producer to support publishing messages to a queue
(feat): Refactor producer to support publishing messages to a queue
(fix): Add SubscribeWithoutSNS method to consumer
(fix): Add SubscribeWithoutSNS method to consumer
(feat): Refactor logging in consumer.go
(feat): Refactor logging in consumer.go
(feat): Add SubscribeWithoutSNS method to Consumer interface
(feat): Add SubscribeWithoutSNS method to Consumer interface
(feat): Refactor SNS consumer to support handlers without action
(feat): Refactor SNS consumer to support handlers without action
(feat): Implement func to estimate messages queue
(feat): Implement func to estimate messages queue
(debug): Add debug information for priority check
(debug): Add debug information for priority check
(feat): Refactor and improve PriorityConsume function
(feat): Refactor and improve PriorityConsume function
(feat): implement PriorityConsume function
(feat): implement PriorityConsume function