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