i have added this configuration to conf/servicemix.xml
Gert Vanthienen wrote:
>
> Arif,
>
> Have you added this configuration to conf/servicemix.xml or have you built
> a servicemix-lwcontainer SU to hold you service?
>
> Have you activated the endpoint? Something like:
> public void init(ComponentContext context) throws JBIException {
> this.context = context;
> context.activateEndpoint(new QName("http://your.namespace";,
> "service"),
> "endpoint");
> }
>
> Gert
>
>
> 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#a10963721
Sent from the ServiceMix - User mailing list archive at Nabble.com.
