-
How to get a specific message body from a queue using a unique ID
I want to know the best way to get the message Body of a specific message instance in a queue. The method I use is the following: My software is calling the SEMP API to get a list of messages metadata like this: {{solace-admin-url}}/SEMP/v2/monitor/msgVpns/my-vpn-name/queues/myqueuename/msgs and the json response looks…
-
How to enable TLS connection in spring boot?
Hello everyone, I have successfully integrated queue communication in solace with spring boot but I'm facing an issue. I want to make it such that any client without a valid certificate (jks) is not allowed to connect even if the credentials are valid. It seems that the default settings allow anyone with credentials to…
-
Error sending message - Direct buffer memory
Hello We are using ( Solace + Spring JMS + Spring Boot + Pivotal Cloud Foundry ) to read a message from a queue and post to Topic. We are facing issue when reading 1 message of size - 7MB and posting to a topic. Smaller message size are working fine. Below error when sending to topic Error Message : javax.jms.JMSException:…
-
Regarding Connectivity status, Session status and Consumer status
We are a consumer of couple of Solace queues. We are consuming messages from (1) Kafka Connect framework using Solace PubSub Plus Source Connector, (2) Custom developed Spring Boot Application using Solace JMS API. Case #1: issues with Solace PubSub Plus Source Connector Sometimes we found that the connector is not listed…
-
JMS 2.0 support on sol-jms
Spring Boot 3+ is using JMS 2.0 and packages jakarta.jms.* instead of javax.jms.* (check for example: Thus solace spring boot starters cannot be used with spring boot 3 applications. https://github.com/SolaceProducts/solace-spring-boot/pull/60 Are there any plans to mitigate this obstacle ? Or any way to fix it ?
-
How to disable the automatic queue creation with amqp qpid jms client
Hello everyone, I am following the tutorial provided here: GitHub - SolaceSamples/solace-samples-amqp-qpid-jms1: Getting Started tutorials for using Apache Qpid JMS 1.1 over AMQP 1.0 with Solace Message Routers. I want to create a consumer on my queue which receives messages. This does work, however everytime the client…
-
How Oauth can be used with Apache Qpid JMS 2.0 AMQP
Hi All, I am using Apache Qpid JMS 2.0 to connect standalone PS+ broker on 5671 port. I am able to achieve using username and password however I am not able to authenticate using Oauth. Our other clients written in nodejs are able to authenticate and connect on 5671 with AMQP protocol and Oauth. As per doc I am providing…
-
Now available: v1.1 of the PubSub+ Connector for IBM MQ
Hello all connector enthusiasts! Version 1.1 of the Self-contained Connector: PubSub+ Connector for IBM MQ is now available. This release contains a number of new features and enhancements since the 1.0 release in Dec. 2022. These include: Support for durable topic subscriptions in the JMS/MQ input binding/consumer of a…
-
Interceptors with Solace JMS
I just wanted to highlight a new feature that was added to Solace JMS v10.14.0. The API now allows for "pre-send" and "pre-receive" interceptors (AKA hooks). This allows a developer to implement common logic in one place and add it into the sending/receiving of multiple apps. A common use case for this would be for logging…
-
JMS Queue Browsing (Received incoming message with no active flow)
I am developing a Spring Boot Application (version 2.7.5). Currently, I'm trying to create a queue broswer using the following code: public int getMessageCount() { return jmsTemplate.browse(fromQueueName, new BrowserCallback<Integer>() { @Override public Integer doInJms(Session s, QueueBrowser qb) throws JMSException {…
-
Applying ACL profile on Queue Subscription!
Hi There! i have a scenario to apply ACL policy for a JMS Subscriber, i would want them to subscribe only from specific Queue. Is there any possibility of achieving this with PubSub+ Broker? Currently i can see i can give exemptions on Topic in ACL profile but not Queues
-
Connectivity Issue from TIBCO BW
Hi All, Getting below error while connecting from TIBCO BW5.x to Solace, we have increased consumer limit also but no use, could you please help. com.solacesystem.jscmp.JSEMPErrorResponseException: 503 Max Router Publishing Flow Exceeded Thanks
-
Error registering listner:Transactions not supported [condition = amqp:not-implemented]
Hello, I am trying to register listeners dynamically to the queues whose names can be fetched at runtime. I am using the JmsListenerEndpointRegistrar from spring for dynamic listener registration. My application is started, and connection to solace broker gets established but the listener invocation fails with the…
-
Springboot Solace JMS Autoconfig with Client Authentication
I am using SpringBoot Solace JMS AutoConfig to listen and produce message for solace queue. I am currently using Basic authentication. Now, I am trying to use Client Authentication using truststore and key store. How do I connect to Solace using JMS AutoConfig?
-
download JMS API on ec2 instance
Hi Team, How to download JMS API on ec2 instance. I have follow https://solace.com/blog/integrating-solace-with-logstash/ example for the same way I tried to download the JMS API. But when I am trying to unzip it getting below message. please suggest. unzip soljsm.zip Archive: soljsm.zip End-of-central-directory signature…
-
NonDurable TopicEndpoint Creation with Connection Factory for JMS API
Hi All, JMS Connection Factories can be created for each msg-VPN in Solace. This can be used to maintain/configure JMS connection properties administratively instead of API code. JMS applications can listen to Solace topic directly for both guaranteed and for non-guaranteed message delivery. When a JMS connection subscribe…
-
Solace consumers and producers connecting with diferent protocol
We have multiple microservices connecting to Solace for different message publish and subscribe requirements. There are some java runtime-based microservices connecting using JMS APIs (using sol-jms library or apache qpid JMS 2.0 library), whereas there are golang and nodejs based runtimes connecting to solace based on…
-
jmsListener selector mechanism for new solace bee's :)
while consuming solace messages with selector functionality from message header property, do not include any special characters in header key.. if in case if you are adding key with special character you may able to successfully send messages but while retrieving from queue/topic using jmsListener you may end-up with…
-
Non-Exclusive Queue using AMQP
Hi, can it be possible to create non-exclusive queue using amqp in solace ? I am exploring Apache Qpid JMS 2.0 over AMQP 1.0 I checked solace-samples-amqp-qpid-jms2/QueueConsumer.java at master · SolaceSamples/solace-samples-amqp-qpid-jms2 (github.com) and it creates an exclusive queue and connects the consumer to the…
-
Setting up standards for publishers using JMS
We are using Solace Cloud PubSub+ and trying to standardize JMS properties for Publishers using the Solace API for JMS. So, some of the recommendations to developers would be like setting these. * DMQ always set to true * JMSMessageID * JMSTimestamp Can these set by default when not supplied by the publishers ?
-
Solace JmsListener Message conversion Exception
The original message is Text Message only, it was working previously recently ran into this issue. org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method could not be invoked with incoming message 2022-01-04T12:16:54.220+05:30 [APP/PROC/WEB/0] [OUT] Endpoint handler details:…
-
Jms Message Id - default set unique id e. g. GUID if not set by publisher
I found that by default use of solace no message id is set when using jms client. As that field is best to corelate an error on subscriber with message parked in DMQ or perform de-duplication, i wonder if there is a. config in solacd to auto. fill when publisher does not set the ApplicationMessageId which normally turns…
-
Can you set compression port on JMS client?
When connecting to Solace via JMS JNDI LookUp with compression the lookup occurs over 55555 but the connection then connects of 55003. I have a network configuration where we port translate to multiple solace instances and trying to figure out how to map different servers to different ports but I can't seem to figure out…
-
JMS Message Handling Scenarios
I am coming through the Solace docs trying to figure out the differences between various JMS pub/sub configurations and how the message and acks would be handled. Here are my scenarios. What I am trying to identify is when an ack is sent, when a message is spooled to disk vs retained in memory, and when/how a message may…
-
How to send NACK(Negative Acknowledgement) using java API
Hi Team, Need your help to find the solution. Current Implementation details, SolConnectionFactory connectionFactory = SolJmsUtility.createConnectionFactory(); --> for create connection factory using host , vpn,trust store,keystore with auth scheme AUTHENTICATION_SCHEME_CLIENT_CERTIFICATE this.connection =…
-
"Guaranteed Message Publish Window Size" with (Solace) JMS
Hi there In one of our applications we use the com.solacesystems.sol-jms (version 10.6.4). I want to configure publishing as described in https://solace.com/blog/understanding-guaranteed-message-publish-window-sizes-and-acknowledgement/ I found this:…
-
Solace Spring JMSListner
Team, I am new to the Solace and i am currently using in the Solace SpringBoot JMS. I have created a Queue and Published 500 Message to it. I want to implement a Multithreading behavior to my consumer which will consume the message parallelly and process instead of one by one. I have added the minimum concurrency as 5 and…
-
webmethods JMS - Solace Integration
This document give basic Integration steps on Integrating webmethods with Solace Event broker for Pub-sub
-
Dynamic Queues
Hi All, How to disable dynamic Queue creation feature in Solace
-
About changing sol-jms version in solace-jms-spring-boot-starter 4.1.0
Hello, Due to some reasons, I need to use sol-jms 10.11. However, I want to use solace-jms-spring-boot-starter for my project but the latest version of the starter (4.1.0) is using sol-jms 10.8.1. I want to change the sol-jms version by: <dependency> <groupId>com.solace.spring.boot</groupId>…
