|
NAMEMojo::RabbitMQ::Client::Publisher - simple Mojo::RabbitMQ::Client based publisherSYNOPSISuse 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; DESCRIPTIONATTRIBUTESMojo::RabbitMQ::Client::Publisher has following attributes.urlSets 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. METHODSMojo::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)
SEE ALSOMojo::RabbitMQ::ClientCOPYRIGHT AND LICENSECopyright (C) 2015-2017, Sebastian Podjasek and othersThis program is free software, you can redistribute it and/or modify it under the terms of the Artistic License version 2.0.
Visit the GSP FreeBSD Man Page Interface. |