Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Run perltidy on all files

  • Loading branch information...
commit 24a713d8ca1600876fbd4f00fd4c848e2f41fb04 1 parent e380900
@plu plu authored
View
2  examples/plain-anyevent-rabbitfoot.pl
@@ -12,7 +12,7 @@
# port => 5672,
);
-Net::AMQP::Protocol->load_xml_spec(Net::RabbitFoot::default_amqp_spec());
+Net::AMQP::Protocol->load_xml_spec( Net::RabbitFoot::default_amqp_spec() );
my $rf1 = Net::RabbitFoot->new->connect( %config, port => 5672 );
my $rf2 = Net::RabbitFoot->new->connect( %config, port => 5672 );
View
8 examples/store.pl
@@ -5,7 +5,7 @@
use lib "$FindBin::Bin/../lib";
use Beetle::DeduplicationStore;
use Data::Dumper;
-$Data::Dumper::Sortkeys=1;
+$Data::Dumper::Sortkeys = 1;
my $store = Beetle::DeduplicationStore->new( hosts => "127.0.0.1:6379" );
@@ -13,10 +13,10 @@
$store->set( $id, $sfx, $val );
warn $store->get( $id, $sfx );
-$store->msetnx( "${id}2" => { foo => 'bar', bla => 'fasel' });
+$store->msetnx( "${id}2" => { foo => 'bar', bla => 'fasel' } );
-$store->redis->set('foo' => 1 );
+$store->redis->set( 'foo' => 1 );
$store->redis->del('foo');
my @keys = $store->redis->keys('*');
-warn Dumper \@keys;
+warn Dumper \@keys;
View
2  examples/subscribe.pl
@@ -27,7 +27,7 @@
$client->register_handler( testperl => $handler );
my $timer = AnyEvent->timer(
- after => 1, # seconds
+ after => 1, # seconds
cb => sub {
$client->stop_listening;
},
View
4 lib/Beetle/Bunny.pm
@@ -49,8 +49,8 @@ has '_channel' => (
# TODO: <plu> talk to author of AnyEvent::RabbitMQ how to fix this properly
{
no warnings 'redefine';
- *AnyEvent::RabbitMQ::Channel::DESTROY = sub {};
- *AnyEvent::RabbitMQ::DESTROY = sub {};
+ *AnyEvent::RabbitMQ::Channel::DESTROY = sub { };
+ *AnyEvent::RabbitMQ::DESTROY = sub { };
}
sub ack {
View
9 lib/Beetle/Redis.pm
@@ -82,7 +82,7 @@ sub AUTOLOAD {
}
my $result = <$sock> || die "can't read socket: $!";
- Encode::_utf8_on($result); ## no critic
+ Encode::_utf8_on($result); ## no critic
warn "<< $result" if $self->{debug};
my $type = substr( $result, 0, 1 );
$result = substr( $result, 1, -2 );
@@ -128,18 +128,19 @@ sub __connect {
PeerAddr => $self->{server} || $ENV{REDIS_SERVER} || '127.0.0.1:6379',
Proto => 'tcp',
) || die $!;
+
# $self->select( $self->{db} || 0 ); # TODO: <plu> make this working
}
}
sub __read_bulk {
my ( $self, $len ) = @_;
- return undef if $len < 0; ## no critic
+ return undef if $len < 0; ## no critic
my $v;
if ( $len > 0 ) {
read( $self->{sock}, $v, $len ) || die $!;
- Encode::_utf8_on($v); ## no critic
+ Encode::_utf8_on($v); ## no critic
warn "<< ", Dumper($v), $/ if $self->{debug};
}
my $crlf;
@@ -149,7 +150,7 @@ sub __read_bulk {
sub __read_multi_bulk {
my ( $self, $size ) = @_;
- return undef if $size < 0; ## no critic
+ return undef if $size < 0; ## no critic
my $sock = $self->{sock};
$size--;
View
2  t/etc/config.pl
@@ -10,4 +10,4 @@
'user' => 'admin',
'verbose' => 1,
'vhost' => '/bar',
-}
+}
View
1  t/lib/TestLib.pm
@@ -5,6 +5,7 @@ use Moose;
use Beetle::Message;
BEGIN {
+
# Disable logger in tests
use Beetle::Config;
no warnings 'redefine';
View
2  t/lib/TestLib/Handler/FooBar.pm
@@ -5,7 +5,7 @@ use Moose;
extends qw(Beetle::Handler);
sub process {
- my ( $self ) = @_;
+ my ($self) = @_;
return uc $self->message;
}
View
2  xt/00-critic.t
@@ -2,4 +2,4 @@ use Test::More;
use FindBin;
eval "use Test::Perl::Critic (-profile => '$FindBin::Bin/perlcriticrc')";
plan skip_all => "Test::Perl::Critic required for testing" if $@;
-all_critic_ok("$FindBin::Bin/../lib");
+all_critic_ok("$FindBin::Bin/../lib");
View
2  xt/00-pod.t
@@ -1,4 +1,4 @@
use Test::More;
eval "use Test::Pod 1.00";
plan skip_all => "Test::Pod 1.00 required for testing POD" if $@;
-all_pod_files_ok();
+all_pod_files_ok();
Please sign in to comment.
Something went wrong with that request. Please try again.