The Perl Toolchain Summit needs more sponsors. If your company depends on Perl, please support this very important event.
 / 
Message-Passing-0.103
River stage two • 19 direct dependents • 19 total dependents
17 ++

Changes for version 0.103

  • Message::Passing::Input::FileTail now defaults to outputting a hash of data which contains additional metadata to the message line, such as the hostname, timestamp, filename. A 'raw => 1' option has been added which can be used to restore the original behaviour.
  • Add an experimental (and undocumented) Message::Passing::Filter::ToLogstash
  • Fix issue in JSON decoder when processing exceptions.

Documentation

Message::Passing::Manual
table of contents for Message::Passing documentation
Message::Passing::Manual::Components
Writing inputs, outputs and filters
Message::Passing::Manual::Concepts
The concepts behind the framework
Message::Passing::Manual::Cookbook
Common recipies
Message::Passing::Manual::Workers
message-pass
command line Message::Passing runner script

Modules

Message::Passing
a simple way of doing messaging.
Message::Passing::DSL
An easy way to make chains of Message::Passing components.
Message::Passing::DSL::Factory
Build a set of chains using symbolic names
Message::Passing::Exception
Base role for Message::Passing exceptions
Message::Passing::Exception::ConnectionDisconnected
A connection disconnected
Message::Passing::Exception::ConnectionTimeout
A connection timed out
Message::Passing::Exception::Decoding
An issue when decoding data
Message::Passing::Exception::Encoding
An issue when encoding data
Message::Passing::Filter::All
Filter all messages out.
Message::Passing::Filter::Decoder::Bzip2
Use Compress:Bzip2 to encrypt messages
Message::Passing::Filter::Decoder::Crypt::CBC
Use Crypt::CBC to decrypt messages
Message::Passing::Filter::Decoder::Gzip
Decompresses messages with Compress::Zlib
Message::Passing::Filter::Decoder::JSON
Message::Passing::Filter::Decoder::Null
Message::Passing::Filter::Delay
Delay messages for some time.
Message::Passing::Filter::Encoder::Bzip2
Use Compress:Bzip2 to encrypt messages
Message::Passing::Filter::Encoder::Crypt::CBC
Use Crypt::CBC to encrypt messages
Message::Passing::Filter::Encoder::Gzip
Compresses messages with Compress::Zlib
Message::Passing::Filter::Encoder::JSON
Encodes data structures as JSON for output
Message::Passing::Filter::Encoder::Null
Message::Passing::Filter::Key
Filter a subset of messages out.
Message::Passing::Filter::Null
Filter no messages out.
Message::Passing::Filter::T
Send a message stream to multiple outputs.
Message::Passing::Input::FileTail
File tailing input
Message::Passing::Input::Null
Null input
Message::Passing::Input::STDIN
STDIN input
Message::Passing::Output::Callback
Output to call back into your code
Message::Passing::Output::File
File output
Message::Passing::Output::IO::Handle
output to an IO handle
Message::Passing::Output::Null
/dev/null for messages
Message::Passing::Output::STDERR
STDOUT output
Message::Passing::Output::STDOUT
STDOUT output
Message::Passing::Output::Socket::UDP
Message::Passing::Output::Test
Output for use in unit tests
Message::Passing::Role::CLIComponent
Package::Variant providing 'foo' and 'foo_options' attributes
Message::Passing::Role::ConnectionManager
A simple manager for inputs and outputs that need to make network connections.
Message::Passing::Role::Crypt::CBC
Common attributes for encoding or decoding encrypted messages
Message::Passing::Role::Filter
Simple abstraction for filtering messages
Message::Passing::Role::HasAConnection
Role for components which have a connection
Message::Passing::Role::HasErrorChain
A role for components which can report errors
Message::Passing::Role::HasHostnameAndPort
Message::Passing::Role::HasTimeoutAndReconnectAfter
Message::Passing::Role::HasUsernameAndPassword
common username and password attributes
Message::Passing::Role::Input
Message::Passing::Role::Output
Consumes messages
Message::Passing::Role::Script
Handy role for building messaging scripts.

Provides

Message::Passing::Filter::ToLogstash
in lib/Message/Passing/Filter/ToLogstash.pm
Message::Passing::Input::Socket::UDP
in lib/Message/Passing/Input/Socket/UDP.pm

Other files