amqp10

Standalone AMQP-1.0 client (no shared code with amqp091 -- a different type system and a three-tier Connection -> Session -> Link hierarchy with credit-based flow control instead of 0-9-1's Connection/Channel model). Links are explicitly sender- or receiver-role; use it to talk to AMQP-1.0 brokers/routers such as ActiveMQ Artemis or Azure Service Bus.

Publish and consume

import tinox.core.amqp10;

class Main
{
    fnc main() -> Int32
    {
        let conn: Amqp10Connection = Amqp10Connection::connect("localhost", 5672, "guest", "guest");
        let session: Amqp10Session = Amqp10Session::begin(conn);

        // role=false is a sender link (target = the destination address)
        let sender: Amqp10Link = Amqp10Link::attach(session, "publisher", false, "orders");
        sender.publish(Amqp10::stringToBytes("hello amqp-1.0"), "text/plain");

        // role=true is a receiver link (source = where messages come from)
        let receiver: Amqp10Link = Amqp10Link::attach(session, "consumer", true, "orders");
        receiver.grantCredit(1);
        let msg: Amqp10Message = receiver.nextMessage();
        if msg.ok
        {
            println(tinoxBytesToString(msg.body));
            receiver.ack(msg.deliveryId);
        }

        session.end();
        conn.close();
        return 0;
    }
}

fn tinoxBytesToString(bytes: List<Int64>) → String

class Amqp10

Methods

class Amqp10Connection

Fields

Methods

class Amqp10Described

Fields

class Amqp10Frame

Fields

class Amqp10Link

Fields

Methods

class Amqp10Message

Fields

class Amqp10Performative

Fields

fn tinoxBytesToString(bytes: List<Int64>) → String

class Amqp10Reader

Fields

Methods

class Amqp10SaslResult

Fields

class Amqp10Session

Fields

Methods

class Amqp10Transaction

Fields

class Amqp10Writer

Fields

Methods