Scroll to navigation

Mojo::RabbitMQ::Client::Publisher(3pm) User Contributed Perl Documentation Mojo::RabbitMQ::Client::Publisher(3pm)

NAME

Mojo::RabbitMQ::Client::Publisher - simple Mojo::RabbitMQ::Client based publisher

SYNOPSIS

  use Mojo::RabbitMQ::Client::Publisher;
  my $publisher = Mojo::RabbitMQ::Client::Publisher->new(
    url => 'amqp://guest:guest@127.0.0.1:5672/?exchange=mojo&routing_key=mojo'
  );

  $publisher->publish_p(
    {encode => { to => 'json'}},
    routing_key => 'mojo_mq'
  )->then(sub {
    say "Message published";
  })->catch(sub {
    die "Publishing failed"
  })->wait;

DESCRIPTION

ATTRIBUTES

Mojo::RabbitMQ::Client::Publisher has following attributes.

url

Sets all connection parameters in one string, according to specification from <https://www.rabbitmq.com/uri-spec.html>.

For detailed description please see Mojo::RabbitMQ::Client#url.

METHODS

Mojo::RabbitMQ::Client::Publisher implements only single method.

publish_p

  $publisher->publish_p('simple plain text body');

  $publisher->publish_p({ some => 'json' });

  $publisher->publish_p($body, { header => 'content' }, routing_key => 'mojo', mandatory => 1);

Method signature

  publish_p($body!, \%headers?, *@params)
body
First argument is mandatory body content of published message. Any reference passed here will be encoded as JSON and accordingly "content_type" header will be set to "application/json".
headers
If second argument is a HASHREF it will be merged to message headers.
params
Any other arguments will be considered key/value pairs and passed to publish method as arguments overriding everything besides body argument.

So this:

  $publisher->publish($body, { header => 'content' });

can be also written like this:

  $publisher->publish($body, header => { header => 'content' });

But beware - headers get merged, but params override values so when you write this:

  $publisher->publish({ json => 'object' }, header => { header => 'content' });

message will lack "content_type" header!

SEE ALSO

Mojo::RabbitMQ::Client

COPYRIGHT AND LICENSE

Copyright (C) 2015-2017, Sebastian Podjasek and others

This program is free software, you can redistribute it and/or modify it under the terms of the Artistic License version 2.0.

2018-07-29 perl v5.26.2