How can MQ Queues and Topics be monitored in LogicMonitor ?

Tech Forums

Product Discussions

How can MQ Queues and Topics and possibly channels be monitored in LogicMonitor ? Not much listed under support for LM.

ericatwood

Posted 4 years ago·Last reply 4 years ago

2 comments

ericatwood

OP4 years ago

Unfortunately, Its IBM MQ or Webphere MQ without using WIM.

LM User

·4 years ago

At one point i had a datasource called RabbitMQ Queue_connections and one called RabbitMQ_cluster_status_connection. Not sure if that's what you're looking for. Here are the scripts for those endpoints. Maybe they can help you if you find the right endpoints for queues and topics.

The collection script:

<span class="kwd">import</span><span class="pln"> com</span><span class="pun">.</span><span class="pln">santaba</span><span class="pun">.</span><span class="pln">agent</span><span class="pun">.</span><span class="pln">groovyapi</span><span class="pun">.</span><span class="pln">http</span><span class="pun">.*</span><span class="pln">
</span><span class="kwd">import</span><span class="pln"> groovy</span><span class="pun">.</span><span class="pln">json</span><span class="pun">.*</span><span class="pln">

def hostName </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"system.hostname"</span><span class="pun">)</span><span class="pln">

def rabbitPort </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.port"</span><span class="pun">)</span><span class="pln">
def rabbitUser </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.user"</span><span class="pun">)</span><span class="pln">
def rabbitPass </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.pass"</span><span class="pun">)</span><span class="pln">
def rabbitAddr </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.apiurl"</span><span class="pun">)</span><span class="pln">

def urlList </span><span class="pun">=</span><span class="pln"> </span><span class="pun">[</span><span class="str">"${rabbitAddr}"</span><span class="pun">,</span><span class="pln">
               </span><span class="str">"https://${hostName}:${rabbitPort}"</span><span class="pun">,</span><span class="pln">
               </span><span class="str">"http://${hostName}:${rabbitPort}"</span><span class="pun">]</span><span class="pln">

def getResult</span><span class="pun">(</span><span class="pln">urlList</span><span class="pun">,</span><span class="pln"> apiPath</span><span class="pun">,</span><span class="pln"> rabbitUser</span><span class="pun">,</span><span class="pln"> rabbitPass</span><span class="pun">,</span><span class="pln"> rabbitPort</span><span class="pun">){</span><span class="pln">
    def response </span><span class="pun">=</span><span class="pln"> null
    urlList</span><span class="pun">.</span><span class="pln">each</span><span class="pun">{</span><span class="pln">url</span><span class="pun">-></span><span class="pln">
        </span><span class="kwd">if</span><span class="pun">(</span><span class="pln">url </span><span class="pun">!=</span><span class="pln"> </span><span class="str">"null"</span><span class="pln"> </span><span class="pun">&&</span><span class="pln"> </span><span class="pun">!</span><span class="pln">response</span><span class="pun">){</span><span class="pln">
            </span><span class="kwd">try</span><span class="pun">{</span><span class="pln">
                def conn </span><span class="pun">=</span><span class="pln"> </span><span class="kwd">new</span><span class="pln"> URL</span><span class="pun">(</span><span class="pln">url </span><span class="pun">+</span><span class="pln"> apiPath</span><span class="pun">).</span><span class="pln">openConnection</span><span class="pun">()</span><span class="pln">
                conn</span><span class="pun">.</span><span class="pln">setReadTimeout</span><span class="pun">(</span><span class="lit">1500</span><span class="pun">)</span><span class="pln">
                def authString </span><span class="pun">=</span><span class="pln"> </span><span class="str">"${rabbitUser}:${rabbitPass}"</span><span class="pun">.</span><span class="pln">getBytes</span><span class="pun">().</span><span class="pln">encodeBase64</span><span class="pun">().</span><span class="pln">toString</span><span class="pun">()</span><span class="pln">
                conn</span><span class="pun">.</span><span class="pln">setRequestProperty</span><span class="pun">(</span><span class="str">"Authorization"</span><span class="pun">,</span><span class="pln"> </span><span class="str">"Basic ${authString}"</span><span class="pun">)</span><span class="pln">
                response </span><span class="pun">=</span><span class="pln"> conn</span><span class="pun">.</span><span class="pln">getInputStream</span><span class="pun">().</span><span class="pln">getText</span><span class="pun">()</span><span class="pln">
            </span><span class="pun">}</span><span class="pln"> </span><span class="kwd">catch</span><span class="pun">(</span><span class="typ">Exception</span><span class="pln"> ex</span><span class="pun">){</span><span class="pln">
                </span><span class="com">// println "Exception: " + ex.message // URL Invalid!</span><span class="pln">
            </span><span class="pun">}</span><span class="pln">
        </span><span class="pun">}</span><span class="pln">
    </span><span class="pun">}</span><span class="pln">
    </span><span class="kwd">return</span><span class="pln"> response
</span><span class="pun">}</span><span class="pln">

