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

Modules

POE::Component::MessageQueue
A POE message queue that uses STOMP for the communication protocol
POE::Component::MessageQueue::IDGenerator
Abstract base class 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), allowing you to specify a timeout and an action to be taken when messages in the front-store expire.
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::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::Structure::DLList
A simple doubly-linked list for wheel-reinventing goodness.
POE::Component::MessageQueue::Storage::Structure::DLList::Cell
Cells in a doubly linked list.
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::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::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