Naveed Massjouni > POE-Component-MessageQueue > POE::Component::MessageQueue::Storage::Memory

Download:
POE-Component-MessageQueue-0.3001.tar.gz

Dependencies

Annotate this POD

View/Report Bugs
Source  

NAME ^

POE::Component::MessageQueue::Storage::Memory -- In memory storage engine.

SYNOPSIS ^

  use POE;
  use POE::Component::MessageQueue;
  use POE::Component::MessageQueue::Storage::Memory;
  use strict;

  POE::Component::MessageQueue->new({
    storage => POE::Component::MessageQueue::Storage::Memory->new()
  });

  POE::Kernel->run();
  exit;

DESCRIPTION ^

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't suggest using this as your main storage engine because if messages aren't removed by consumers, it will continue to consume more memory until it explodes. Check-out POE::Component::MessageQueue::Storage::Complex which can use this module internally to keep messages in memory for a period of time before moving them into persistent storage.

CONSTRUCTOR PARAMETERS ^

None to speak of!

SUPPORTED STOMP HEADERS ^

persistent

Ignored. Nothing is persistent in this store.

expire-after

Ignored. All messages are kept until handled.

deliver-after

Fully Supported.

SEE ALSO ^

POE::Component::MessageQueue::Storage::BigMemory -- Alternative memory-based storage engine.

POE::Component::MessageQueue, POE::Component::MessageQueue::Storage

Other storage engines:

POE::Component::MessageQueue::Storage::BigMemory, POE::Component::MessageQueue::Storage::FileSystem, POE::Component::MessageQueue::Storage::DBI, POE::Component::MessageQueue::Storage::Generic, POE::Component::MessageQueue::Storage::Generic::DBI, POE::Component::MessageQueue::Storage::Throttled, POE::Component::MessageQueue::Storage::Complex, POE::Component::MessageQueue::Storage::Default

syntax highlighting: