Hi @marc.dipasquale , I followed your tutorial in this thread, how to listen to Solace Topic via JMS. I tried to configure it in my program as well, but I got an error of : unknown endpoint (503: Unknown Queue). I just started learning Solace, can you help me find the issue ? Think you~ This is my JMS configurations:
@Bean("connectionFactory")
public ConnectionFactory connectionFactory() throws Exception {
Properties env = new Properties();
env.put(InitialContext.INITIAL_CONTEXT_FACTORY, "com.solacesystems.jndi.SolJNDIInitialContextFactory");
env.put(InitialContext.PROVIDER_URL, solaceProperties.getBrokerUrl());
env.put(SupportedProperty.SOLACE_JMS_VPN, solaceProperties.getVpn());
env.put(InitialContext.SECURITY_PRINCIPAL, solaceProperties.getUsername());
env.put(InitialContext.SECURITY_CREDENTIALS, solaceProperties.getPassword());
SolConnectionFactory solConnectionFactory = SolJmsUtility.createConnectionFactory(env);
return solConnectionFactory;
}
****
@JmsListener(destination = "TestTopic01")
void receiveMsgFromTopic(Message msg) {
log.info("received Solace Topic message>>>>>>>>>>");
StringBuffer msgAsStr = new StringBuffer("============= Received \nHeaders:");
MessageHeaders hdrs = msg.getHeaders();
msgAsStr.append("\nUUID: " + hdrs.getId());
msgAsStr.append("\nTimestamp: " + hdrs.getTimestamp());
Iterator<String> keyIter = hdrs.keySet().iterator();
while (keyIter.hasNext()) {
String key = keyIter.next();
msgAsStr.append("\n" + key + ": " + hdrs.get(key));
}
msgAsStr.append("\nPayload: " + msg.getPayload());
log.info(msgAsStr.toString());
}
I have configured “spring.jms.pub-sub-domain=true” in my application.properties file.
But my program reports an error : Unknown Queue
