[Rt-commit] r6265 - MessageBus/lib/MessageBus/Cache

[audreyt at bestpractical.com]

Author: audreyt
Date: Tue Oct 24 21:47:41 2006
New Revision: 6265

Modified:
   MessageBus/lib/MessageBus/Cache/DBM_Deep.pm
   MessageBus/lib/MessageBus/Cache/Memcached.pm

Log:
* Fix multipublishing in Memcached and DBM_Deep

Modified: MessageBus/lib/MessageBus/Cache/DBM_Deep.pm
==============================================================================
--- MessageBus/lib/MessageBus/Cache/DBM_Deep.pm	(original)
+++ MessageBus/lib/MessageBus/Cache/DBM_Deep.pm	Tue Oct 24 21:47:41 2006
@@ -33,14 +33,14 @@
 
 sub add_publisher {
     my ($self, $chan, $pub) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     $pubs->{$pub} = 0;
     $$self->put("$chan#", $pubs);
 }
 
 sub remove_publisher {
     my ($self, $chan, $pub) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     delete $pubs->{$pub};
     $$self->put("$chan#", $pubs);
 }
@@ -52,7 +52,7 @@
 
 sub set_index {
     my ($self, $chan, $pub, $idx) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     $pubs->{$pub} = $idx;
     $$self->put("$chan#", $pubs);
 }

Modified: MessageBus/lib/MessageBus/Cache/Memcached.pm
==============================================================================
--- MessageBus/lib/MessageBus/Cache/Memcached.pm	(original)
+++ MessageBus/lib/MessageBus/Cache/Memcached.pm	Tue Oct 24 21:47:41 2006
@@ -34,14 +34,14 @@
 
 sub add_publisher {
     my ($self, $chan, $pub) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     $pubs->{$pub} = 0;
     $$self->set("$chan#", $pubs);
 }
 
 sub remove_publisher {
     my ($self, $chan, $pub) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     delete $pubs->{$pub};
     $$self->set("$chan#", $pubs);
 }
@@ -53,7 +53,7 @@
 
 sub set_index {
     my ($self, $chan, $pub, $idx) = @_;
-    my $pubs = $$self->get($chan) || {};
+    my $pubs = $$self->get("$chan#") || {};
     $pubs->{$pub} = $idx;
     $$self->set("$chan#", $pubs);
 }