我正在尝试从 JBoss EAP 6.3 实例连接到 Websphere MQ。我可以使连接正常工作,但需要我将主机名编码到 bean 中。有些事我宁愿不做。我在standalone.xml 中有一些配置,但我认为这些设置没有被使用。
这是我的standalone.xml 中的内容:
<subsystem xmlns="urn:jboss:domain:resource-adapters:1.1">
<resource-adapters>
<resource-adapter id="wmq.jmsra.rar">
<archive>
wmq.jmsra.rar
</archive>
<transaction-support>NoTransaction</transaction-support>
<connection-definitions>
<connection-definition class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" jndi-name="java:/jms/wmqCF" enabled="true" use-java-context="true" pool-name="wmqCF">
<config-property name="port">
1414
</config-property>
<config-property name="hostName">
my.mqserver.net
</config-property>
<config-property name="channel">
SYSTEM.DEF.SVRCONN
</config-property>
<config-property name="transportType">
CLIENT
</config-property>
<config-property name="queueManager">
MY.QUEUE.MANAGER
</config-property>
</connection-definition>
</connection-definitions>
</resource-adapter>
</resource-adapters>
</subsystem>
在我的 bean 中,我有以下注释:
@MessageDriven( name="WebSphereMQMDB",
activationConfig =
{
@ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "MQ.QUEUE.NAME")
})
public class WebSphereMQMDB implements MessageListener {
}
当我部署上述代码时,出现错误,指出它无法连接到 localhost(1414) 上的队列管理器。当我将 hostName 属性添加到 bean 时,它确实可以工作,如下所示:
@MessageDriven( name="WebSphereMQMDB",
activationConfig =
{
@ActivationConfigProperty(propertyName = "hostName",propertyValue = "my.mqserver.net"),
@ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "MQ.QUEUE.NAME")
})
public class WebSphereMQMDB implements MessageListener {
}
如何让我的 bean 使用standalone.xml 中的配置,这样我就不必在每个 bean 中设置 hostName 属性?
最佳答案
standalone.xml 上的定义对于到 websphere MQ 的传出连接有效(向队列发送消息)。在我们从 HornetQ 迁移到 WebSphere 的应用程序中,我们在 META-INF 文件夹中添加 ejb-jar.xml,内容如下:
<?xml version='1.0' encoding='UTF-8' ?>
<ejb-jar id="ejb-jar_1" xmlns="http://java.sun.com/xml/ns/j2ee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
http://java.sun.com/xml/ns/j2ee/ejb-jar_2_1.xsd"
version="2.1">
<enterprise-beans>
<message-driven>
<ejb-name>WebSphereMQMDB</ejb-name>
<ejb-class>com.your.package.WebSphereMQMDB </ejb-class>
<transaction-type>Container</transaction-type>
<message-destination-type>javax.jms.Queue</message-destination-type>
<activation-config>
<activation-config-property>
<activation-config-property-name>maxSession</activation-config-property-name>
<activation-config-property-value>8</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>destination</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.destination}</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>hostName</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.hostname}</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>port</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.port}</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>queueManager</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.queuemanager}</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>channel</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.channel}</activation-config-property-value>
</activation-config-property>
<activation-config-property>
<activation-config-property-name>transportType</activation-config-property-name>
<activation-config-property-value>${com.your.package.MQ.transporttype}</activation-config-property-value>
</activation-config-property>
</activation-config>
</message-driven>
</enterprise-beans>
</ejb-jar>
然后您应该在扩展之后立即在standalone.xml 上定义属性,例如:
<system-properties>
<property name="com.your.package.MQ.destination" value="Q00.APP.AG000001" />
<property name="com.your.package.MQ.hostname" value="mqserver.yourcompany.com" />
<property name="com.your.package.MQ.port" value="1416" />
<property name="com.your.package.MQ.queuemanager" value="Q00" />
<property name="com.your.package.MQ.channel" value="Q00.APP.SVRCONN" />
<property name="com.your.package.MQ.transporttype" value="Client" />
</system-properties>
希望对你有帮助
关于java - 从standalone.xml到MQ的JBoss连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28767145/