-
Using an ITransactedSession and handling errors with the .net API
Suppose I am publishing guaranteed messages to a topic. I want to avoid sending duplicate messages. I am also going to send messages in transactional batches to make it easier to guarantee the broker receives the messages in the same order that the publisher creates them, without having to fall back to completely…
-
JMSToolBox not showing messages greater than 4MB
We use JMSToolBox to browse the messages in Solace Queue since there is no built-in tool. We now faced strange behaviour likely caused by large message sizes. What happened: * We published messages >5 MB to Solace * We could see the messages in Solace Portal(message count increased) * When using JMSToolbox and looking into…
-
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 =…
-
Queue with random order?
We aim to have a queue without order. The motivation behind this is that younger events update older events, and the updating process is relatively 'expensive'. However, if younger events arrive first, older events are simply discarded. How can we enable this?
-
Release note / Change Logs for version 10.0.1.XX
May i know where to find changes log for version 10.0.1.XX ? I want to know whether there is any vulnerability patch happen in 10.0.1.XX
-
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…
-
Filtering messages on a topic by the consumer
I have a topic to which my backend service publishes the messages. I connect to that topic from my UI ( angular application) to consume the messages. I can have multiple browser sessions subscribing to the topic. I want to consume messages from the topic which are relevant to a browser session only
-
Certificate of Training - how to change the name?
Certificate of Training - how to change the name? I noticed that the value in field This is to certify that contains a spelling mistake. Am I able to correct that as self-service? In field My Profile I fixed the issue. When hitting the Download your Certificate button it is working with the previous spelling.
-
Connection pool size for outbound messages
What would connection pool mean in solace mean ?Would it mean pooling the session,that is multiple sessions treated as one or something else? And is Connection pool size configurable in solace-cloud?
-
Intermittent "Assured message delivery is not enabled on this channel" errors
Hi there, We've had this publisher app that sends events to topics other client apps in the firm are subscribed to using queues of their own, for years. Lately, though, we've started to notice these exceptions intermittently that we've encountered previously. The client profile has "Allow Guaranteed message send" enabled…
-
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…
-
Event Mesh using DMR
Hi All, Currently I’m setting up event mesh using DMR for 3 solace brokers. I have 3 cluster. Cluster A, B and C. A is connected to B using external link. C is connected to B using external link. As of now, when A publish a message, my cluster B is able to receive the message, however I face the below issue. If A publish a…
-
Can someone please help me to know How to generate the details mentioned below.
IP Address of the Solace messaging appliance in the form: [Protocol:]Host[:Port] (e.g. tcp:192.168.160.101:55555 ). * Client username and Message-vpn used by the sample application (e.g. browser_nse_dev) * Password for the Client username used by sample application (e.g. browser)
-
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?
-
Publish unicode string using solclientjs
Hi Experts, I am trying to publish a non-ascii string to a solace topic using the solclientjs library in nodeJs, and consume the same using the golang solace messaging library, and vice-versa (i.e. golang to nodeJs). Example string: abc-nonascii_ãçï_স I understand I have three options to do this in solclientjs: as…
-
Solace Spring Cloud Stream Function (Processor pattern) with StreamBridge
Hi, I currently have a usecase wherein I have implemented a Processor pattern using the typical Bean Function<?,?> for my SCS application. I understand that a Processor pattern is a straightforward Input-Output Solace stream. But now I have an additional requirement that, within the processor, an arbitrary event message…
-
Serialize Solace JCSMP BytesXMLMessage
I am working on Apache Flink based Realtime/Streaming data processing pipeline. Here my upstream system is Solace Q's. After receiving message from Solace, I have a requirement to store the message(BytesXMLMessage) in cache until all the functions(filter/map/translator/enricher) in the Flink pipeline are executed. Since…
-
Write for the community and get paid with the Solace Scholars Program!
Good news! We just launched the Solace Scholars Program to encourage original technical content about Solace by the community and for the community. What can you write about? You can write about your project, a use case, or something you are working on or have built using Solace technology and third-party integrations. You…
-
Timestamp when queue received message
Hi, does Solace durable queue store a timestamp when it received a message or can we configure it to do so? I tried InboundMessage.getTimeStamp and it always returns 0. I also tried InboundMessage.getSenderTimestamp and it's always null because I'm not filling it in the sender. According to an older question…
-
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…
-
C API error as --'solclient/solClient.h' file not found #include "solclient/solClient.h"
When I am trying to run a file in C, I am getting this error. Can someone please help me with this. I am new to PubSub+. Trying to learn as much as I can.
-
How to enable queue to accept incoming messages from CLI
Hello, I m using solace cli to provision a queue in the router, but I m not able to find the command that enable the incoming / outgoing functionality that I can see in the solace console UI. This is a snippet of the script : configure message-spool message-vpn default create queue dev/st1/q1/p1 access-type non-exclusive…
-
Could not load file or assembly 'SolaceSystems.Solclient.Messaging, Version=10.23.0.0 in container.
Hi Thank you Solace team - I was very excited with the release of version 10.23, as this now supports the Mac series M processors. I am now able to build event driven dotnet applications on my Mac M2, using rider, without issues. However, when dockerizing these applications & running the container locally on my M2, I still…
-
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-pubsubplus is not getting installed in python:3.8.0-alpine3.10
Trying to install the solace-pubsubplus==1.6.0 into the python3.8.0-alphine3.10 inside the docker ERROR: Could not find a version that satisfies the requirement solace-pubsubplus==1.6.0 (from versions: 0.2.0, 0.2.1) ERROR: No matching distribution found for solace-pubsubplus==1.6.0 error building image: error building…
-
After Active-Passive solace brokers has switched there role. what is the best way to do switchback
Lets say After solace Active-Passive brokers has switched there role due to primary. what is the best way to handle switchback once previous primary node becomes healthy. should there be any change in configuration? pls let me know