My configuration is very simple just iam trying to inject one pojo class
Configuaration for tap is
<eip:wire-tap service="bescocr:PipetoJmsTapSvc" endpoint="endpoint">
<eip:target>
<eip:exchange-target service="foo:BESMessageInterceptor" />
</eip:target>
<eip:inListener>
<eip:exchange-target service="bescocr:JmsTapQ4" />
</eip:inListener>
</eip:wire-tap>
JMS Topic configuration is
<jms:endpoint service="bescocr:JMSConsumer"
endpoint="jms"
role="provider"
destinationStyle="queue"
jmsProviderDestinationName="PHB800"
connectionFactory="#jmsFactory"
defaultMep="http://www.w3.org/2004/08/wsdl/in-only";
/>
<bean id="jmsFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
</property>
</bean>
Arif Mohd wrote:
>
> Hi,
>
> Iam using servicemix3.1 my components configuration is as follows.
>
> wire tap --> POJO class ---> JMS Topic
>
> I have configured POJO class as follows in servicemix.xml
>
> <sm:activationSpecs>
> <sm:activationSpec id="BESMessageInterceptor"
> service="foo:BESMessageInterceptor"
> destinationService="bescocr:JMSConsumer">
> <sm:component><bean
> class="com.e2e.bes.processor.MessageInterceptor"/></sm:component>
> </sm:activationSpec>
> </sm:activationSpecs>
>
>
> And my pojo class method is
>
> public void onMessageExchange(MessageExchange exchange) throws
> MessagingException {
> log.info("Received message " + exchange);
> NormalizedMessage message = exchange.getMessage("in");
> System.out.println("_______________hai__________");
> getMessageList().addMessage(message);
> exchange.setStatus(ExchangeStatus.DONE);
> context.getDeliveryChannel().send(exchange);
> }
>
>
> when i start my servicemix pojo class gets deployed the following output
> depicts that
>
>
> INFO - JBIContainer - Activating component for:
> [container=ServiceMix,name=BESMessageInterceptor] with service
> : BESMessageInterceptor component:
> org.apache.servicemix.components.util.ComponentAdaptorMEListener for
> com.e2e.bes.process
> [EMAIL PROTECTED]
> INFO - ComponentMBeanImpl - Initializing component:
> BESMessageInterceptor
> INFO - ComponentMBeanImpl - Setting running state for
> Component: servicemix-bpe to Started
>
> But when i send a message to wire tap iam getting the following exception
>
>
>
> WARN - DefaultBroker - ServiceName
> (BESMessageInterceptor) specified for routing, but can't find it
> registered
> WARN - DefaultBroker - ServiceName
> (BESMessageInterceptor) specified for routing, but can't find it
> registered
> ERROR - EIPComponent - Error processing exchange InOnly[
> id: ID:EC4T16INT165110-2355-1180969168607-5:38
> status: Active
> role: provider
> service: {http://xxx.com/bescocr_031807}PipetoJmsTapSvc
> endpoint: endpoint
> in: <?xml version="1.0" encoding="UTF-8"?>
> <Actual message which i got in tap>]
> javax.jbi.messaging.MessagingException: Could not find route for exchange:
> InOnly[
> id: ID:EC4T16INT165110-2355-1180969168607-5:40
> status: Active
> role: provider
> service: BESMessageInterceptor
> in: <?xml version="1.0" encoding="UTF-8"?>
>
> <Actual message which i got in tap>] for service: BESMessageInterceptor
> 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.send(DeliveryChannelImpl.java:417)
> at
> org.apache.servicemix.common.AsyncBaseLifeCycle.sendConsumerExchange(AsyncBaseLifeCycle.java:546)
> at
> org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:77)
> at
> org.apache.servicemix.common.endpoints.SimpleEndpoint.send(SimpleEndpoint.java:67)
> at
> org.apache.servicemix.eip.patterns.WireTap.sendToListenerAndTarget(WireTap.java:258)
> at
> org.apache.servicemix.eip.patterns.WireTap.processAsync(WireTap.java:204)
> at
> org.apache.servicemix.eip.EIPEndpoint.process(EIPEndpoint.java:160)
> 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)
>
--
View this message in context:
http://www.nabble.com/Not-able-to-call-POJO-class-tf3865883s12049.html#a10963364
Sent from the ServiceMix - User mailing list archive at Nabble.com.
