|
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); |