18 |
use XML::Feed; |
use XML::Feed; |
19 |
use DateTime::Format::Flexible; |
use DateTime::Format::Flexible; |
20 |
use Encode; |
use Encode; |
21 |
|
use Redis 2.0; |
22 |
|
|
23 |
=head1 NAME |
=head1 NAME |
24 |
|
|
565 |
" " . $a->{message}; |
" " . $a->{message}; |
566 |
|
|
567 |
eval { $sth_insert_log->execute($a->{channel}, $a->{me}, $a->{nick}, $a->{message}, $a->{time}); }; |
eval { $sth_insert_log->execute($a->{channel}, $a->{me}, $a->{nick}, $a->{message}, $a->{time}); }; |
568 |
|
|
569 |
|
eval { |
570 |
|
my $redis = Redis->new( server => '192.168.1.61:6379' ); |
571 |
|
my @channel = ( 'channel' , $a->{channel}, $a->{nick} ); |
572 |
|
push @channel, 'me' if $a->{me}; |
573 |
|
$redis->publish( join(' ',@channel), $a->{message} ); |
574 |
|
}; |
575 |
|
|
576 |
if ( $@ ) { |
if ( $@ ) { |
577 |
_log "ERROR: can't archive ", $a->{message}; |
_log "ERROR: can't archive ", $a->{message}; |
578 |
} else { |
} else { |