我正在尝试访问消息处理程序端点以通过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 中)中找到它。