|
Lines 89-98
sub connect {
Link Here
|
| 89 |
|
89 |
|
| 90 |
try { |
90 |
try { |
| 91 |
$stomp = Net::Stomp->new( { hostname => $hostname, port => $port } ); |
91 |
$stomp = Net::Stomp->new( { hostname => $hostname, port => $port } ); |
| 92 |
$stomp->connect($credentials); |
92 |
my $connected_frame = $stomp->connect($credentials); |
|
|
93 |
if ( $connected_frame->command ne 'CONNECTED' ) { |
| 94 |
my $message = $connected_frame->body; |
| 95 |
chomp $message; |
| 96 |
warn sprintf "Cannot connect to broker (%s)", $message; |
| 97 |
undef $stomp; |
| 98 |
} |
| 93 |
} catch { |
99 |
} catch { |
| 94 |
warn "Cannot connect to broker " . $_; |
100 |
warn sprintf "Cannot connect to broker (%s)", $_; |
| 95 |
$stomp = undef; |
101 |
undef $stomp; |
| 96 |
}; |
102 |
}; |
| 97 |
|
103 |
|
| 98 |
return $stomp; |
104 |
return $stomp; |
| 99 |
- |
|
|