warn "<<<< ",dump( $from, $message );
return unless $from !~ m/\Q($nick|$room)\E/; # FIXME: skip our messages
my ( undef, $gw, $type, $user ) = split(/ /,$from);
- MQR::Redis->publish( "SEND $nick\@$server $room" => "<$user> $message" );
+ MQR::Redis->publish( "SEND $nick\@$server $room $user" => "<$user> $message" );
});
-MQR::Redis->redis->psubscribe( "SEND $nick\@$server $room", sub {
+MQR::Redis->redis->psubscribe( "SEND $nick\@$server $room *", sub {
my ( $message, $from ) = @_;
- warn "<<<< ",dump( $from, $message );
+ warn "PRIVMSG $room $message\n";
$con->send_msg( 'PRIVMSG', $room => $message );
});