-
Synchronous call with solace new java api
Hi, currently, I'm using new Java Api so I'm using the below snippet for request-reply. -------- Request --------- RequestReplyMessagePublisher publisher = messagingService .requestReply() .createRequestReplyMessagePublisherBuilder() .build().start(); InboundMessage inboundMessage =…
-
Will JCSMPInboundChannelAdapter have configurable shutdownInterruptThresholdInMillis?
Hello, we are experiencing an issue with graceful shutdown of an application. We are using spring cloud "com.solace.spring.cloud:spring-cloud-starter-stream-solace:4.1.0" There is no awaiting for the termination and messages finish in the error queue. Is there a better way to gracefully stop and resume? Will configuring…
-
SolConnectionFactory stuck on javax
Hi, I'm trying to migrate my project from Java 11 to Java 17 while also updating to Spring Boot 3. The depencies I use for this solace-jms-spring-boot starter and autoconfigure, both on v 4.3.0. My problem is that the DefaultJmsListenerContainerFactory requires a ConnectionFactory that extends Jakarta ConnectionFactory,…
-
Facing "com.solacesystems.jms.ConfigurationException: Unable to load trust store" in OCP4.x (K8s)
Hi Team I have developed a spring boot application which reads message from solace queue and store it to a DB. My app works fine in local IDE, physical linux VMs and even in testbox podman containers. However, below exception occurs when I try to deploy the same in OpenShift container platform (4.x). I load the solace…
-
Connecting ActiveMQ Artemis to Solace Message Broker
Does Solace provide some kind of connector to read (subscribe) the (AMQP) messages from a ActiveMQ Artemis and publish them to Solace broker? And, subscribe message from solace message broker and publish to ActiveMQ Artemis?
-
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 make Queue browser to stop listening when no more message are in queue?
Context: I am using the Java API for browsing messages. I have my code looking like this: MessagingService messagingService = createMessagingService(clientUser, clientPass); Queue queue = Queue.durableExclusiveQueue(queueToBrowse); MessageQueueBrowser browser; if (selector == null || selector.isEmpty()) { browser =…
-
use Spring Cloud Stream to connect to solace occurs ConnectException.
use the spring Cloud Stream solace to connect to solace in my project, and enabled SSL_VALIDATE_CERTIFICATE. when the component spring-cloud-starter-stream-solace version is 3.3.2,can connect to solace success and worked properly. After i upgrade the version to the earliest version 4.1.0, it occurs exception. the exception…
-
Solace IBM MQ Connector -Why outgoing message to IBM MQ has expiry time instead of -1 [Non Expiring]
Hi Solace community, I am using solace IBM MQ connector to send solace message to MQ client as well as consuming message send from MQ client to solace. I have an issue where outgoing MQ message header to MQ contains expiry value set to something that is not -1 [Non Expiring]. Is this a bug? Or is there a way to override…
-
Solace Prometheus exporter build docker image failure
Can you please reopen this case as we are doing a configuration of solace prometheus exporter and its failing while building the docker image? Please is the highlighted error. Although we are able to pull the image manually. Sending build context to Docker daemon 2.846MB Step 1/19 : FROM…
-
Solace IBM MQ Connector - Can MQ Message Header expiry be set to 'Non Expiring'?
Hi Solace community, I came across an issue with Solace IBM MQ Connector. The connector is working that I am able to send solace → MQ and MQ to solace but noticed an issue when examining the MQ Message. In The MQ Message Header, I saw Expiry wasn't set to -1[Non Expiring]' and has a preset value set to something close to…
-
K8s industrial environment
Hi guys, im the new guy, with a lot of questions - hopefully you can help me :-) I want to check if the solace broker is a good solution for our industrial k8s environments. (1) Im wondering because i cant find any helm charts for a production deployment, how do you guys operate your broker in a ha environment? I found the…
-
Solace IBM MQ Connector - How to enable queue to be subscribed to topic?
Hi Solace community. Could someone help me understand below warning from solace ibm mq connector? I have a solace queue setup with a topic subscription but when I run solace ibm mq connector, everything works fine to consume message off topic but message is not removed from queue's message queue for some reason. In solace…
-
Proxy Solace Connection with Javascript
I am using the solclientjs https://www.npmjs.com/package/solclientjs and need to use a proxy. Is this possible? I tried the settings from https://docs.solace.com/API/API-Developer-Guide/Session-Props-Required.htm#Creating_ent_sessions_sess_props_host_proxies but could not get a connection. Which library is solclientjs…
-
How to stop Default solace queue name getting created
Java 17, Spring boot - 3.0.13 and spring-cloud-starter-stream-solace:4.0.0 Our bindings are like below: #Cloud stream channels configuration spring: cloud: function: routing: enabled routing-expression: headers['type'] definition: routerFunc1;routerFunc2 stream: default-binder: solace-broker bindings: routerFunc1-in-0:…
-
Solace PubSub+ IBM MQ Connector to send from solace through jms with non jms consumer
Hi, I am using Solace PubSub+ IBM MQ Connector to send from solace through jms with non jms consumer. I encounter a problem where the non-jms consumer doesn't understand MQHRF2 format. Is there a way to configure ibm mq connector to send it as MQSTR so the MQHRF2 header is not included?
-
How do I configure solace mq connector to set mq message format to MQSTR?
It looks like default mq message format is MQHRF2. How do I configure solace mq connector to set mq message format to MQSTR?
-
Mule Solace PubSub+ connector best way to mimic SOLACE:CONNECTIVITY error in MUnit
Hey all, I'm wondering if anyone has any knowledge of the best way to throw the specific Solace errors that will set the error context properly as if the application was running. We are using the PubSub+ connector within a MuleSoft application that is running on Mule 4.4.0 and MUnit tools and runner version of 3.0.0.…
-
How to consume messages synchronously from a solace "Queue" via Spring boot application?
Hi Team I am trying to develop an application where we connect to a Queue ( which is subscribing to multiple topics) and read message synchronously and make sure the next message is consumed only after current message is acknowledged. I tried reading resources provided by solace documentation and found snippet available…
-
in spring cloud stream 3.2.3, how to Manually Handle Null Payload manually
preSend or extending AbstractMessageHandler did not work, And @StreamListener annotation is deprecated How to handle it, without changing any versions
-
Connection to SAP S4 HANA Cloud
Hi, Is it possible to connect Solace PubSub+ to SAP S4 HANA cloud.If yes, could anyone help me on how to do that. Regards, Keerthana
-
Does Solace support any kind of Connector from/to MSMQ ?
We currently want to integrate a .net based solution and i wanted to know if any connectors exists from/to Solace from/to MSMQ ? Or is only option to use the .net API and receive messages to forward into MSMQ ? (message bridge)
-
Support for Priority ?
We are currently looking into a multi tenant integration (up to 800 tenants). If we would create 1 queue per event type we would get 20+ Event Types * 800 Unit = 16000 Queues!!!! So alternative would be to have 1 queue per Unit but in this queue different message events will arrive and some are more important and some…
-
what changes are required on Solace VPN to connect to Kafka Connector.
From a solace admins end what are changes i need to make to my VPN, so the Kafka connectors can connect easily.
-
How to keep the queue consumer flow open?
Hi everyone, I have actually a bunch of questions, hopefully it's okay to ask here :) How to keep the queue consumer flow open? Example Consumer provided here (https://tutorials.solace.dev/dotnet/persistence-with-queues/) gets messages only currently on the queue and closes immediately after that. How to keep the flow open…
-
PDB for libsolclient.dll version 7.19.0.30 for x64 windows
Hi All Is there a download link for the libsolclient.pdb for version 7.19.0.30 for x64 windows. I am building against version 7.14.0.8. However during runtime the program is picking up 7.19.0.30. Is that a problem ? I see some unexpected behaviour. and the pdb will give a slightly better idea. the program actually starts…
-
.NET - Enforcing Queue to Respect Message Priority
Hello everyone, I am trying to implement a simple PoC solution to check whether Solace PubSub+ will be appropriate for my company. All went fine to the moment I wanted to use priority messaging. I would like to 1. create a queue from .NET 2. assign Priority to messages 3. enforce the queue to respect message priority…
-
Google Storage Connector Speed Issue
Hello, There seems to be a problem with delivering message to a google cloud storage bucket. Solace can't deliver the messages in the same speed as they come in. It falls back to 1 per 1-3 seconds. Why would this happen and why would it need to redeliver? I've checked it with another storage account and there it has no…
-
Solace JMS Channel closing on it's own when running on a Kubernetes cluster (Spring Boot Autoconfig)
Log snippet: {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label": "Client-109: Connected to host 'orig=host:55555, scheme=tcp://, host=host, port=55555' (smfclient 109)"} {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label":"Client-109: Channel Closed (smfclient 109)"} It basically loops like…
-
How to export queue configuration with SEMP API
I'm building a process to integrate Solace with CI/CD, where we need to export the queues from Dev to UAT as part of the deployment process. Basically developer create the queues in DEV using UI and then its moved to upper envs with automation. I could not find a way to export specific queues configurations using SEMP,…
