diff --git a/internal/pg/pg.go b/internal/pg/pg.go
index c6f298b..bd162cf 100644
--- a/internal/pg/pg.go
+++ b/internal/pg/pg.go
@@ -1,4 +1,4 @@
-package pgutils
+package pg
 
 import (
 	"strconv"
diff --git a/publisher.go b/publisher.go
index 372ee41..d6ed5c7 100644
--- a/publisher.go
+++ b/publisher.go
@@ -111,9 +111,9 @@ func (d *publisher) Publish(ctx context.Context, queue string, msgs ...Message)
 func buildInsertQuery(queue string, msgCount int) string {
 	var sb strings.Builder
 	sb.WriteString("INSERT INTO ")
-	sb.WriteString(pgutils.QuoteIdentifier(queue))
+	sb.WriteString(pg.QuoteIdentifier(queue))
 	sb.WriteString(" (payload, metadata) VALUES ")
-	var params pgutils.StmtParams
+	var params pg.StmtParams
 	for rowIdx := 0; rowIdx < msgCount; rowIdx++ {
 		if rowIdx != 0 {
 			sb.WriteString(",")