Hi Gert,
Firstly i want to know the sender endpoint from drools component(i.e, i
want to know how to write a rule for determining sender endpoint)
Secondly you are talking about message auditor, could you please elobarate
how to do this? if possible with example.
Gert Vanthienen wrote:
>
> Arif Mohd,
>
>
> I think this is possible if you use the
> ${org.apache.servicemix.senderEndpoint} property in your CBR's xpath
> expressions to determine the sender endpoint. However, if you use the
> tap's for debugging purposes, I would suggest you build a message
> auditor that logs the messages somehow (whatever is done by your
> wiretaps right now). This way, if you do not need the logging, you
> simply disable the auditor in your ServiceMix configuration.
>
> This would also allow you to remove all debugging configuration from
> your SA, so it only contains real routing/service configuration. This
> improves the maintainability/readability of your configuration a lot
> (recently done that for one of my own projects, which also had wiretaps
> all over...)
>
>
> Gert
>
> Arif Mohd wrote:
>> Thank you gert,
>> 1) Iam able to call my rules now without any error.
>> 2) The example i was using is simply routing a message based on the
>> content of message, which can be easily done with Content Based Router
>> Now i want to do routing based on the source component of the message
>> from where the message is coming i.e, i want to remove the tap's(used for
>> debugging) at runtime using drools.
>>
>> My component setup is
>>
>> JMS queue(Consumer)-->eip:Tap1-->eip:Content Based
>> Router-->eip:Tap2--->eip:Transformer
>>
>> Now i want to enable/disable Tap1 and Tap2 during runtime by using
>> drools,
>> for that purpose i planned to have my component setup as follows
>>
>> JMS
>> queue(Consumer)-->SA(DroolsComponent)eip:Tap1-->SA(DroolsComponent)--->eip:Content
>> Based
>> Router-->SA(DroolsComponent)--->eip:Tap2--->SA(DroolsComponent)-->eip:Transformer
>>
>> the logic in rules files should be as follows
>>
>> if source component is JMS queue, route to Tap1
>> if source component is Tap1, route to Content based router
>> if source component is ContentBaseRouter, route to Tap2
>> if source component is Tap2, route to Transformer
>>
>>
>> How can i write this kind of rules,please help me in this regard.
>> Also let me know is it a feasible way of adding/removing components
>> logically?
>>
>>
>>
>>
>>
>>
>> Gert Vanthienen wrote:
>>
>>> Arif,
>>>
>>>
>>> You can find a description on how to form this kind of URIs on
>>> http://incubator.apache.org/servicemix/uris.html.
>>>
>>> If you think the URI is correct but still have these 'Cannot find route
>>> to ...' errors, you can use a JMX console to verify which endpoints are
>>> actually available on the ESB. I think your service URI contained the
>>> endpoint name, where it should only hold the service name.
>>>
>>>
>>> Gert
>>>
>>> Arif Mohd wrote:
>>>
>>>> Hi Rabi,
>>>>
>>>> I didn't understand this concept of giving service name as
>>>> "service:http://xxx.com/bescocr_031807/tap1"; but still it is not
>>>> working
>>>>
>>>> Can you please elobarate what is the meaning of the above statement,
>>>> i
>>>> agree that previously i have missed to preceede the service name with
>>>> namespace i.e, i should have given like
>>>>
>>>> jbi.route( "service:bescocr:tap1" );
>>>>
>>>> But even the above statement is not working
>>>>
>>>>
>>>> rabi wrote:
>>>>
>>>>> in your routing.drl replace
>>>>>
>>>>> jbi.route( "bescocr::tap1" ); with
>>>>>
>>>>> jbi.route("service:http://xxx.com/bescocr_031807
>>>>> <https://webmail.wipro.com/exchweb/bin/redir.asp?URL=http://xxx.com/bescocr_031807>
>>>>> /tap1");
>>>>>
>>>>> and jbi.route( "bescocr::tap2" ); with
>>>>>
>>>>> jbi.route("service:http://xxx.com/bescocr_031807
>>>>> <https://webmail.wipro.com/exchweb/bin/redir.asp?URL=http://xxx.com/bescocr_031807>
>>>>> /tap2");
>>>>>
>>>>> Regards,
>>>>> Rabi Mishra
>>>>> http://rabisblog.blogspot.com/
>>>>>
>>>>> ________________________________
>>>>>
>>>>> From: Arif Mohd [mailto:[EMAIL PROTECTED]
>>>>> Sent: Wed 6/20/2007 7:25 PM
>>>>> To: [email protected]
>>>>> Subject: Problem while invoking rule by using drools component
>>>>>
>>>>>
>>>>>
>>>>>
>>>>> Hi,
>>>>>
>>>>> Iam having the following setup
>>>>>
>>>>> JMS queue(Consumer)-->eip:Content Based
>>>>> Router-->SA(DroolsComponent)-->eip:TAP1 or eip:TAP2(Based on rule
>>>>> base)
>>>>>
>>>>> part of xbean.xml for "eip:Content Based Router" is
>>>>>
>>>>> <eip:routing-rule>
>>>>> <eip:predicate>
>>>>> <eip:xpath-predicate xpath="/Record/eid = 100"
>>>>> namespaceContext="#nsContext" />
>>>>> </eip:predicate>
>>>>> <eip:target>
>>>>> <eip:exchange-target service="bescocr:myDroolsService" />
>>>>> </eip:target>
>>>>> </eip:routing-rule>
>>>>>
>>>>> xbean.xml for DroolsComponent(SU) is
>>>>>
>>>>> <beans xmlns:drools="http://servicemix.apache.org/drools/1.0";
>>>>> xmlns:bescocr="http://xxx.com/bescocr_031807";>
>>>>> <drools:endpoint
>>>>> service="bescocr:myDroolsService"
>>>>> endpoint="endpoint"
>>>>> ruleBaseResource="classpath:routing.drl"/>
>>>>> </beans>
>>>>>
>>>>>
>>>>> routing.drl is
>>>>>
>>>>> package org.apache.servicemix.drools
>>>>> import org.apache.servicemix.drools.model.Exchange;
>>>>> global org.apache.servicemix.drools.model.JbiHelper jbi;
>>>>>
>>>>> rule "Route to tap1"
>>>>> when
>>>>> me : Exchange( status == Exchange.ACTIVE, in : in !=
>>>>> null
>>>>> )
>>>>> eval( in.xpath("/Record/eid = 100") )
>>>>> then
>>>>> jbi.route( "bescocr::tap1" );
>>>>> end
>>>>>
>>>>> rule "Route to tap2"
>>>>> when
>>>>> me : Exchange( status == Exchange.ACTIVE, in : in !=
>>>>> null
>>>>> )
>>>>> eval( in.xpath("/Record/eid = 101") )
>>>>> then
>>>>> jbi.route( "bescocr::tap2" );
>>>>> end
>>>>>
>>>>>
>>>>> with the above setup iam getting the following exception "for service:
>>>>> null
>>>>> and interface: null" the exception is as follows, do i need to set
>>>>> something
>>>>> else in xbean.xml?
>>>>>
>>>>> javax.jbi.messaging.MessagingException: Could not find route for
>>>>> exchange:
>>>>> InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-7:0
>>>>> status: Active
>>>>> role: provider
>>>>> in: <My Message>
>>>>> ] for service: null and interface: null
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.DefaultBroker.sendExchangePacket(DefaultBroker.java:295)
>>>>> at
>>>>> org.apache.servicemix.jbi.security.SecuredBroker.sendExchangePacket(SecuredBroker.java:80)
>>>>> at
>>>>> org.apache.servicemix.jbi.container.JBIContainer.sendExchange(JBIContainer.java:793)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:381)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.sendSync(DeliveryChannelImpl.java:456)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.sendSync(DeliveryChannelImpl.java:428)
>>>>> at
>>>>> org.apache.servicemix.common.EndpointDeliveryChannel.sendSync(EndpointDeliveryChannel.java:88)
>>>>> at
>>>>> org.apache.servicemix.drools.model.JbiHelper.route(JbiHelper.java:109)
>>>>> at
>>>>> org.apache.servicemix.drools.Rule_Route_to_tap1_0.consequence(Rule_Route_to_tap1_0.java:11)
>>>>> at
>>>>> org.apache.servicemix.drools.Rule_Route_to_tap1_0ConsequenceInvoker.evaluate(Rule_Route_to_tap1_0ConsequenceInvoker.ja
>>>>> va:19)
>>>>> at org.drools.common.DefaultAgenda.fireActivation(Unknown
>>>>> Source)
>>>>> at org.drools.common.DefaultAgenda.fireNextItem(Unknown
>>>>> Source)
>>>>> at
>>>>> org.drools.common.AbstractWorkingMemory.fireAllRules(Unknown
>>>>> Source)
>>>>> at
>>>>> org.drools.common.AbstractWorkingMemory.fireAllRules(Unknown
>>>>> Source)
>>>>> at
>>>>> org.apache.servicemix.drools.DroolsEndpoint.drools(DroolsEndpoint.java:150)
>>>>> at
>>>>> org.apache.servicemix.drools.DroolsEndpoint.process(DroolsEndpoint.java:141)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:489)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:441)
>>>>> at
>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:593)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:174)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:176)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690)
>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>> ERROR - DroolsComponent - Error processing exchange
>>>>> InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-3:2
>>>>> status: Active
>>>>> role: provider
>>>>> service: {http://xxx.com/bescocr_031807}myDroolsService
>>>>> endpoint: endpoint
>>>>> in: <My Message>
>>>>> ]
>>>>> org.drools.spi.ConsequenceException:
>>>>> javax.jbi.messaging.MessagingException:
>>>>> Could not find route for exchange: InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-7:0
>>>>> status: Active
>>>>> role: provider
>>>>> in: <My Message>
>>>>> ] for service: null and interface: null
>>>>> at org.drools.common.DefaultAgenda.fireActivation(Unknown
>>>>> Source)
>>>>> at org.drools.common.DefaultAgenda.fireNextItem(Unknown
>>>>> Source)
>>>>> at
>>>>> org.drools.common.AbstractWorkingMemory.fireAllRules(Unknown
>>>>> Source)
>>>>> at
>>>>> org.drools.common.AbstractWorkingMemory.fireAllRules(Unknown
>>>>> Source)
>>>>> at
>>>>> org.apache.servicemix.drools.DroolsEndpoint.drools(DroolsEndpoint.java:150)
>>>>> at
>>>>> org.apache.servicemix.drools.DroolsEndpoint.process(DroolsEndpoint.java:141)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:489)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:441)
>>>>> at
>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:593)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:174)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:176)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690)
>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>> Caused by: javax.jbi.messaging.MessagingException: Could not find
>>>>> route
>>>>> for
>>>>> exchange: InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-7:0
>>>>> status: Active
>>>>> role: provider
>>>>> in: <My Message>
>>>>> ] for service: null and interface: null
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.DefaultBroker.sendExchangePacket(DefaultBroker.java:295)
>>>>> at
>>>>> org.apache.servicemix.jbi.security.SecuredBroker.sendExchangePacket(SecuredBroker.java:80)
>>>>> at
>>>>> org.apache.servicemix.jbi.container.JBIContainer.sendExchange(JBIContainer.java:793)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:381)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.sendSync(DeliveryChannelImpl.java:456)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.sendSync(DeliveryChannelImpl.java:428)
>>>>> at
>>>>> org.apache.servicemix.common.EndpointDeliveryChannel.sendSync(EndpointDeliveryChannel.java:88)
>>>>> at
>>>>> org.apache.servicemix.drools.model.JbiHelper.route(JbiHelper.java:109)
>>>>> at
>>>>> org.apache.servicemix.drools.Rule_Route_to_tap1_0.consequence(Rule_Route_to_tap1_0.java:11)
>>>>> at
>>>>> org.apache.servicemix.drools.Rule_Route_to_tap1_0ConsequenceInvoker.evaluate(Rule_Route_to_tap1_0ConsequenceInvoker.ja
>>>>> va:19)
>>>>> ... 16 more
>>>>> ERROR - JmsComponent - Error processing exchange
>>>>> InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-4:0
>>>>> status: Error
>>>>> role: consumer
>>>>> service: {http://xxx.com/bescocr_031807}JmsToPipeTapSvc
>>>>> endpoint: tap
>>>>> in: <My Message>
>>>>> error: org.drools.spi.ConsequenceException:
>>>>> javax.jbi.messaging.MessagingException: Could not find route for
>>>>> exchange:
>>>>> InOnly[
>>>>> id: ID:EC4T16INT165110-4730-1182344415869-7:0
>>>>> status: Active
>>>>> role: provider
>>>>> in: <My Message>
>>>>> ] for service: null and interface: null
>>>>> ]
>>>>> java.lang.UnsupportedOperationException: A destination must be
>>>>> specified.
>>>>> at
>>>>> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:448)
>>>>> at
>>>>> org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:75)
>>>>> at
>>>>> org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:60)
>>>>> at
>>>>> org.apache.servicemix.jms.multiplexing.MultiplexingConsumerProcessor.process(MultiplexingConsumerProcessor.java:125)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:489)
>>>>> at
>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:463)
>>>>> at
>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:593)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:174)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:176)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690)
>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>> ERROR - JmsComponent - Error setting exchange status
>>>>> to
>>>>> ERROR
>>>>> javax.jbi.messaging.MessagingException: illegal call to send /
>>>>> sendSync
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.MessageExchangeImpl.handleSend(MessageExchangeImpl.java:571)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:370)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:417)
>>>>> at
>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:58)
>>>>> at
>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:593)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:174)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:176)
>>>>> at
>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:665)
>>>>> at
>>>>> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:690)
>>>>> at java.lang.Thread.run(Thread.java:595)
>>>>>
>>>>>
>>>>>
>>>>>
>>>>> --
>>>>> View this message in context:
>>>>> http://www.nabble.com/Problem-while-invoking-rule-by-using-drools-component-tf3952519s12049.html#a11213830
>>>>> Sent from the ServiceMix - User mailing list archive at Nabble.com.
>>>>>
>>>>>
>>>>>
>>>>>
>>>>>
>>>>>
>>>>> The information contained in this electronic message and any
>>>>> attachments
>>>>> to this message are intended for the exclusive use of the addressee(s)
>>>>> and
>>>>> may contain proprietary, confidential or privileged information. If
>>>>> you
>>>>> are not the intended recipient, you should not disseminate, distribute
>>>>> or
>>>>> copy this e-mail. Please notify the sender immediately and destroy all
>>>>> copies of this message and any attachments.
>>>>>
>>>>> WARNING: Computer viruses can be transmitted via email. The recipient
>>>>> should check this email and any attachments for the presence of
>>>>> viruses.
>>>>> The company accepts no liability for any damage caused by any virus
>>>>> transmitted by this email.
>>>>>
>>>>> www.wipro.com
>>>>>
>>>>>
>>>
>>
>>
>
>
>
--
View this message in context:
http://www.nabble.com/Problem-while-invoking-rule-by-using-drools-component-tf3952519s12049.html#a11534408
Sent from the ServiceMix - User mailing list archive at Nabble.com.
