diff --git a/internal/signaling/stores/postgres.go b/internal/signaling/stores/postgres.go
index 017e418..65392ed 100644
--- a/internal/signaling/stores/postgres.go
+++ b/internal/signaling/stores/postgres.go
@@ -97,16 +97,9 @@ func (s *PostgresStore) listen(ctx context.Context) error {
 		}
 		rawCompressed = rawCompressed[:l]
 
-		var raw []byte
-		if util.IsGzipCompressed(rawCompressed) {
-			raw, err = util.GzipDecompress(rawCompressed)
-			if err != nil {
-				return fmt.Errorf("failed to decompress payload: %w", err)
-			}
-		} else {
-			logger := logging.GetLogger(ctx)
-			logger.Warn("received uncompressed notification", zap.String("topic", topic))
-			raw = rawCompressed
+		raw, err := util.GzipDecompress(rawCompressed)
+		if err != nil {
+			return fmt.Errorf("failed to decompress payload: %w", err)
 		}
 
 		s.notify(ctx, topic, raw)
diff --git a/internal/util/gzip.go b/internal/util/gzip.go
index 64e14ca..5414095 100644
--- a/internal/util/gzip.go
+++ b/internal/util/gzip.go
@@ -6,11 +6,6 @@ import (
 	"io"
 )
 
-func IsGzipCompressed(data []byte) bool {
-	// Gzip magic bytes: 0x1f 0x8b
-	return len(data) >= 2 && data[0] == 0x1f && data[1] == 0x8b
-}
-
 func GzipCompress(input []byte) ([]byte, error) {
 	var buf bytes.Buffer
 	writer, err := gzip.NewWriterLevel(&buf, gzip.BestSpeed)