Apache Camel with Solace on Docker

krishnendra

I am trying to configure Apache Camel Route
I configure a Spring bean

Bean("solace")
public JmsComponent getSolaceJmsComponent(){
SolConnectionFactory solConnectionFactory = null;
try{
solConnectionFactory = SolJmsUtility.createConnectionFactory(host,username,password,vpn,new Hashtable<>(1));
}catch(Exception e){
logger.info("Exception in creating connection:{}",e);
}
solConnectionFactory.setDirectTransport(false);
JmsConfiguration jmsConfiguration = new JmsConfiguration(solConnectionFactory);
JmsComponent jmsComponent = new JmsComponent(jmsConfiguration);
return jmsComponent;
}

Route is

from("solace:queue:")
.process((exchange -> {
System.out.println(exchange.getIn().getBody().toString());
})).to("log:foo");

When i connect i get this message

2020-02-08 20:00:38.355 INFO 21632 --- [ main] c.s.b.CamelSpringBootApplicationListener : Starting CamelMainRunController to ensure the main thread keeps running
2020-02-08 20:00:38.449 INFO 21632 --- [ main] c.s.j.protocol.impl.TcpClientChannel : Connecting to host 'orig=tcp://localhost:55555, scheme=tcp://, host=localhost, port=55555' (host 1 of 1, smfclient 2, attempt 1 of 1, this_host_attempt: 1 of 1)
2020-02-08 20:00:38.470 INFO 21632 --- [ main] c.s.j.protocol.impl.TcpClientChannel : Connected to host 'orig=tcp://localhost:55555, scheme=tcp://, host=localhost, port=55555' (smfclient 2)
2020-02-08 20:00:38.475 INFO 21632 --- [ main] o.a.c.s.boot.SpringBootCamelContext : Route: route1 started and consuming from: solace://queue:XXXXXX
2020-02-08 20:00:38.481 INFO 21632 --- [ main] o.a.c.s.boot.SpringBootCamelContext : Total 1 routes, of which 1 are started
2020-02-08 20:00:38.486 INFO 21632 --- [ main] o.a.c.s.boot.SpringBootCamelContext : Apache Camel 3.0.1 (CamelContext: camel-1) started in 0.504 seconds
2020-02-08 20:00:38.490 INFO 21632 --- [ main] org.example.Application : Started Application in 2.349 seconds (JVM running for 2.932)
2020-02-08 20:00:38.502 INFO 21632 --- [2_ReactorThread] c.s.jcsmp.impl.flow.BindRequestTask : Error Response (503) - Queue Shutdown
2020-02-08 20:00:43.506 WARN 21632 --- [mer[]] c.c.j.DefaultJmsMessageListenerContainer : Setup of JMS message listener invoker failed for destination '' - trying to recover. Cause: Error creating consumer - shutdown endpoint (503: Queue Shutdown)
2020-02-08 20:00:43.510 INFO 21632 --- [mer[]] c.s.j.protocol.impl.TcpClientChannel : Channel Closed (smfclient 2)
2020-02-08 20:00:43.521 INFO 21632 --- [mer[]] c.s.j.protocol.impl.TcpClientChannel : Connecting to host 'orig=tcp://localhost:55555, scheme=tcp://, host=localhost, port=55555' (host 1 of 1, smfclient 4, attempt 1 of 1, this_host_attempt: 1 of 1)
2020-02-08 20:00:43.537 INFO 21632 --- [mer[]] c.s.j.protocol.impl.TcpClientChannel : Connected to host 'orig=tcp://localhost:55555, scheme=tcp://, host=localhost, port=55555' (smfclient 4)
2020-02-08 20:00:43.544 INFO 21632 --- [3_ReactorThread] c.s.jcsmp.impl.flow.BindRequestTask : Error Response (503) - Queue Shutdown

Can someone point me to the error ?

rdesoju

It appears that Queue is created but it is "shutdown". You need to figure out a way to do "no shutdown" on it.