Solace Community is getting a facelift!
On March 3rd we will be starting the process of migrating Solace Community to a new platform. As a result, Solace Community will go in to a temporary read-only state. You will still be able to come onto Solace Community and search through posts to find answers, but you won't be able to ask questions, post comments, or react in any way.
We hope to have the migration complete by Wednesday March 5th (or sooner), so please keep an eye out!
Apache Camel with Solace on Docker
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 ?
Comments
Categories
