@Test public void getRegisterServiceRequestBodyTest() { JamService jamService = new JamService("http: assertTrue(jamService.getServiceQueueExistRequestBody("myQueueName", "tcp: assertTrue(jamService.getRegisterServiceRequestBody("myQueueName", "tcp: }
protected String getRegisterServiceRequestBody(final String queueName, final String brokerUrl, final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery, final boolean profileEnabled) { return "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> " + " <serviceQueue>" + " <queueName>" + StringEscapeUtils.escapeXml(queueName) + "</queueName>" + " <brokerUrl>" + StringEscapeUtils.escapeXml(brokerUrl) + "</brokerUrl>" + " <queryIntervalInSeconds>" + queryIntervalInSeconds + "</queryIntervalInSeconds>" + " <resetStatisticsAfterQuery>" + resetStatisticsAfterQuery + "</resetStatisticsAfterQuery>" + " <profileEnabled>" + profileEnabled + "</profileEnabled>" + "</serviceQueue>"; }
JamService { protected String getRegisterServiceRequestBody(final String queueName, final String brokerUrl, final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery, final boolean profileEnabled) { return "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> " + " <serviceQueue>" + " <queueName>" + StringEscapeUtils.escapeXml(queueName) + "</queueName>" + " <brokerUrl>" + StringEscapeUtils.escapeXml(brokerUrl) + "</brokerUrl>" + " <queryIntervalInSeconds>" + queryIntervalInSeconds + "</queryIntervalInSeconds>" + " <resetStatisticsAfterQuery>" + resetStatisticsAfterQuery + "</resetStatisticsAfterQuery>" + " <profileEnabled>" + profileEnabled + "</profileEnabled>" + "</serviceQueue>"; } }
JamService { protected String getRegisterServiceRequestBody(final String queueName, final String brokerUrl, final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery, final boolean profileEnabled) { return "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> " + " <serviceQueue>" + " <queueName>" + StringEscapeUtils.escapeXml(queueName) + "</queueName>" + " <brokerUrl>" + StringEscapeUtils.escapeXml(brokerUrl) + "</brokerUrl>" + " <queryIntervalInSeconds>" + queryIntervalInSeconds + "</queryIntervalInSeconds>" + " <resetStatisticsAfterQuery>" + resetStatisticsAfterQuery + "</resetStatisticsAfterQuery>" + " <profileEnabled>" + profileEnabled + "</profileEnabled>" + "</serviceQueue>"; } JamService(String jamServerBaseUrl); }
JamService { protected String getRegisterServiceRequestBody(final String queueName, final String brokerUrl, final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery, final boolean profileEnabled) { return "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> " + " <serviceQueue>" + " <queueName>" + StringEscapeUtils.escapeXml(queueName) + "</queueName>" + " <brokerUrl>" + StringEscapeUtils.escapeXml(brokerUrl) + "</brokerUrl>" + " <queryIntervalInSeconds>" + queryIntervalInSeconds + "</queryIntervalInSeconds>" + " <resetStatisticsAfterQuery>" + resetStatisticsAfterQuery + "</resetStatisticsAfterQuery>" + " <profileEnabled>" + profileEnabled + "</profileEnabled>" + "</serviceQueue>"; } JamService(String jamServerBaseUrl); HttpClient getClient(); void setClient(HttpClient client); String getJamServerBaseUrl(); void setJamServerBaseUrl(String jamServerBaseUrl); void addServerToServiceQueue(final String queueName, final String brokerUrl,
                                        final String host, final int port); void disableServiceQueue(final String queueName); boolean doesServiceQueueExist(final String queueName, final String brokerUrl); void enableServiceQueue(final String queueName); void registerServiceQueue(final String queueName, final String brokerUrl,
                                     final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery,
                                     final boolean profileEnabled); void removeServerFromServiceQueue(final String queueName, final String brokerUrl,
                                             final String host, final int port); void removeServiceQueue(final String queueName); void runGather(final String queueName, final String brokerUrl); int loadJMXAgent(int port); }
JamService { protected String getRegisterServiceRequestBody(final String queueName, final String brokerUrl, final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery, final boolean profileEnabled) { return "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> " + " <serviceQueue>" + " <queueName>" + StringEscapeUtils.escapeXml(queueName) + "</queueName>" + " <brokerUrl>" + StringEscapeUtils.escapeXml(brokerUrl) + "</brokerUrl>" + " <queryIntervalInSeconds>" + queryIntervalInSeconds + "</queryIntervalInSeconds>" + " <resetStatisticsAfterQuery>" + resetStatisticsAfterQuery + "</resetStatisticsAfterQuery>" + " <profileEnabled>" + profileEnabled + "</profileEnabled>" + "</serviceQueue>"; } JamService(String jamServerBaseUrl); HttpClient getClient(); void setClient(HttpClient client); String getJamServerBaseUrl(); void setJamServerBaseUrl(String jamServerBaseUrl); void addServerToServiceQueue(final String queueName, final String brokerUrl,
                                        final String host, final int port); void disableServiceQueue(final String queueName); boolean doesServiceQueueExist(final String queueName, final String brokerUrl); void enableServiceQueue(final String queueName); void registerServiceQueue(final String queueName, final String brokerUrl,
                                     final int queryIntervalInSeconds, final boolean resetStatisticsAfterQuery,
                                     final boolean profileEnabled); void removeServerFromServiceQueue(final String queueName, final String brokerUrl,
                                             final String host, final int port); void removeServiceQueue(final String queueName); void runGather(final String queueName, final String brokerUrl); int loadJMXAgent(int port); static final Logger LOGGER; }