2015-01-29 3 views
1

Исходя из этого link, я подключил JBoss eap 6.2 к внешнему ActiveMQ 5.9.0. org.apache.activemq.ActiveMQConnectionFactory имеет поле sendTimeout, которое я хочу установить. Но в этом подходе я не могу получить доступ к этому классу напрямую, и кажется, что все, что я могу сделать, это добавить некоторый параметр в ServerUrl в resouce-adapter замедление в standalone.xml в JBoss.Настройка sendTimeout при подключении к ActiveMQ с адаптером ресурсов Jboss

Исходя из этого link, можно добавить параметр в ServerUrl, но, похоже, он не имеет параметра sendTimeout. И это link (ActiveMQ CPP) вводит некоторые другие параметры, что они не работают, и я получаю ниже ошибки в запуске JBoss:

java.lang.IllegalArgumentException: Invalid connect parameters: {connection.sendTimeout=20000} 

resource-adapter ActiveMQ в standalone.xml файл:

<subsystem xmlns="urn:jboss:domain:resource-adapters:1.1"> 
    <resource-adapters> 
     <resource-adapter id="activemq-rar.ra"> 
      <module slot="main" id="org.apache.activemq"/> 
      <transaction-support>LocalTransaction</transaction-support> 
      <config-property name="ServerUrl">tcp://localhost:61616?connection.sendTimeout=20000</config-property> 
      <connection-definitions> 
       <connection-definition class-name="org.apache.activemq.ra.ActiveMQManagedConnectionFactory" jndi-name="java:/activemq/ConnectionFactory" enabled="true" use-java-context="true" pool-name="ActiveMQConnectionFactoryPool"> 
       </connection-definition> 
      </connection-definitions> 
     </resource-adapter> 
     <!--resource-adapter--> 
    </resource-adapters> 
</subsystem> 

Так как может i установить значение этого параметра? Должен ли я конфигурировать ServerUrl в файле ra.xml?

ответ

1

основы this config page, timeout параметра Failover Transport Options:

Если посыл заблокирован в ожидании на неверном воссоединиться, как долго она должна ждать, прежде чем провалив посыл, по умолчанию навсегда (-1).

Так я изменил ServerUrl собственности resource-adapterra.xml и к:

отказоустойчивые: // (TCP: //127.0.0.1: 61616)? Таймаут = 20000

Смежные вопросы