我们使用的是JBoss EAP6.4。在我们的项目中,我们使用两个MOM: 1) Websphere MQ 2) Solace MQ这是上面两个MOM在我们的standalone.xml中定义的资源适配器
<?xml version='1.0' encoding='UTF-8'?>
<server xmlns="urn:jboss:domain:1.7">
<profile>
<subsystem xmlns="urn:jboss:domain:ejb3:1.5">
<mdb>
<resource-adapter-ref resource-adapter-name="wmq.jmsra.rar"/>
<bean-instance-pool-ref pool-name="mdb-strict-max-pool"/>
</mdb>
<pools>
<bean-instance-pools>
<strict-max-pool name="mdb-strict-max-pool" max-pool-size="20" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>
</bean-instance-pools>
</pools>
</subsystem>
<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>
<config-property name="traceLevel">3</config-property>
<config-property name="traceEnabled">true</config-property>
<connection-definitions>
<connection-definition class-name="com.ibm.mq.connector.outbound.ManagedQueueConnectionFactoryImpl" jndi-name="java:jboss/jms/myJMSQueueConnectionFactory" enabled="true" use-java-context="true" pool-name="jms/myJMSQueueConnectionFactoryPool">
<config-property name="channel">${mq.channel}</config-property>
<config-property name="hostName">${mq.host}</config-property>
<config-property name="transportType">${mq.transportType}</config-property>
<config-property name="queueManager">${mq.manager}</config-property>
<config-property name="port">${mq.port}</config-property>
</connection-definition>
</connection-definitions>
<admin-objects>
<admin-object class-name="com.ibm.mq.connector.outbound.MQQueueProxy" jndi-name="java:jboss/jms/abcQueue" enabled="true" use-java-context="true" pool-name="jms/abcQueuePool">
<config-property name="targetClient">MQ</config-property>
<config-property name="persistence">PERS</config-property>
<config-property name="expiry">UNLIMITED</config-property>
<config-property name="baseQueueName">${my.abc.queue}</config-property>
<config-property name="arbitraryProperties">mdMessageContext="2",mdWriteEnabled="true",mdReadEnabled="true"</config-property>
<config-property name="baseQueueManagerName">${mq.manager}</config-property>
</admin-object>
</admin-objects>
</resource-adapter>
<resource-adapter id="com.solacesystems.ra">
<archive>sol-jms-ra-7.1.2.248.rar</archive>
<transaction-support>NoTransaction</transaction-support>
<config-property name="extendedProps">${solace.extendedproperties}</config-property>
<config-property name="UserName">${solace.username}</config-property>
<config-property name="MessageVPN">${solace.vpn}</config-property>
<config-property name="ConnectionURL">${solace.connectionurl}</config-property>
<config-property name="Password">${solace.password}</config-property>
<connection-definitions>
<connection-definition class-name="com.solacesystems.jms.ra.outbound.ManagedJMSConnectionFactory" jndi-name="java:jboss/jms/solaceMessageConnectionFactory" enabled="true" pool-name="solaceMessageCFPool">
<config-property name="ConnectionFactoryJndiName">${solace.connectionfactory}</config-property>
<security>
<application/>
</security>
<validation>
<background-validation>false</background-validation>
</validation>
<recovery>
<recover-credential>
<user-name>${solace.username}</user-name>
<password>${solace.password}</password>
</recover-credential>
</recovery>
</connection-definition>
</connection-definitions>
<admin-objects>
<admin-object class-name="com.solacesystems.jms.ra.outbound.TopicProxy" jndi-name="java:jboss/jms/xyzMessageTopic" enabled="true" use-java-context="false" pool-name="xyzMessageTopicPool">
<config-property name="Destination">${xyz.topic}</config-property>
</admin-object>
</admin-objects>
</resource-adapter>
</resource-adapters>
</subsystem>
</profile>
在上面的文件中,我们基本上定义了两个resourceAdapters --一个用于WMQ,另一个用于Solace。
<mdb>标记下,我们定义了默认资源适配器名和定义了<bean-instance-pool-ref值,以限制默认情况下用于消息驱动Beans的实例池。由于我们有多个消息驱动的bean同时监听WMQ和SOLACE,所以我的问题是:
发布于 2016-10-19 15:03:00
1)没有指定实例池的mdb将使用默认的mdb-严格-最大-池。您可以定义自己的池(我建议这样做):
<pools>
<bean-instance-pools>
<strict-max-pool name="slsb-strict-max-pool" max-pool-size="20" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>
<strict-max-pool name="mdb-strict-max-pool" max-pool-size="20" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>
<strict-max-pool name="MyPool" max-pool-size="10" instance-acquisition-timeout="5" instance-acquisition-timeout-unit="MINUTES"/>
</bean-instance-pools>
</pools>然后使用注释:
import org.jboss.ejb3.annotation.Pool;
@Pool(value="MyPool") 在MDB里。这也可以在部署描述符文件中完成。
2)见上文。我更喜欢每个MDB部署的实例池。我不喜欢MDB竞争实例池。
3)与上述相同。请注意,您可以看到MDB部署在JMX中使用的实例池名称。注意,如果您有单独的实例池,则池统计信息将变得更有意义。
https://stackoverflow.com/questions/40112293
复制相似问题