def response </span><span class="pun">=</span><span class="pln"> getResult</span><span class="pun">(</span><span class="pln">urlList</span><span class="pun">,</span><span class="pln"> </span><span class="str">"/api/connections"</span><span class="pun">,</span><span class="pln"> rabbitUser</span><span class="pun">,</span><span class="pln"> rabbitPass</span><span class="pun">,</span><span class="pln"> rabbitPort</span><span class="pun">)</span><span class="pln">
</span><span class="kwd">if</span><span class="pun">(!</span><span class="pln">response</span><span class="pun">){</span><span class="kwd">return</span><span class="pln"> </span><span class="lit">1</span><span class="pun">}</span><span class="pln">
def slurper </span><span class="pun">=</span><span class="pln"> </span><span class="kwd">new</span><span class="pln"> </span><span class="typ">JsonSlurper</span><span class="pun">()</span><span class="pln">
def json </span><span class="pun">=</span><span class="pln"> slurper</span><span class="pun">.</span><span class="pln">parseText</span><span class="pun">(</span><span class="pln">response</span><span class="pun">)</span><span class="pln">
json</span><span class="pun">.</span><span class="pln">each</span><span class="pun">{</span><span class="pln">
    def connection </span><span class="pun">=</span><span class="pln"> </span><span class="str">"${it.name.replaceAll("</span><span class="pln"> </span><span class="str">","").replaceAll("</span><span class="pun">:</span><span class="str">","</span><span class="pun">-</span><span class="str">")}"</span><span class="pln">
    println</span><span class="pun">(</span><span class="str">"${connection}.channels: ${it.channels}"</span><span class="pun">)</span><span class="pln">
    println</span><span class="pun">(</span><span class="str">"${connection}.state: ${(it.state=="</span><span class="pln">running</span><span class="str">") ? 1 : 0}"</span><span class="pun">)</span><span class="pln">
    println</span><span class="pun">(</span><span class="str">"${connection}.send_pend: ${it.send_pend}"</span><span class="pun">)</span><span class="pln">
    println</span><span class="pun">(</span><span class="str">"${connection}.send_cnt: ${it.send_cnt}"</span><span class="pun">)</span><span class="pln">
</span><span class="pun">}</span><span class="pln">

</span><span class="kwd">return</span><span class="pln"> </span><span class="lit">0</span><span class="pun">;</span>

discovery script:

<span class="kwd">import</span><span class="pln"> com</span><span class="pun">.</span><span class="pln">santaba</span><span class="pun">.</span><span class="pln">agent</span><span class="pun">.</span><span class="pln">groovyapi</span><span class="pun">.</span><span class="pln">http</span><span class="pun">.*</span><span class="pln">
</span><span class="kwd">import</span><span class="pln"> groovy</span><span class="pun">.</span><span class="pln">json</span><span class="pun">.*</span><span class="pln">

def hostName </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"system.hostname"</span><span class="pun">)</span><span class="pln">

def rabbitPort </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.port"</span><span class="pun">)</span><span class="pln">
def rabbitUser </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.user"</span><span class="pun">)</span><span class="pln">
def rabbitPass </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.pass"</span><span class="pun">)</span><span class="pln">
def rabbitAddr </span><span class="pun">=</span><span class="pln"> hostProps</span><span class="pun">.</span><span class="pln">get</span><span class="pun">(</span><span class="str">"rabbitmq.apiurl"</span><span class="pun">)</span><span class="pln">

def urlList </span><span class="pun">=</span><span class="pln"> </span><span class="pun">[</span><span class="str">"${rabbitAddr}"</span><span class="pun">,</span><span class="pln">
               </span><span class="str">"https://${hostName}:${rabbitPort}"</span><span class="pun">,</span><span class="pln">
               </span><span class="str">"http://${hostName}:${rabbitPort}"</span><span class="pun">]</span><span class="pln">

