NAME

Stomp - basic Simple Text Orientated Messaging Protocol implementation

SYNOPSIS

use Stomp;

my $client = Stomp::Client.new(:$login, :$password, :$port, :$host);
await $client.connect;

# receiving
react {
    whenever $client.subscribe($queue) -> $v {
        say "Got : ",$v.body;
    }
}

# sending
$client.send($queue, $message);

DESCRIPTION

The Stomp distribution provides basic support for Stomp (aka Simple Text Oriented Message Protocol) for both client and server roles.

CLASSES

Stomp::Client

my $client = Stomp::Client.new(:$login, :$password, :$port, :$host);
await $client.connect;

react {
    whenever $client.subscribe($queue) -> $v {
        say "Got : ",$v.body;
    }
}

The subscribe method expects the name of the STOMP queue to receive messages from. It returns a Supply.

send

$client.send($queue, $message, :$content-type);

The send method will send the given message to the indicated queue. An optional named argument :content-type can be specified with a MIME-type. The default is text/plain.

Stomp::Server

my $server = Stomp::Server.new(:$host, :$port);

react {
    whenever $server.listen -> $message {
        # ...
    }
}

UPDATE NOTES

This module was never released as a public module before being released. It was released as a Raku Community module that it would be useful to someone.

It lacks documentation and definitely needs a lot of TLC. Caretakers are very welcome, as are any Pull Requests to make this a better distribution.

AUTHOR

Jonathan Worthington

Source can be located at: https://github.com/raku-community-modules/Stomp . Comments and Pull Requests are welcome.

COPYRIGHT AND LICENSE

This library is free software; you can redistribute it and/or modify it under the Artistic License 2.0.