Put back namespace::autoclean and fix more whitespace

diff --git a/lib/Catalyst/Controller/MessageDriven.pm b/lib/Catalyst/Controller/MessageDriven.pm
index cdc129e..678e34b 100644 (file)
--- a/lib/Catalyst/Controller/MessageDriven.pm
+++ b/lib/Catalyst/Controller/MessageDriven.pm
@@ -1,6 +1,7 @@
 package Catalyst::Controller::MessageDriven;
 use Moose;
 use Data::Serializer;
+use namespace::autoclean;
 
 BEGIN { extends 'Catalyst::Controller' }
 

diff --git a/lib/Catalyst/Engine/Stomp.pm b/lib/Catalyst/Engine/Stomp.pm
index 49a0bab..ae6e991 100644 (file)
--- a/lib/Catalyst/Engine/Stomp.pm
+++ b/lib/Catalyst/Engine/Stomp.pm
@@ -1,12 +1,13 @@
 package Catalyst::Engine::Stomp;
 use Moose;
-extends 'Catalyst::Engine::Embeddable';
-
-our $VERSION = '0.04';
-
 use List::MoreUtils qw/ uniq /;
 use HTTP::Request;
 use Net::Stomp;
+use namespace::autoclean;
+
+extends 'Catalyst::Engine::Embeddable';
+
+our $VERSION = '0.04';
 
 has connection => (is => 'rw', isa => 'Net::Stomp');
 has conn_desc => (is => 'rw', isa => 'Str');
@@ -117,10 +118,10 @@ client IP address.
 =cut
 
 sub prepare_request {
-        my ($self, $c, $req, $res_ref) = @_;
-        shift @_;
-        $self->next::method(@_);
-        $c->req->address($self->conn_desc);
+    my ($self, $c, $req, $res_ref) = @_;
+    shift @_;
+    $self->next::method(@_);
+    $c->req->address($self->conn_desc);
 }
 
 =head2 finalize_headers
@@ -131,12 +132,12 @@ Overridden to dump out any errors encountered, since you won't get a
 =cut
 
 sub finalize_headers {
-        my ($self, $c) = @_;
-        my $error = join "\n", @{$c->error};
-        if ($error) {
-                $c->log->debug($error);
-        }
-        return $self->next::method($c);
+    my ($self, $c) = @_;
+    my $error = join "\n", @{$c->error};
+    if ($error) {
+        $c->log->debug($error);
+    }
+    return $self->next::method($c);
 }
 
 =head2 handle_stomp_frame
@@ -146,18 +147,18 @@ Dispatch according to Stomp frame type.
 =cut
 
 sub handle_stomp_frame {
-        my ($self, $app, $frame) = @_;
-
-        my $command = $frame->command();
-        if ($command eq 'MESSAGE') {
-                $self->handle_stomp_message($app, $frame);
-        }
-        elsif ($command eq 'ERROR') {
-                $self->handle_stomp_error($app, $frame);
-        }
-        else {
-                $app->log->debug("Got unknown Stomp command: $command");
-        }
+    my ($self, $app, $frame) = @_;
+
+    my $command = $frame->command();
+    if ($command eq 'MESSAGE') {
+        $self->handle_stomp_message($app, $frame);
+    }
+    elsif ($command eq 'ERROR') {
+        $self->handle_stomp_error($app, $frame);
+    }
+    else {
+        $app->log->debug("Got unknown Stomp command: $command");
+    }
 }
 
 =head2 handle_stomp_message
@@ -167,31 +168,31 @@ Dispatch a Stomp message into the Catalyst app.
 =cut
 
 sub handle_stomp_message {
-        my ($self, $app, $frame) = @_;
-
-        # queue -> controller
-        my $queue = $frame->headers->{destination};
-        my ($controller) = $queue =~ m!^/queue/(.*)$!;
-
-        # set up request
-        my $config = $app->config->{'Engine::Stomp'};
-        my $url = 'stomp://'.$config->{hostname}.':'.$config->{port}.'/'.$controller;
-        my $req = HTTP::Request->new(POST => $url);
-        $req->content($frame->body);
-        $req->content_length(length $frame->body);
-
-        # dispatch
-        my $response;
-        $app->handle_request($req, \$response);
-
-        # reply, if header set
-        if (my $reply_to = $response->headers->header('X-Reply-Address')) {
-                my $reply_queue = '/remote-temp-queue/' . $reply_to;
-                $self->connection->send({ destination => $reply_queue, body => $response->content });
-        }
-
-        # ack the message off the queue now we've replied / processed
-        $self->connection->ack( { frame => $frame } );
+    my ($self, $app, $frame) = @_;
+
+    # queue -> controller
+    my $queue = $frame->headers->{destination};
+    my ($controller) = $queue =~ m|^/queue/(.*)$|;
+
+    # set up request
+    my $config = $app->config->{'Engine::Stomp'};
+    my $url = 'stomp://'.$config->{hostname}.':'.$config->{port}.'/'.$controller;
+    my $req = HTTP::Request->new(POST => $url);
+    $req->content($frame->body);
+    $req->content_length(length $frame->body);
+
+    # dispatch
+    my $response;
+    $app->handle_request($req, \$response);
+
+    # reply, if header set
+    if (my $reply_to = $response->headers->header('X-Reply-Address')) {
+        my $reply_queue = '/remote-temp-queue/' . $reply_to;
+        $self->connection->send({ destination => $reply_queue, body => $response->content });
+    }
+
+    # ack the message off the queue now we've replied / processed
+    $self->connection->ack( { frame => $frame } );
 }
 
 =head2 handle_stomp_error
@@ -201,13 +202,11 @@ Log any Stomp error frames we receive.
 =cut
 
 sub handle_stomp_error {
-        my ($self, $app, $frame) = @_;
+    my ($self, $app, $frame) = @_;
 
-        my $error = $frame->headers->{message};
-        $app->log->debug("Got Stomp error: $error");
+    my $error = $frame->headers->{message};
+    $app->log->debug("Got Stomp error: $error");
 }
 
 __PACKAGE__->meta->make_immutable;
 
-1;
-