def getResult</span><span class="pun">(</span><span class="pln">urlList</span><span class="pun">,</span><span class="pln"> apiPath</span><span class="pun">,</span><span class="pln"> rabbitUser</span><span class="pun">,</span><span class="pln"> rabbitPass</span><span class="pun">,</span><span class="pln"> rabbitPort</span><span class="pun">){</span><span class="pln">
    def response </span><span class="pun">=</span><span class="pln"> null
    urlList</span><span class="pun">.</span><span class="pln">each</span><span class="pun">{</span><span class="pln">url</span><span class="pun">-></span><span class="pln">
        </span><span class="kwd">if</span><span class="pun">(</span><span class="pln">url </span><span class="pun">!=</span><span class="pln"> </span><span class="str">"null"</span><span class="pln"> </span><span class="pun">&&</span><span class="pln"> </span><span class="pun">!</span><span class="pln">response</span><span class="pun">){</span><span class="pln">
            </span><span class="kwd">try</span><span class="pun">{</span><span class="pln">
                def conn </span><span class="pun">=</span><span class="pln"> </span><span class="kwd">new</span><span class="pln"> URL</span><span class="pun">(</span><span class="pln">url </span><span class="pun">+</span><span class="pln"> apiPath</span><span class="pun">).</span><span class="pln">openConnection</span><span class="pun">()</span><span class="pln">
                conn</span><span class="pun">.</span><span class="pln">setReadTimeout</span><span class="pun">(</span><span class="lit">1500</span><span class="pun">)</span><span class="pln">
                def authString </span><span class="pun">=</span><span class="pln"> </span><span class="str">"${rabbitUser}:${rabbitPass}"</span><span class="pun">.</span><span class="pln">getBytes</span><span class="pun">().</span><span class="pln">encodeBase64</span><span class="pun">().</span><span class="pln">toString</span><span class="pun">()</span><span class="pln">
                conn</span><span class="pun">.</span><span class="pln">setRequestProperty</span><span class="pun">(</span><span class="str">"Authorization"</span><span class="pun">,</span><span class="pln"> </span><span class="str">"Basic ${authString}"</span><span class="pun">)</span><span class="pln">
                response </span><span class="pun">=</span><span class="pln"> conn</span><span class="pun">.</span><span class="pln">getInputStream</span><span class="pun">().</span><span class="pln">getText</span><span class="pun">()</span><span class="pln">
            </span><span class="pun">}</span><span class="pln"> </span><span class="kwd">catch</span><span class="pun">(</span><span class="typ">Exception</span><span class="pln"> ex</span><span class="pun">){</span><span class="pln">
                </span><span class="com">// println "Exception: " + ex.message // URL Invalid!</span><span class="pln">
            </span><span class="pun">}</span><span class="pln">
        </span><span class="pun">}</span><span class="pln">
    </span><span class="pun">}</span><span class="pln">
    </span><span class="kwd">return</span><span class="pln"> response
</span><span class="pun">}</span><span class="pln">

def response </span><span class="pun">=</span><span class="pln"> getResult</span><span class="pun">(</span><span class="pln">urlList</span><span class="pun">,</span><span class="pln"> </span><span class="str">"/api/connections"</span><span class="pun">,</span><span class="pln"> rabbitUser</span><span class="pun">,</span><span class="pln"> rabbitPass</span><span class="pun">,</span><span class="pln"> rabbitPort</span><span class="pun">)</span><span class="pln">
</span><span class="kwd">if</span><span class="pun">(!</span><span class="pln">response</span><span class="pun">){</span><span class="kwd">return</span><span class="pln"> </span><span class="lit">1</span><span class="pun">}</span><span class="pln">

def slurper </span><span class="pun">=</span><span class="pln"> </span><span class="kwd">new</span><span class="pln"> </span><span class="typ">JsonSlurper</span><span class="pun">()</span><span class="pln">
def json </span><span class="pun">=</span><span class="pln"> slurper</span><span class="pun">.</span><span class="pln">parseText</span><span class="pun">(</span><span class="pln">response</span><span class="pun">)</span><span class="pln">
json</span><span class="pun">.</span><span class="pln">each</span><span class="pun">{</span><span class="pln">
    println</span><span class="pun">(</span><span class="str">"${it.name.replaceAll("</span><span class="pln"> </span><span class="str">","").replaceAll("</span><span class="pun">:</span><span class="str">","</span><span class="pun">-</span><span class="str">")}##${it.name.replaceAll("</span><span class="pln"> </span><span class="str">","")}######node=${it.node}&protocol=${it.protocol}&type=${it.type}"</span><span class="pun">)</span><span class="pln">
</span><span class="pun">}</span><span class="pln">
</span><span class="kwd">return</span><span class="pln"> </span><span class="lit">0</span>

1	SUYASH GAIKWAD
2	PJ Pankaj Jain
3	KT Kyle Taylor
4	KV karthikeyan VG
5	ME Mir Ehtesham Ali
6	SN Sangeetha Nataraj