Add some feedback to the test; shorten spinup delay.

[catagits/Catalyst-Engine-STOMP.git] / lib / Catalyst / Controller / MessageDriven.pm

package Catalyst::Controller::MessageDriven;
use Moose;

BEGIN { extends 'Catalyst::Controller' }

__PACKAGE__->config(
		    'default'   => 'text/x-yaml',
		    'stash_key' => 'response',
		    'map'       => { 'text/x-yaml' => 'YAML' },
		   );

sub begin :ActionClass('Deserialize') { }

sub end :ActionClass('Serialize') {
	my ($self, $c) = @_;

	# Engine will send our reply based on the value of this header.
	$c->response->headers->header( 'X-Reply-Address' => $c->req->data->{reply_to} );

	# Custom error handler - steal errors from catalyst and dump them into
	# the stash, to get them serialized out as the reply.
 	if (scalar @{$c->error}) {
 		my $error = join "\n", @{$c->error};
 		$c->stash->{response} = { status => 'ERROR', error => $error };
		$c->error(0); # clear errors, so our response isn't clobbered
 	}
}

sub default : Private {
	my ($self, $c) = @_;
	
	# Forward the request to the appropriate action, based on the
	# message type.
	my $action = $c->req->data->{type};
	$c->forward($action, [$c->req->data]);
}

__PACKAGE__->meta->make_immutable;

1;