my $channel = $conn->open_channel();

my @job_types = qw( batch_biblio_record_modification batch_authority_record_modification );

my $job_type = 'batch_biblio_record_modification';

# FIXME cf note in Koha::BackgroundJob about $namespace

$channel->declare_queue(

my $namespace = C4::Context->config('memcached_namespace');

    queue => $job_type,

for my $job_type ( @job_types ) {

    durable => 1,

    $conn->subscribe({ destination => sprintf("%s-%s", $namespace, $job_type), ack => 'client' });

);

}

while (1) {

$channel->qos(prefetch_count => 1,);

    my $frame = $conn->receive_frame;

    if ( !defined $frame ) {

$channel->consume(

        # maybe log connection problems

    on_consume => sub {

        next;    # will reconnect automatically

        my $var = shift;

    }

        my $body = $var->{body}->{payload};

        say " [x] Received $body";

    my $body = $frame->body;

    say " [x] Received $body";

        my $args = decode_json( $body );

    my $args = decode_json($body);

        Koha::BackgroundJob::BatchUpdateBiblio->process($args, $channel);

    # FIXME This means we need to have create the DB entry before

        say " [x] Done";

    # It could work in a first step, but then we will want to handle job that will be created from the message received

    },

    my $job = Koha::BackgroundJobs->find($args->{job_id});

    no_ack => 0,

    my $success = $job->process( $args );

);

    say " [x] Done";

# Wait forever

    $conn->ack( { frame => $frame } ); # FIXME depending on $success?

AnyEvent->condvar->recv;

}

$conn->disconnect;