Apache/lucene
1
0
Fork 0
mirror of https://github.com/apache/lucene.git synced 2025-02-27 21:09:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added debug output and changed the failing test to use SolrIndexSearcher's ObjectName directly.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/lucene/solr/trunk@681640 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Shalin Shekhar Mangar 2008-08-01 10:04:48 +00:00
parent 670174c87b
commit 1d92c29bf0
1 changed files with 16 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
src/test/org/apache/solr/core/TestJmxIntegration.java
View File

@ -26,6 +26,7 @@ import javax.management.*;
import java.lang.management.ManagementFactory;
import java.util.List;
import java.util.Set;
import java.util.Hashtable;
/**
* Test for JMX Integration
@ -83,39 +84,27 @@ public class TestJmxIntegration extends AbstractSolrTestCase {
public void testJmxUpdate() throws Exception {
List<MBeanServer> servers = MBeanServerFactory.findMBeanServer(null);
System.out.println("Servers in testJmxUpdate: " + servers);
boolean found = false;
Set<ObjectInstance> objects = null;
MBeanServer mbeanServer = null;
for (MBeanServer server : servers) {
objects = server.queryMBeans(null, Query.match(
Query.attr("numDocs"), Query.value("*")));
if (!objects.isEmpty()) {
found = true;
mbeanServer = server;
break;
}
}
ObjectName searcher = getObjectName("searcher", h.getCore().getInfoRegistry().get("searcher"));
MBeanServer mbeanServer = servers.get(0);
System.out.println("Mbeans in server: " + mbeanServer.queryNames(null, null));
if (!found) {
assertFalse("No MBean for SolrIndexSearcher found in MBeanServer", objects.isEmpty());
}
int oldNumDocs = Integer.valueOf((String) mbeanServer.getAttribute(objects
.iterator().next().getObjectName(), "numDocs"));
assertFalse("No mbean found for SolrIndexSearcher", mbeanServer.queryMBeans(searcher, null).isEmpty());
int oldNumDocs = Integer.valueOf((String) mbeanServer.getAttribute(searcher, "numDocs"));
assertU(adoc("id", "1"));
assertU(commit());
objects = mbeanServer.queryMBeans(null, Query.match(Query.attr("numDocs"),
Query.value("*")));
assertFalse("No MBean for SolrIndexSearcher found in MBeanServer", objects
.isEmpty());
int numDocs = Integer.valueOf((String) mbeanServer.getAttribute(objects
.iterator().next().getObjectName(), "numDocs"));
assertU("commit", commit());
int numDocs = Integer.valueOf((String) mbeanServer.getAttribute(searcher, "numDocs"));
assertTrue("New numDocs is same as old numDocs as reported by JMX",
numDocs > oldNumDocs);
}
private ObjectName getObjectName(String key, SolrInfoMBean infoBean)
throws MalformedObjectNameException {
Hashtable<String, String> map = new Hashtable<String, String>();
map.put("type", key);
map.put("id", infoBean.getName());
return ObjectName.getInstance("solr", map);
}
}