restart subscription connection if dequeue lag behind enqueue

temp_fix_inner_broker.rb

require 'rubygems'
require 'jmx4r'

JMX::MBean.establish_connection :host => "localhost", :port => 9999, :username => "pwd", :password => "pwd"

JMX::MBean.find_all_by_name("org.apache.activemq:BrokerName=inner-broker,Type=Subscription,persistentMode=Non-Durable,destinationType=Topic,destinationName=pulso.>,*").each do |sub| 
	
	next unless sub.enqueue_counter - sub.dequeue_counter > 100

	conn = JMX::MBean.find_all_by_name("org.apache.activemq:BrokerName=inner-broker,Type=Connection,ConnectorName=inner-openwire,Connection=ID_#{conn_id.split(":")[1][0...-2]}*").first

	conn.stop

end