99 |
map { $_->clearBuffer() } (values %Channels); |
map { $_->clearBuffer() } (values %Channels); |
100 |
} |
} |
101 |
|
|
102 |
|
sub numChannels { |
103 |
|
|
104 |
|
return scalar(keys %Channels); |
105 |
|
} |
106 |
|
|
107 |
############################################################################### |
############################################################################### |
108 |
# Factory methods |
# Factory methods |
109 |
############################################################################### |
############################################################################### |
165 |
|
|
166 |
$startIndex=0 if($startIndex<0); |
$startIndex=0 if($startIndex<0); |
167 |
|
|
168 |
|
my $numMsgToSend=0; |
169 |
while($startIndex<$msgCount) |
while($startIndex<$msgCount) |
170 |
{ |
{ |
171 |
my $message=$self->{'messages'}->[$startIndex++]; |
my $message=$self->{'messages'}->[$startIndex++]; |
172 |
|
|
173 |
$txt.=$message->message(); |
$txt.=$message->message(); |
174 |
|
$numMsgToSend++; |
175 |
} |
} |
176 |
|
|
177 |
$subscriber->sendMessage($txt); |
$subscriber->sendMessage($txt,$numMsgToSend); |
178 |
} |
} |
179 |
|
|
180 |
sub removeSubscriber { |
sub removeSubscriber { |