File Coverage

blib/lib/POE/Component/MessageQueue/Topic.pm

Criterion	Covered	Total	%
statement	3	8	37.5
branch			n/a
condition			n/a
subroutine	1	5	20.0
pod	0	4	0.0
total	4	17	23.5

#
# Copyright 2007, 2008 Paul Driver <[e-mail]>
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.
#

package POE::Component::MessageQueue::Topic;
use Moose;

with qw(POE::Component::MessageQueue::Destination);
__PACKAGE__->meta->make_immutable();

sub send
{
	my ($self, $message) = @_;

	foreach my $subscriber ($self->all_subscriptions)
	{
		$self->dispatch_message($message, $subscriber);
	}

	return;
}

sub is_persistent { return 0 }

# These do nothing now, but they may someday
sub pump {}
sub shutdown {}

1;