NAME

AnyMQ::Topic - AnyMQ Topic

SYNOPSIS

  my $channel = AnyMQ->topic('Foo');
  my $client = AnyMQ->new_listener($channel);

DESCRIPTION

An AnyMQ::Topic instance is a topic where messages can be published to, and AnyMQ::Queue objects can subscribe to. each message published to the topic will be appended to each subscribing queue.

ATTRIBUTES

recycle

True if the topic should be recycled once all listeners are gone.

reaper_interval

Interval in seconds that destroyed listeners to this topic should be reaped and freed.

METHODS

publish(@messages)

Publish messages to the topic.

add_subscriber($queue)

Add a new listener to the topic.