chore: upload *

CHANGELOG.md

@@ -6,3 +6,12 @@ Initial version.
 - feat: Includes the ability to create, purge, drop a `Queue`.
 - feat: Includes the ability to send, read, pop, archive, delete a `Message`.
 - feat: Includes the ability to set a `vt` (visibility timeout).
+
+## 2.0.0
+
+- feat: Improve performance by using connection pool.
+- feat: Make `Queue` disposable.
+- feat: Use postgres as client for pgmq
+- feat: Add cancellation on request execution.
+- feat: Add support of prisma to manage `Queue`.
+- feat: Add fromJson and toJson on `Messsage`.

README.md

@@ -1,7 +1,7 @@
 ## Dart PGMQ 
 A dart client for Postgres Message Queue ([PGMQ](https://github.com/tembo-io/pgmq)).
 
-### Usage
+### Setup
 
 ```bash
 # Start a Postgres instance
@@ -23,7 +23,9 @@ CREATE SCHEMA pgmq;
 CREATE EXTENSION pgmq;
 ```
 
-### Then
+### Usage
+
+- With Postgresql
 
 ```dart
 // Create a database connection
@@ -46,6 +48,20 @@ final pgmq = await Pgmq.createConnection(param: databaseParam);
 final queue = await pgmq.createQueue(queueName: queueName);
 ```
 
+- With Prisma
+
+```dart
+// Create a pgmq connection with PrismaClient
+final pgmq = Pgmq.createConnectionUsingPrisma(prismaClient: PrismaClient());
+```
+
+```dart
+// Create a queue [queueName]
+final queue = await pgmq.createQueue(queueName: queueName);
+```
+
+### Then
+
 ```dart
 // Send a message
 queue.send({"foo": "bar"});

example/example_delete.dart → example/delete.dart

@@ -5,7 +5,7 @@ Future<void> main() async {
   final databaseParam = DatabaseConnection(
       host: 'localhost',
       database: 'postgres',
-      password: 'password',
+      password: 'postgres',
       username: 'postgres',
       ssl: false,
       port: 5432);
@@ -18,7 +18,7 @@ Future<void> main() async {
         maxConnection: 5,
       ));
 
-  print("Initialized in ${a.elapsed.inMilliseconds}");
+  print("Initialized in ${a.elapsed.inMilliseconds}ms");
 
   //  Create a queue
   final queue = await pgmq.createQueue(queueName: 'test');