my_variable>) will be discarded after
each run.
Returns result on success (serializable by the L<JSON> module). The result will
be discarded if the job is added as a background process.
Provides pro(optional) C<$args> (hashref), arguments required for running the
function (serializable by the L<JSON> module)
=item * (optional, internal) job handle to be later used by send_progress()
=back
Ret* (optional) C<$args> (hashref), arguments needed for running the
function (serializable by the L<JSON> module)
=back
Returns result (may be false of C<undef>) on success, C<die()>s on error
=cut
aCloud::JobManager::Broker';
use Net::AMQP::RabbitMQ;
use UUID::Tiny ':std';
use Tie::Cache;
use JSON;
use Data::Dumper;
use Readonly;
use Log::Log4perl qw(:easy);
Log::Log4perl->easy_init(
{
NORMAL => 1,
$MediaCloud::JobManager::Job::MJM_JOB_PRIORITY_HIGH => 2,
);
# JSON (de)serializer
my $json = JSON->new->allow_nonref->canonical->utf8;
# RabbitMQ connection credentials
has '_hos_declare_queue( $queue_name, $durable, $declare_and_bind_exchange, $lazy_queue );
}
sub _publish_json_message($$$;$$)
{
my ( $self, $routing_key, $payload, $extra_options, $extra_props ) = @_;