Блог

У меня настроен WSO2 CEP с адаптером событий ввода, установленным для прослушивания очереди IBM WebSphere MQ. Ниже есть conf в 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. Куда мне нужно поместить этот параметр? Я пробовал в адаптере событий и в построителе событий, но это не работает.

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

Питер

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

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

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

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