- warn "#Q<< ",dump( $from, $message );
- my ( undef, $gw, $user ) = split(/ /,$from,3);
- $user =~ s{^.+/}{};
- $con->send_msg( 'PRIVMSG', $room => "<$user> $message" );
+ my ( undef, $gw, $type, $user ) = split(/ /,$from);
+ MQR::Redis->publish( "SEND $nick\@$server $room $user" => "<$user> $message" );
+});
+
+MQR::Redis->redis->psubscribe( "SEND $nick\@$server $room *", sub {
+ my ( $message, $from ) = @_;
+ warn "PRIVMSG $room $message\n";
+ $con->send_msg( 'PRIVMSG', $room => $message );