Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-3753: Expose More Metrics via IMBE

Browse Source 
JIRA: https://jira.spring.io/browse/INT-3753

INT-3753: Add Channel Send Count to IMBE

Missing accessor for channel send counts.

Expose Full Metrics Objects
This commit is contained in:
Gary Russell
2015-06-30 09:31:30 -04:00
parent 9c96a14cd1
commit 4131c82faf
3 changed files with 88 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-integration-jmx/src/test/java/org/springframework/integration/monitor/ChannelIntegrationTests-context.xml
View File

@@ -8,10 +8,11 @@
<int:channel id="requests" />
<int:channel id="intermediate">
<int:queue capacity="99" />
<int:queue capacity="1" />
</int:channel>
<int:bridge id="bridge" input-channel="requests" output-channel="intermediate"/>
<int:bridge id="bridge" input-channel="requests" output-channel="intermediate"
send-timeout="1" />
<bean id="mbeanExporter" class="org.springframework.integration.monitor.IntegrationMBeanExporter">
<property name="server" ref="mbeanServer" />
@@ -22,4 +23,8 @@
<property name="locateExistingServerIfPossible" value="true" />
</bean>
<int:inbound-channel-adapter id="source" channel="nullChannel" expression="''">
<int:poller fixed-delay="10" />
</int:inbound-channel-adapter>
</beans>

36
spring-integration-jmx/src/test/java/org/springframework/integration/monitor/ChannelIntegrationTests.java
View File

@@ -12,14 +12,18 @@
*/
package org.springframework.integration.monitor;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.assertTrue;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.handler.management.MessageHandlerMetrics;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageDeliveryException;
import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.test.annotation.DirtiesContext;
@@ -50,15 +54,41 @@ public class ChannelIntegrationTests {
requests.send(new GenericMessage<String>("foo"));
String intermediateChannelName = "" + intermediate;
assertEquals(1, messageChannelsMonitor.getChannelSendCount(intermediateChannelName));
double rate = messageChannelsMonitor.getChannelSendRate("" + requests).getMean();
assertTrue("No statistics for requests channel", rate >= 0);
rate = messageChannelsMonitor.getChannelSendRate("" + intermediate).getMean();
rate = messageChannelsMonitor.getChannelSendRate(intermediateChannelName).getMean();
assertTrue("No statistics for intermediate channel", rate >= 0);
assertNotNull(intermediate.receive(100L));
double count = messageChannelsMonitor.getChannelReceiveCount("" + intermediate);
assertTrue("No statistics for intermediate channel", count >= 0);
assertEquals(1, messageChannelsMonitor.getChannelReceiveCount(intermediateChannelName));
requests.send(new GenericMessage<String>("foo"));
try {
requests.send(new GenericMessage<String>("foo"));
}
catch (MessageDeliveryException e) {
}
assertEquals(3, messageChannelsMonitor.getChannelSendCount(intermediateChannelName));
assertEquals(1, messageChannelsMonitor.getChannelSendErrorCount(intermediateChannelName));
assertSame(intermediate, messageChannelsMonitor.getChannelMetrics(intermediateChannelName));
MessageHandlerMetrics handlerMetrics = messageChannelsMonitor.getHandlerMetrics("bridge");
assertEquals(3, handlerMetrics.getHandleCount());
assertEquals(1, handlerMetrics.getErrorCount());
Thread.sleep(50);
assertTrue(messageChannelsMonitor.getSourceMessageCount("source") > 0);
assertTrue(messageChannelsMonitor.getSourceMetrics("source").getMessageCount() > 0);
}