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

INT-1816 chahnged NotificationPublishingMessageHandler to select the first available MBeanExporter instance

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-03-10 10:02:35 -05:00
parent b7deee0475
commit de8ff948e7
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-integration-jmx/src/main/java/org/springframework/integration/jmx/NotificationPublishingMessageHandler.java
View File

@@ -29,7 +29,7 @@ import org.springframework.beans.factory.ListableBeanFactory;
import org.springframework.integration.Message;
import org.springframework.integration.handler.AbstractMessageHandler;
import org.springframework.integration.mapping.OutboundMessageMapper;
import org.springframework.integration.monitor.IntegrationMBeanExporter;
import org.springframework.jmx.export.MBeanExporter;
import org.springframework.jmx.export.annotation.ManagedResource;
import org.springframework.jmx.export.notification.NotificationPublisher;
import org.springframework.jmx.export.notification.NotificationPublisherAware;
@@ -90,12 +90,12 @@ public class NotificationPublishingMessageHandler extends AbstractMessageHandler
@Override
public final void onInit() throws Exception {
Assert.isTrue(this.getBeanFactory() instanceof ListableBeanFactory, "A ListableBeanFactory is required.");
Map<String, IntegrationMBeanExporter> exporters = BeanFactoryUtils.beansOfTypeIncludingAncestors(
(ListableBeanFactory) this.getBeanFactory(), IntegrationMBeanExporter.class);
Assert.isTrue(exporters.size() == 1,
"No unique IntegrationMBeanExporter is available in the current context (found " +
Map<String, MBeanExporter> exporters = BeanFactoryUtils.beansOfTypeIncludingAncestors(
(ListableBeanFactory) this.getBeanFactory(), MBeanExporter.class);
Assert.isTrue(exporters.size() > 0,
"No MBeanExporter is available in the current context (found " +
exporters.size() + ").");
IntegrationMBeanExporter exporter = exporters.values().iterator().next();
MBeanExporter exporter = exporters.values().iterator().next();
if (this.notificationMapper == null) {
this.notificationMapper = new DefaultNotificationMapper(this.objectName, this.defaultNotificationType);
}