scalability with A MQ Xpaas component in openshift

[Meissa Sakho]

Hi all,
I'm using the A MQ Xpass component that is shipped with openshift 3.1

I've defined a multiple A-MQ pod with a broker running on each pod to
achieve scalability.
On the client side, I need to instruct to the consumer and provider the way
to access the service.
I'm not very sure about the protocole to use to send and receive messages.
here is the source code (extract) of my camel route:



@ContextName("myCdiCamelContext")

public class MyRoutes extends RouteBuilder {



    @Inject

    *@ServiceName("failover://broker-amq-tcp?randomize=false")*

    @Alias("jms")

    ActiveMQComponent activeMQComponent;



    @Inject

    @Uri("jms:queue:TEST.FOO")

    Endpoint jmsEndpoint;



    @Inject

    @Uri("direct:hello")

    Endpoint helloEndpoint;



    @Inject

    @Uri("direct:bye")

    Endpoint byeEndpoint;



    @Inject

    @Uri("log:output")

    Endpoint finalEndpoint;



    @Inject

    private DOICLogger myLogger;



    @Override

    public void configure() throws Exception {







        restConfiguration().component("jetty").host("0.0.0.0").port(8080);




rest("rest/say").get("/hello/{name}").route().id("1").to(helloEndpoint);

        rest("rest/say").get("/bye/{name}").route().id("2").to(byeEndpoint);



        from(helloEndpoint).id("3").transform().simple("Hello ${header.name
}").to(jmsEndpoint);

        from(byeEndpoint).id("4").transform().simple("Bye ${header.name
}").to(jmsEndpoint);





        from(jmsEndpoint).id("5").to(finalEndpoint);

    }

}





When I deploy my route on openshift, I'm having the exception below:

org.apache.camel.ExchangeTimedOutException: The OUT message was not
received within: 20000 millis due reply message with correlationID:
Camel-ID-app-amq-3-4r37y-34752-1460564678101-0-15 not received on
destination: temp-queue://ID:app-amq-3-4r37y-40118-1460564679395-1:2:1.
Exchange[Message: Hello Bonjour]

        at
org.apache.camel.component.jms.reply.ReplyManagerSupport.processReply(ReplyManagerSupport.java:152)

        at
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler.onTimeout(TemporaryQueueReplyHandler.java:61)

        at
org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:54)



Do you have any idea about what's wrong here.

thanks in advance,

Meissa

Thanks,

Meissa