Jms consumer not consuming a message from Topic

[pratibhaG]

Hi all,

I have an example which was working in smx3.3.1. the example use to put a
message in jms topic and the consumer use to consume it. To fix some other
problem I replaced my servicemix-camel-2009.01-installer.zip component with
servicemix-camel-2009.02-installer.zip. now with this change my jms consumer
is not picking up the message in topic.

the jms configuration like this:


<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:jms="http://servicemix.apache.org/jms/1.0";
       xmlns:up="http://servicemix.in2m.com/operations/updateprofile";
       xmlns:amq="http://activemq.org/config/1.0";>

    <jms:consumer service="up:DirectorConsumerService"
                  endpoint="directorConsumerEndpoint"
                                  targetService="up:DirectorConsumerService"
                                  clientId="Director"
                                  pubSubDomain="true"
                                  subscriptionDurable="true"
                  destinationName="updateUserProfileTopic"
                  connectionFactory="#connectionFactory" 
                                  messageSelector="userPrincipals NOT LIKE 
'%director%'"
                                  cacheLevel="2"
                                  transacted="jms"/>
        
        <jms:consumer service="up:PortalConsumerService"
                  endpoint="portalConsumerEndpoint"
                                  targetService="up:PortalConsumerService"
                                  pubSubDomain="true"
                                  clientId="Portal"
                                  subscriptionDurable="true"
                  destinationName="updateUserProfileTopic"
                                  connectionFactory="#connectionFactory" 
                                  messageSelector="userPrincipals NOT LIKE 
'%portal%'"
                                  cacheLevel="2"
                                  transacted="jms"/>
        
  <bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
      <property name="location" value="classpath:servicemix.properties" />
  </bean>
        
   <amq:connectionFactory id="connectionFactory" brokerURL="${activemq.url}"
/>

</beans>




and :


<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:jms="http://servicemix.apache.org/jms/1.0";
       xmlns:up="http://servicemix.in2m.com/operations/updateprofile";
       xmlns:amq="http://activemq.org/config/1.0";>

        <jms:provider service="up:JMSProviderService"
                  endpoint="JMSProviderEndpoint"
                                  pubSubDomain="true"
                  destinationName="updateUserProfileTopic"
                  connectionFactory="#connectionFactory"
                                  marshaler="#jmsMarshaler"/>

        <bean id="jmsMarshaler"
class="com.in2m.servicemix.common.marshaller.jms.DefaultJmsProviderMarshaler"/>
        
    <bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
      <property name="location" value="classpath:servicemix.properties" />
    </bean>
        
   <amq:connectionFactory id="connectionFactory" brokerURL="${activemq.url}"
/>

</beans>


The camel configuration is like this:
package com.in2m.servicemix.operations.updateprofile;

import org.apache.camel.builder.RouteBuilder;

import com.in2m.servicemix.common.errorhandling.CustomDelegateProcessor;
import com.in2m.servicemix.common.errorhandling.ErrorConstants;


public class MessageRouting extends RouteBuilder {

    public void configure() {
        
        
        
        //errorHandler(deadLetterChannel().maximumRedeliveryDelay(3600000L));
        
        onException(java.lang.Throwable.class)
        .process(new CustomDelegateProcessor(ErrorConstants.SYSTEM_ERROR));     
           
       
        onException(java.net.SocketException.class)
        .maximumRedeliveries(5)
        .useExponentialBackOff()
        .redeliveryDelay(300000L)
        .backOffMultiplier(2.0)
        .maximumRedeliveryDelay(3600000L)
        .process(new CustomDelegateProcessor(ErrorConstants.SOCKET_ERROR));
            
       
from("jbi:service:http://servicemix.in2m.com/operations/updateprofile/RoutingService";)
       
.to("jbi:service:http://servicemix.in2m.com/operations/updateprofile/JMSProviderService?mep=in-only";)
       
.to("jbi:service:http://servicemix.in2m.com/operations/updateprofile/ResponseGeneratorService?mep=in-out";);
       
       
from("jbi:service:http://servicemix.in2m.com/operations/updateprofile/DirectorConsumerService";)
       
.setHeader(ErrorConstants.APPLICATION_NAME,constant("DirectorService"))
        .process(new CustomDelegateProcessor())         
       
.to("jbi:service:http://servicemix.in2m.com/operations/updateprofile/DirectorService?mep=in-out";);
       
       
from("jbi:service:http://servicemix.in2m.com/operations/updateprofile/PortalConsumerService";)
       
.setHeader(ErrorConstants.APPLICATION_NAME,constant("PortalService"))
        .process(new CustomDelegateProcessor())     
       
.to("jbi:service:http://servicemix.in2m.com/operations/updateprofile/PortalService?mep=in-out";);
    }
}


Please provide some help

Thanks,
Pratibha

-- 
View this message in context: 
http://old.nabble.com/Jms-consumer-not-consuming-a-message-from-Topic-tp27983805p27983805.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.