Commit aa868aa
committed
Refactor PGMQueue methods to utilize PGMQOperation for extension checks, queue creation, validation, and message handling
- Replaced direct SQL execution with calls to PGMQOperation methods for checking pgmq and pg_partman extensions.
- Consolidated queue creation, validation, and message sending methods to use PGMQOperation for both sync and async operations.
- Updated method signatures to include optional session and commit parameters for better session management.
- Removed redundant sync and async methods, streamlining the codebase and improving maintainability.1 parent a288482 commit aa868aa
1 file changed
Lines changed: 507 additions & 625 deletions
0 commit comments