WSO2 CEP IBM MQ и transport.jms.ConcurrentConsumers

У меня есть CEP WSO2, настроенный с помощью адаптера входных событий, настроенного на прослушивание очереди IBM WebSphere MQ. Ниже есть конфа в xml:

<inputEventAdaptor name="WEBSPHEREMQ" statistics="disable" trace="disable" type="jms" xmlns="http://wso2.org/carbon/eventadaptormanager">
  <property name="java.naming.provider.url">file:/opt/bindings</property>
  <property name="transport.jms.SubscriptionDurable">false</property>
  <property name="java.naming.factory.initial">com.sun.jndi.fscontext.RefFSContextFactory</property>
  <property name="transport.jms.ConnectionFactoryJNDIName">MQ_JMS_MANAGER</property>
  <property name="transport.jms.DestinationType">queue</property>
</inputEventAdaptor>

и построитель событий с набором очереди:

<from eventAdaptorName="WEBSPHEREMQ" eventAdaptorType="jms">
  <property name="transport.jms.Destination">MSCRM_IN_JMS_QUEUE</property>
</from>

Я хочу увеличить transport.jms.ConcurrentConsumers, чтобы ускорить результаты производительности CEP. Где мне нужно поставить этот параметр? Я пробовал в адаптере событий и в построителе событий, но это не работает.

Большое спасибо за любую помощь! :)

Питер


performance wso2 ibm-mq jms wso2cep
person peter    schedule 02.07.2014    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Извините, на данный момент нет никакого способа передать это свойство из коробки адаптеру jms. Но я твердо верю, что это хорошее дополнение для адаптера jms. Мы делаем некоторые улучшения, связанные с этим, стремясь к следующему выпуску. Я создал jira [1], чтобы отслеживать это..

[1] https://wso2.org/jira/browse/CEP-884

на данный момент у вас есть два варианта: улучшить текущий входной jms-адаптер, исправив его в исходном коде, или написать собственный jms-адаптер, который вам нужен.

Спасибо, Мохан

person Mohanadarshan    schedule 02.07.2014