Merge branch 'main' into 30-prometheus-exporter

didil · Jun 24, 2024 · 4dbf79f · 4dbf79f
2 parents e843a32 + d078d8b
commit 4dbf79f
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 3 deletions.
diff --git a/.release-please-manifest.json b/.release-please-manifest.json
@@ -1 +1 @@
-{".":"0.1.6"}
+{".":"0.1.7"}
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,5 +1,12 @@
 # Changelog
 
+## [0.1.7](https://github.com/didil/inhooks/compare/v0.1.6...v0.1.7) (2023-08-29)
+
+
+### Bug Fixes
+
+* log processing error ([#46](https://github.com/didil/inhooks/issues/46)) ([971fcfe](https://github.com/didil/inhooks/commit/971fcfe1b231918ca7e561a46f93bf0b68686cef))
+
 ## [0.1.6](https://github.com/didil/inhooks/compare/v0.1.5...v0.1.6) (2023-08-09)
 
 

diff --git a/README.md b/README.md
@@ -25,6 +25,7 @@ Inhooks listens to HTTP webhooks and saves the messages to Redis. A processing m
 - Fast, concurrent processing
 - Supports delayed processing
 - Supports retries on failure with configurable number of attempts, interval and constant or exponential backoff
+- Supports different HTTP payloads types: JSON, x-www-form-urlencoded, multipart/form-data
 - ... more features planned
 
 ## Usage

diff --git a/pkg/supervisor/ready.go b/pkg/supervisor/ready.go
@@ -84,9 +84,8 @@ func (s *Supervisor) startReadyProcessor(ctx context.Context, f *models.Flow, si
 
 			processingErr := s.messageProcessor.Process(ctx, sink, m)
 			if processingErr != nil {
-				logger.Info("message processing failed")
+				logger.Info("message processing failed", zap.Error(processingErr))
 				messageProcessingFailureCounter.Inc()
-
 				queuedInfo, err := s.processingResultsSvc.HandleFailed(ctx, sink, m, processingErr)
 				if err != nil {
 					logger.Error("could not handle failed processing", zap.Error(err))