以编程方式访问通过 JMX 公开的消息处理程序



我正在尝试访问消息处理程序端点以通过JMX启动和停止服务。我的上下文文件中有以下配置。我能够通过JConsole访问启动/停止方法。

我还能够使用MBeanServerConnectionFactoryBean从基于spring的客户端访问端点。

现在我想使用 MBeanProxyFactoryBean 访问端点,以便我可以直接调用这些方法,就好像 bean 是本地的一样。这似乎行不通。

您能否在下面查看我的配置并建议出了什么问题或还需要做什么?

服务器.xml

    <int-jms:message-driven-channel-adapter id="jmsIn" 
    connection-factory="connectionFactory" concurrent-consumers="3" max-concurrent-consumers="5" 
    destination-name="emsQueue" acknowledge="transacted" channel="jmsInChannel"  
    extract-payload="false" />
 <integration:service-activator id="serviceAct" input-channel="jmsInChannel" output-channel="fileNamesChannel" 
    ref="handler" method="process" />

客户端.xml

<bean id="mBeanServerClient" class="org.springframework.jmx.support.MBeanServerConnectionFactoryBean">
    <property name="serviceUrl" value="service:jmx:rmi:///jndi/rmi://localhost:9004/jmxrmi" />
</bean>
<bean id="jmxClient" class="com.abc.test.IBalJMXClient">
    <property name="connection" ref="mBeanServerClient" />
</bean>
<bean id="remoteJMSMBean" class="org.springframework.jmx.access.MBeanProxyFactoryBean">
    <property name="objectName" value="com.abc.test:name=serviceAct" />
    <property name="server" ref="mBeanServerClient" />
    <property name="proxyInterface" value="com.abc.client.intf.IBalJMSController" />
</bean>

IBalJMSController 是我在其中定义 start()、stop() 和 isRunning() 方法的接口,以便我可以从任何类访问它。

当我尝试测试它时,我收到调用异常。任何建议将不胜感激

你在春季论坛上问了同样的问题;我在那里回答了;http://forum.springsource.org/showthread.php?127726-Programatically-access-MessageHandlers-exposed-via-JMX

但我会在这里重复答案...

首先,停止处理程序不是正确的做法 - 所做的只是取消订阅频道,消息将收到错误"调度程序没有订阅者"。您需要停止()消息驱动的通道适配器。

其次,您需要提供完整的MBean对象名称,例如"com.irebalpoc.integration:type=ManagedEndpoint,na me=jmsin,bean=endpoint"。您可以在 MBean 元数据(例如在 VisualVM 中)中找到它。

相关内容

  • 没有找到相关文章