Lines 81-89
sub connect {
Link Here
|
81 |
$credentials->{passcode} = $config->{password} if $config->{password}; |
81 |
$credentials->{passcode} = $config->{password} if $config->{password}; |
82 |
$credentials->{host} = $config->{vhost} if $config->{vhost}; |
82 |
$credentials->{host} = $config->{vhost} if $config->{vhost}; |
83 |
} |
83 |
} |
84 |
my $stomp = Net::Stomp->new( { hostname => $hostname, port => $port } ); |
84 |
|
|
|
85 |
my $stomp; |
86 |
|
85 |
try { |
87 |
try { |
86 |
$stomp = $self->connect; |
88 |
$stomp = Net::Stomp->new( { hostname => $hostname, port => $port } ); |
|
|
89 |
$stomp->connect( $credentials ); |
87 |
} catch { |
90 |
} catch { |
88 |
warn "Cannot connect to broker " . $_; |
91 |
warn "Cannot connect to broker " . $_; |
89 |
$stomp = undef; |
92 |
$stomp = undef; |
Lines 134-140
sub enqueue {
Link Here
|
134 |
$job_args->{job_id} = $self->id; |
137 |
$job_args->{job_id} = $self->id; |
135 |
|
138 |
|
136 |
my $conn = $self->connect; |
139 |
my $conn = $self->connect; |
137 |
|
|
|
138 |
return $self->id unless $conn; |
140 |
return $self->id unless $conn; |
139 |
|
141 |
|
140 |
$json_args = $json->encode($job_args); |
142 |
$json_args = $json->encode($job_args); |