diff --git a/internal/subscriber/subscriber.go b/internal/subscriber/subscriber.go
index f70dc88..7995aef 100644
--- a/internal/subscriber/subscriber.go
+++ b/internal/subscriber/subscriber.go
@@ -129,6 +129,14 @@ func (s *Subscriber) ensureQueue(ch *amqp.Channel) error {
 }
 
 func (s *Subscriber) handleDelivery(ch *amqp.Channel, d amqp.Delivery) {
+	slog.Info("raw message received",
+		"name", s.cfg.Name,
+		"queue", s.cfg.Queue,
+		"source", s.cfg.Source,
+		"delivery_tag", d.DeliveryTag,
+		"body", string(d.Body),
+	)
+
 	disp := HandleMessage(context.Background(), HandleInput{
 		Body:       d.Body,
 		Headers:    map[string]any(d.Headers),