Permalink
Browse files

Need to pass the CV in

  • Loading branch information...
1 parent 37b6f61 commit d614df723dc82e2624f2f051d1fe5a015e7d827a @bobtfish committed Mar 16, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 lib/IPC/Lock/RabbitMQ/Lock.pm
@@ -32,7 +32,7 @@ sub unlock {
my ($self) = @_;
return 0 unless $self->channel->{_is_open}; # This is fugly, the API to AnyEvent::RabbitMQ sucks here..
my $cv = AnyEvent->condvar;
- my $t = $self->_gen_timer('Unlock');
+ my $t = $self->_gen_timer($cv, 'Unlock');
$self->channel->close(
on_success => sub { $cv->send(1) },
on_failure => sub { $cv->send(0) },

0 comments on commit d614df7

Please sign in to comment.