mirror of https://github.com/apache/activemq.git
added explicit disconnect after Chris T.'s patch
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511781 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
c0fb0c5584
commit
6c57f721c2
|
@ -42,6 +42,7 @@ begin
|
||||||
STDIN.each_line { |line|
|
STDIN.each_line { |line|
|
||||||
@conn.send @destination, line, @headers
|
@conn.send @destination, line, @headers
|
||||||
}
|
}
|
||||||
|
@conn.disconnect
|
||||||
|
|
||||||
rescue
|
rescue
|
||||||
end
|
end
|
||||||
|
|
|
@ -48,3 +48,4 @@ while true
|
||||||
$stdout.print "#{@msg.command}: #{@msg.body}\n"
|
$stdout.print "#{@msg.command}: #{@msg.body}\n"
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
@conn.disconnect
|
|
@ -63,3 +63,5 @@ for i in 1..(@batches)
|
||||||
end
|
end
|
||||||
|
|
||||||
@conn.send '/topic/event', "SHUTDOWN", {'persistent'=>'false'}
|
@conn.send '/topic/event', "SHUTDOWN", {'persistent'=>'false'}
|
||||||
|
|
||||||
|
@conn.disconnect
|
|
@ -43,6 +43,7 @@ begin
|
||||||
$stdout.flush
|
$stdout.flush
|
||||||
@conn.ack @msg.headers["message-id"]
|
@conn.ack @msg.headers["message-id"]
|
||||||
end
|
end
|
||||||
|
@conn.disconnect
|
||||||
|
|
||||||
rescue
|
rescue
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue