.\" Automatically generated by Pod::Man 4.14 (Pod::Simple 3.43)
.\"
.\" Standard preamble:
.\" ========================================================================
.de Sp \" Vertical space (when we can't use .PP)
.if t .sp .5v
.if n .sp
..
.de Vb \" Begin verbatim text
.ft CW
.nf
.ne \\$1
..
.de Ve \" End verbatim text
.ft R
.fi
..
.\" Set up some character translations and predefined strings. \*(-- will
.\" give an unbreakable dash, \*(PI will give pi, \*(L" will give a left
.\" double quote, and \*(R" will give a right double quote. \*(C+ will
.\" give a nicer C++. Capital omega is used to do unbreakable dashes and
.\" therefore won't be available. \*(C` and \*(C' expand to `' in nroff,
.\" nothing in troff, for use with C<>.
.tr \(*W-
.ds C+ C\v'-.1v'\h'-1p'\s-2+\h'-1p'+\s0\v'.1v'\h'-1p'
.ie n \{\
. ds -- \(*W-
. ds PI pi
. if (\n(.H=4u)&(1m=24u) .ds -- \(*W\h'-12u'\(*W\h'-12u'-\" diablo 10 pitch
. if (\n(.H=4u)&(1m=20u) .ds -- \(*W\h'-12u'\(*W\h'-8u'-\" diablo 12 pitch
. ds L" ""
. ds R" ""
. ds C` ""
. ds C' ""
'br\}
.el\{\
. ds -- \|\(em\|
. ds PI \(*p
. ds L" ``
. ds R" ''
. ds C`
. ds C'
'br\}
.\"
.\" Escape single quotes in literal strings from groff's Unicode transform.
.ie \n(.g .ds Aq \(aq
.el .ds Aq '
.\"
.\" If the F register is >0, we'll generate index entries on stderr for
.\" titles (.TH), headers (.SH), subsections (.SS), items (.Ip), and index
.\" entries marked with X<> in POD. Of course, you'll have to process the
.\" output yourself in some meaningful fashion.
.\"
.\" Avoid warning from groff about undefined register 'F'.
.de IX
..
.nr rF 0
.if \n(.g .if rF .nr rF 1
.if (\n(rF:(\n(.g==0)) \{\
. if \nF \{\
. de IX
. tm Index:\\$1\t\\n%\t"\\$2"
..
. if !\nF==2 \{\
. nr % 0
. nr F 2
. \}
. \}
.\}
.rr rF
.\" ========================================================================
.\"
.IX Title "Message::Passing::Output::AMQP 3pm"
.TH Message::Passing::Output::AMQP 3pm "2022-11-19" "perl v5.36.0" "User Contributed Perl Documentation"
.\" For nroff, turn off justification. Always turn off hyphenation; it makes
.\" way too many mistakes in technical documents.
.if n .ad l
.nh
.SH "NAME"
Message::Passing::Output::AMQP \- output messages to AMQP.
.SH "SYNOPSIS"
.IX Header "SYNOPSIS"
.Vb 1
\& message\-pass \-\-input STDIN \-\-output AMQP \-\-output_options \*(Aq{"exchange_name":"test","hostname":"127.0.0.1","username":"guest","password":"guest"}\*(Aq
.Ve
.SH "DESCRIPTION"
.IX Header "DESCRIPTION"
A Message::Passing AnyEvent::RabbitMQ output class.
.PP
Can be used as part of a chain of classes with the message-pass utility, or directly as
a logger in normal perl applications.
.SH "ATTRIBUTES"
.IX Header "ATTRIBUTES"
.SS "routing_key"
.IX Subsection "routing_key"
The routing key for all messages, defaults to ''.
.SS "header_cb"
.IX Subsection "header_cb"
Optional callback function which gets passed the message before it is
serialized using \*(L"serialize_cb\*(R".
Should return a hashref which gets passed to publish( header => ).
.PP
\&\s-1NOTE:\s0 if you want to set the message headers (note the s) you have to pass them inside headers, e.g.:
.PP
.Vb 6
\& {
\& content_type => \*(Aqapplication/json\*(Aq,
\& headers => {
\& key => \*(Aqvalue\*(Aq,
\& }
\& }
.Ve
.SS "serialize_cb"
.IX Subsection "serialize_cb"
Optional callback function which gets passed the message and should return a
scalar. This is useful when passing structured messages e.g. hashrefs or
objects where some attributes should be accessible for the \*(L"header_cb\*(R" function.
If the serialization happens before using a Message::Passing::Role::Filter
it would require to deserialize it again in header_cb.
To use a Message::Passing filter you can instantiate it and pass it's filter
function to serialize_cb:
.PP
.Vb 1
\& my $filter = Message::Passing::Filter::Encoder::JSON\->new(output_to => undef);
\&
\& ...
\&
\& {
\& serialize_cb => sub { $filter\->filter(shift) },
\& }
.Ve
.SH "METHODS"
.IX Header "METHODS"
.SS "consume"
.IX Subsection "consume"
Sends a message.
.SH "SEE ALSO"
.IX Header "SEE ALSO"
.IP "Message::Passing::AMQP" 4
.IX Item "Message::Passing::AMQP"
.PD 0
.IP "Message::Passing::Input::AMQP" 4
.IX Item "Message::Passing::Input::AMQP"
.IP "Message::Passing" 4
.IX Item "Message::Passing"
.IP "\s-1AMQP\s0" 4
.IX Item "AMQP"
.IP "" 4
.IX Item ""
.PD
.SH "AUTHOR, COPYRIGHT AND LICENSE"
.IX Header "AUTHOR, COPYRIGHT AND LICENSE"
See Message::Passing::AMQP.