Skip to content

Commit 971fcfe

Browse files
authored
fix: log processing error (#46)
1 parent 517f76e commit 971fcfe

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

README.md

+1
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ Inhooks listens to HTTP webhooks and saves the messages to Redis. A processing m
2525
- Fast, concurrent processing
2626
- Supports delayed processing
2727
- Supports retries on failure with configurable number of attempts, interval and constant or exponential backoff
28+
- Supports different HTTP payloads types: JSON, x-www-form-urlencoded, multipart/form-data
2829
- ... more features planned
2930

3031
## Usage

pkg/supervisor/ready.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ func (s *Supervisor) startReadyProcessor(ctx context.Context, f *models.Flow, si
6666

6767
processingErr := s.messageProcessor.Process(ctx, sink, m)
6868
if processingErr != nil {
69-
logger.Info("message processing failed")
69+
logger.Info("message processing failed", zap.Error(processingErr))
7070
queuedInfo, err := s.processingResultsSvc.HandleFailed(ctx, sink, m, processingErr)
7171
if err != nil {
7272
logger.Error("could not handle failed processing", zap.Error(err))

0 commit comments

Comments
 (0)