POE::Component::MessageQueue - A STOMP based message queue server River stage one • 2 direct dependents • 2 total dependents

This module implements a message queue [1] on top of POE that communicates via the STOMP protocol [2]. There exist a few good Open Source message queues, most notably ActiveMQ [3] which is written in Java. It provides more features and flexibility th...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage - Parent of provided storage engines River stage one • 2 direct dependents • 2 total dependents

The role implemented by all storage engines. It provides a few bits of global functionality, but mostly exists to define the interface for storage engines....

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Statistics - Gather MQ Usage Statistics River stage one • 2 direct dependents • 2 total dependents

POE::Component::MessageQueue::Statistics is a simple observer that receives events from the main POE::Component::MessageQueue object to collect usage statistics. By itself it will only *gather* statistics, and will not output anything. To enable outp...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::IDGenerator - Role for id generators. River stage one • 2 direct dependents • 2 total dependents

This can't be used directly, but just defines the interface for ID generators....

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Client.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Topic.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Queue.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Subscription.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Message.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Logger.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

lib/POE/Component/MessageQueue/Destination.pm River stage one • 2 direct dependents • 2 total dependents

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::DBI - A storage engine that uses DBI River stage one • 2 direct dependents • 2 total dependents

A storage engine that uses DBI. All messages stored with this backend are persisted. Performance is increased greatly by wrapping this engine in POE::Component::MessageQueue::Storage::Throttled at the expense of being slower to persist messages. This...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Memory - In memory storage engine. River stage one • 2 direct dependents • 2 total dependents

A storage engine that keeps all the messages in memory. Provides no persistence what-so-ever. For an alternative in-memory storage engine optimized for a large number of messages, please see POE::Component::MessageQueue::Storage::BigMemory. I wouldn'...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Double - Stores composed of two other stores. River stage one • 2 direct dependents • 2 total dependents

Refactor mercilessly, as they say. They also say don't repeat yourself. This module contains functionality for any store that is a composition of two stores. At least Throttled and Complex share this trait, and it doesn't make any sense to duplicate ...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Remote - Access a remote storage engine via a TCP socket River stage one • 2 direct dependents • 2 total dependents

With this module, you can talk to a storage engine running under POE::Component::MessageQueue::Storage::Remote::Server transparently. You can treat this like a normal local store once it's set up, and it can optionally failover to other stores....

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Generic - Wraps storage engines that aren't asynchronous via POE::Component::Generic so they can be used. River stage one • 2 direct dependents • 2 total dependents

Wraps storage engines that aren't asynchronous via POE::Component::Generic so they can be used. Using this module is by far the easiest way to write custom storage engines because you don't have to worry about making your operations asynchronous. Thi...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Default - The default storage engine (based on Complex), recommended for the most common case and used by mq.pl. River stage one • 2 direct dependents • 2 total dependents

This storage engine combines all the other provided engines. It uses POE::Component::MessageQueue::Storage::BigMemory as the front store and POE::Component::MessageQueue::Storage::FileSystem as the back store for POE::Componenet::MessageQueue::Storag...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::IDGenerator::UUID - UUID generator. River stage one • 2 direct dependents • 2 total dependents

This is a concrete implementation of the Generator interface for creating message IDs. It uses standards compliant UUIDs, which according to Data::UUID are guaranteed to be unique until 3500 C.E., though I'm not sure how it knows that....

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::Throttled - Wraps around another storage engine to throttle the number of messages sent to be stored at one time. River stage one • 2 direct dependents • 2 total dependents

Wraps around another engine to limit the number of messages sent to be stored at once. Use of this module is highly recommend! If the storage engine is unable to store the messages fast enough (ie. with slow disk IO) it can get really backed up and s...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC

POE::Component::MessageQueue::Storage::FileSystem - A storage engine that keeps message bodies on the filesystem River stage one • 2 direct dependents • 2 total dependents

A storage engine that wraps around another storage engine in order to store the message bodies on the file system. The other message properties are stored with the wrapped storage engine. While I would argue that using this module is less efficient t...

IRONCAMEL/POE-Component-MessageQueue-0.3004 - 05 Jun 2017 14:11:33 UTC
32 results (0.057 seconds)