Ngpmq 1.0.1

Npgmq

A .NET client for <a href="https://github.com/tembo-io/pgmq">Postgres Message Queue</a> (PGMQ).

Compatibility

• pgmq >= 0.31.0

Installation

To install the package via Nuget, run the following command:

dotnet add package Npgmq

Usage

Here is an example that uses Npgmq to create a queue and then send/read/archive a message:

using Npgmq;

var npgmq = new NpgmqClient("<YOUR CONNECTION STRING HERE>");

await npgmq.CreateQueueAsync("my_queue");

var msgId = await npgmq.SendAsync("my_queue", new MyMessageType
{
    Foo = "Test",
    Bar = 123
});
Console.WriteLine($"Sent message with id {msgId}");

var msg = await npgmq.ReadAsync<MyMessageType>("my_queue");
if (msg != null)
{
    Console.WriteLine($"Read message with id {msg.MsgId}: Foo = {msg.Message?.Foo}, Bar = {msg.Message?.Bar}");
    await npgmq.ArchiveAsync("my_queue", msg!.MsgId);
}

This example assumes you have defined a class called MyMessageType with the structure something like:

public class MyMessageType
{
    public string Foo { get; set; } = null!;
    public int Bar { get; set; }
}

You can also send and read messages as JSON strings:

var msgId = await npgmq.SendAsync("my_queue", "{\"foo\":\"Test\",\"bar\":123}");
Console.WriteLine($"Sent message with id {msgId}");

var msg = await npgmq.ReadAsync<string>("my_queue");
if (msg != null)
{
    Console.WriteLine($"Read message with id {msg.MsgId}: {msg.Message}");
    await npgmq.ArchiveAsync("my_queue", msg!.MsgId);
}

Database Connection

Npgmq uses Npgsql internally to connect to the database.

The connection string passed to the NpgmqClient constructor should be an Npgsql connection string.