Skip to Main Content

Integration

Announcement

For appeals, questions and feedback about Oracle Forums, please email oracle-forums-moderators_us@oracle.com. Technical questions should be asked in the appropriate category. Thank you!

how to use MessageSelector in JMS adapter ,

810575Feb 12 2014 — edited Feb 14 2014


HI All ,

       Sub : Consumer JMS adapter not able to create instance . Messages are keep on increasing in Queue .

i have a requirment , where i need to deQueue message from server Weblogic Q ,

But for DeQueueing , there is a condition which i implemented through MessageSelector in JMS adapter  .

  I am setting the JMSHeaderProperty values in Producer process by invoke property .like below .. Setted properties are showing perfectly in console as well .

      <bpelx:inputProperty name="jca.jms.JMSPriority" expression="9"/>

      <bpelx:inputProperty name="jca.jms.JMSCorrelationID"  variable="inputVariable" part="payload" query="/ns2:Input/ns2:Value"/>

I have configured my consumer JMS adapter . corresponding .jca file is as below .

Used MessageSelector like .. <property name="MessageSelector" value="jca.jms.JMSCorrelationID &gt; 5 "/>   and <property name="MessageSelector" value="JMSCorrelationID &gt; 5 "/> both

If i remove the  MessageSelector property , its able to pick up the messages from Queue . with this property its NOT picking from Queue .

I have checked few links like..

  https://community.oracle.com/message/9585652

  http://docs.oracle.com/cd/E28280_01/integration.1111/e10231/adptr_jms.htm

  http://docs.oracle.com/cd/E25178_01/integration.1111/e10231/adptr_propertys.htm

Can any one help me out , why messages are not getting picked by consumer when i am putting this MessageSelector property .

==================================JCA file=============================================

<adapter-config name="Consumer" adapter="JMS Adapter" wsdlLocation="Consumer.wsdl" xmlns="http://platform.integration.oracle/blocks/adapter/fw/metadata"> 

  <connection-factory location="eis/wljms/POC_QUEUE" UIJmsProvider="WLSJMS" UIConnectionName="ApplicationServerConn"/>

  <endpoint-activation portType="Consume_Message_ptt" operation="Consume_Message">

    <activation-spec className="oracle.tip.adapter.jms.inbound.JmsConsumeActivationSpec">

      <property name="PayloadType" value="TextMessage"/>

     <property name="MessageSelector" value="jca.jms.JMSCorrelationID &gt; 5 "/>     <!--  <property name="MessageSelector" value="JMSCorrelationID &gt; 5 "/>  -->

      <property name="UseMessageListener" value="false"/>

      <property name="DestinationName" value="jms/aia/POC_QUEUE"/>

    </activation-spec>

  </endpoint-activation>

</adapter-config>

Comments
Locked Post
New comments cannot be posted to this locked post.
Post Details
Locked on Mar 14 2014
Added on Feb 12 2014
4 comments
2,374 views