/ 
POE-Component-MessageQueue-0.3004
River stage one • 2 direct dependents • 2 total dependents

Documentation

POE::Component::MessageQueue::Manual::Clustering
Instructions for setting up clustered MQ's with fail-over

Modules

POE::Component::MessageQueue
A STOMP based message queue server
POE::Component::MessageQueue::IDGenerator
Role for id generators.
POE::Component::MessageQueue::IDGenerator::SimpleInt
Simple integer IDs.
POE::Component::MessageQueue::IDGenerator::UUID
UUID generator.
POE::Component::MessageQueue::Statistics
Gather MQ Usage Statistics
POE::Component::MessageQueue::Statistics::Publish
Base Statistics Publish Class
POE::Component::MessageQueue::Statistics::Publish::YAML
Publish Statistics In YAML Format
POE::Component::MessageQueue::Storage
Parent of provided storage engines
POE::Component::MessageQueue::Storage::BigMemory
In-memory storage engine optimized for a large number of messages.
POE::Component::MessageQueue::Storage::Complex
A configurable storage engine that keeps a front-store (something fast) and a back-store (something persistent), only storing messages in the back-store after a configurable timeout period.
POE::Component::MessageQueue::Storage::DBI
A storage engine that uses DBI
POE::Component::MessageQueue::Storage::Default
The default storage engine (based on Complex), recommended for the most common case and used by mq.pl.
POE::Component::MessageQueue::Storage::Double
Stores composed of two other stores.
POE::Component::MessageQueue::Storage::FileSystem
A storage engine that keeps message bodies on the filesystem
POE::Component::MessageQueue::Storage::Generic
Wraps storage engines that aren't asynchronous via POE::Component::Generic so they can be used.
POE::Component::MessageQueue::Storage::Generic::DBI
A storage engine that uses DBI
POE::Component::MessageQueue::Storage::Memory
In memory storage engine.
POE::Component::MessageQueue::Storage::Remote
Access a remote storage engine via a TCP socket
POE::Component::MessageQueue::Storage::Remote::Server
Expose a storage engine as a service over a TCP socket
POE::Component::MessageQueue::Storage::Throttled
Wraps around another storage engine to throttle the number of messages sent to be stored at one time.
POE::Component::Server::Stomp
A generic Stomp server for POE

Provides

POE::Component::MessageQueue::Client
in lib/POE/Component/MessageQueue/Client.pm
POE::Component::MessageQueue::Destination
in lib/POE/Component/MessageQueue/Destination.pm
POE::Component::MessageQueue::Logger
in lib/POE/Component/MessageQueue/Logger.pm
POE::Component::MessageQueue::Message
in lib/POE/Component/MessageQueue/Message.pm
POE::Component::MessageQueue::Queue
in lib/POE/Component/MessageQueue/Queue.pm
POE::Component::MessageQueue::Storage::BigMemory::DelayedMessageElement
in lib/POE/Component/MessageQueue/Storage/BigMemory.pm
POE::Component::MessageQueue::Storage::BigMemory::MessageElement
in lib/POE/Component/MessageQueue/Storage/BigMemory.pm
POE::Component::MessageQueue::Storage::Complex::IdleElement
in lib/POE/Component/MessageQueue/Storage/Complex.pm
POE::Component::MessageQueue::Storage::Generic::Base
in lib/POE/Component/MessageQueue/Storage/Generic/Base.pm
POE::Component::MessageQueue::Subscription
in lib/POE/Component/MessageQueue/Subscription.pm
POE::Component::MessageQueue::Topic
in lib/POE/Component/MessageQueue/Topic.pm

Examples

Other files