perl - タスクキューとしての Mojo::Redis2 - 非決定的な動作

Question

Redis を使用して軽いジョブ キューを実装したいと考えています (ミニオンには Postgresql が必要です)。最小限のサンプルは正常に実行できますが、完全な Mojolicious アプリケーションには問題があります。

startupルーチンと呼び出しは次のようになります。

sub startup{
    ...
    ###################### Redis part
    $self->helper(
        redis => sub {
            state $redis = Mojo::Redis2->new(server => '127.0.0.1:6379'); 
        }
    );

    $self->redis->on(message => sub {
        my ($redisself, $message, $channel) = @_;

        # PROBLEM: on morbo this is blocking
        # PROBLEM: on hypnotoad this works only sometimes 
        # - e.g., for the first time after hot deployment restart

        say "DEQUEUE: $message @ $channel";
        sleep (10); # replaces long-running operation
        say "FINISHED processing: $message @ $channel";
    });

    $self->redis->subscribe(['long_running_tasks'] => sub {
        my ($rself, $err, $res) = @_;
        say "SUBSCRIBED to channel long_running_tasks";       
    });

    $self->redis->on(connection => sub { 
        my ($self, $info) = @_;  
        say "got redis connection id: $info->{id}, group: $info->{group}, nblocking: $info->{nb}.";
    });

    $self->redis->on(error => sub {
        my ($self, $err) = @_;
        say "got redis error $err";
    });
    ######################## Redis part END
    ... 

    # route
    $manager->get('/regenerate')->to('controller#regenerate');
}


#######################
# in the Controller.pm
#######################
sub regenerate {
    my $self = shift;

    $self->redis->publish("long_running_tasks" => "regenerate");

    $self->flash(
        msg_type => 'info',
        msg      => 'Regeneration of will be executed in background.'
    );
    $self->redirect_to($self->get_referrer());
}

ローカルホストで Redis 3.2.5 (自作) を実行しています。問題は、コードの非決定的な動作に関係しています。

• 最小限の例
  • モルボで問題なく動く
  • ヒプノトードでパブリッシュアクションが3回実行される
• 大きな例
  • morbo では、発行アクションがブロックされていますが、正常に実行されます
  • hypnotoad では、パブリッシュ アクションはノンブロッキング方式で実行されますが、実行は一部の呼び出しでのみ行われます (たとえば、ホット デプロイの再起動後の最初の呼び出しの一部)。
    • サブスクライブ アクションは常に成功します

問題はどこにありますか？