-
Two or more consumers for different queues
In this example, I see only one consumer, in one subscription like here: https://github.com/SolaceSamples/solace-samples-java-jcsmp/blob/master/src/main/java/com/solace/samples/jcsmp/HelloWorld.java How should I create one consumer/listener for different queues? For instance, one consumer for certificateUpdate and another…
-
Send does not work, gives WaitingForDNS error yet connect() doesn't fail
I'm not sure whether my earlier post was misplaced, hopefully this is a better place. I'm trying to do a pub/sub tutorial, both publishing 1 message and subscribing to the queue. The original JS code as Solace created on Github. I'm trying to Typescript-ify the code and now it says OperationError: Cannot perform operation…
-
Authentication on reconnect?
I'm developing an application with the Java API. The application is a long running server. We are authenticating with username and password, and our passwords are rotated every twelve hours. It's not clear to me if sessions need to be reauthenticated on reconnection. If they do is there a way to update the PASSWORD in a…
-
Client Certificate Authentication Is Shutdown - How to activate?
user@broker-vm:/var/opt/solace/jail/logs$ tail event.log 2022-09-21T09:55:08.842+00:00 <local3.notice> broker-defaultshard-primary-vm event: VPN: VPN_BRIDGING_LINK_REJECTED: vapnonprod_vpn - Message VPN (1) vapnonprod_vpn Bridge edge_defaultshard.to.core_b from VPN vapnonprod_vpn rejected: Service Unavailable…
-
Return error information after enable TLSv1.2 on .Net Platform:
TLSV1,TLSv1.2 is working, Session connect is ok. But Return error information after enable TLSv1.2: [18:53:51 ERR] Exception thrown Operation Error: ReturnCode = SOLCLIENT_NOT_READY Error Info: (Subcode=CommunicationError, Error string=SSL establishment failed as the client due to 5 (ret -1, 'Peer closed socket') for…
-
Automatically run cli script during/after docker startup
Hello, is there a place or option somewhere that allows us to automatically run CLI scripts right after the startup completed ? The idea comes from PostgreSQL where you can create .sql files and place them in a specific path (here initdb.d) and they will get automatically executed. [...] If you would like to do additional…
-
Subscribing with #noexport fails to receive messages
Per the Solace docs, if I prefix my topic with "#noexport," I should be able to subscribe to the topic, but the subscription will not be advertised to adjacent nodes by MNR or DMR. But I'm having trouble getting that to work. In the below example, everything takes places on the same broker. Here is my publisher: 2022-10-20…
-
Queue not able to send expiry message to DMQ
Hi, I created 2 message queue 1) Main_Queue 2) DEAD_MSG_QUEUE The main queue has been configured 'DEAD_MSG_QUEUE' as DMQ name and 'Respect TTL enabled' with Maximum TTL (sec) as 180 sec. A producer is sending a message with DMQEligible to true and when the trough dashboard i can verify that message properties for…
-
When the fix "Q1CY2023" will be available for the usage ?
Will it fix the StalesessionException issue ? at java.base/java.lang.Thread.run(Thread.java:834), exception_class=com.solacesystems.jcsmp.StaleSessionException, exception_message=Tried to call receive on a stopped message…
-
Delete All Messages on a Queue/Topic Endpoint now available in Broker Manager and SEMPv2
One of the most requested features from our management users has been the ability to Delete All messages in one action from a Queue or Topic Endpoint. Well, I have good news! This feature is now available in version 10.0.1 of PubSub+ Event Broker. The Broker Manager UI now has an "Action" to "Delete All Messages" in either…
-
Protected Request Headers collection now available for RDP Queue Bindings
What? Solace has introduced a new collection/list of "Protected" Request Headers that management users can manage via PubSub+ Broker Manager, SEMPv2, and CLI management interfaces. The Protected Request Headers are exactly the same as the existing Request Headers collection that defines the REST header/value pairs defined…
-
Solcache
Hello....first post in the community so please be gentle. What is the difference between PubSubCache+ and Solcache ? is it just a rename? I want to try to push solcache as a solution for reference data store however, one restriction that I can't seem to suggest a solution for is: example: Object is Listing and Stock is…
-
Close connection on openshift every 2sec
My consumer connection to solace is closed after every 2seconds that leads to fail big message more than 5 mb read. Please suggest
-
Solace PubSub+ APIs (JMS/JCSMP, C, .NET) are released
In case you don't get the email notifications I just wanted to share the latest API info! Download from solace.com/downloads or grab them from the Solace Products site :)
-
Set ApplicationMessageType via REST API?
I rely on the ApplicationMessageType property to map received events back to the POCOs that they were generated from. I am publishing events from a Blazor WASM application, and can't use the SolaceSystems NuGet package since it won't run in a WASM environment. Thus, I'm using an HttpClient with the REST API. I've looked…
-
Solace SpringCloudStream PubSub model using durable topic endpoint
We have a requirement to stop listening to queue when any error occurred while processing. We are on Kubernates and we have many instances of an application which listening to the same queue, so if i try to stop listening to queue using the service name it stops only one instance others still listening to the queue. As in…
-
How to ensure that the replier is always online throughout the whole time request messages are being
Hi Team, Good Afternoon!! Functionality: Publishers ---> q/prd:durable queue--->XYZ consumers (replier) and reply to publisher by using non-durable queue. Please help with me with end to end steps for below ask. How to ensure that the replier is always online throughout the whole time request messages are being published?…
-
Connection State Problem
Hello Community, While we are trying to move our setup from centos to ubuntu as host vm, together with docker setup, we are trying to solve the folloing error: Connection State: Down (Local SSL handshake failed: Server certificate verification failed: path length constraint exceeded solace That message is shown on an edge…
-
SEMP java client INVALID PARAMETER
Hi, The Semp v2 java client built via swagger code gen doesn't appear to be able to handle a comma separated list of selects and where clauses. Using selects - queueName,msgs.count: ApiClient.buildUrl calls escapeString(value) which causes 'queueName,msgs' not a valid attribute. If i change the change to remove the…
-
Show max num subscriptions exceeded error when running direct receiver script - Python
Hi all, Currently I am working on the direct message PubSub. In the beginning, the script works very well without any error. However, after executing the script several times without making any changes, errors pop out and say the maximum numbers of subscriptions exceeded and unable to unsubscribe the topic. May I ask is…
-
solClient_session_connect failed subCode: SOLCLIENT_SUBCODE_LOGIN_FAILURE, responseCode: 401, reason
I started a Solace broker docker instance, created message-vpn and username: esptest. When my solace pubsub client tries to connect to the broker using username/password, it gets "Unauthorized error". I have set up the auth-type to internal and followed the doc:…
-
Query regarding Topic Based Filtering of Payload
I have a Solace Topic Based Filtering related requirement in which we have a topic already established with the topic name: Dia/Tech/Mulesoft/Interlayer/PRC/PIOS/RSVD/RSVD/FromMSBQueue/Published/1/PRC/PIOS which is attached as a subscription to Queue in On-Premises : Dia.Azure.POC & Queue in Cloud Broker :…
-
Sending Ack with multiple flows
@Ragnar as per the conversion here is fresh discussion. Hello, I am new to solace and I have a question about having multiple flows. Consider the following situation: A consumer is consuming messages from 2 queues. Then the consumer will create 2 flows. Here the consumer is not just consuming the messages, it also…
-
My Question is regarding Replay in Solace
Hi , I have following questions on Replay Want to know more about the replay Queues that gets created once we enable the replay on our VPN. One of the queues has name like Replay Log which stores all the persistant messages getting send to the VPN , what about the other queue having name like REPLAY_TOPICS what exactly is…
-
[Demo & Live Coding] Outputting syslogs in JSON format
Tamimi and Rey show you how to use this feature.
-
[Demo & Live Coding] Replay to temporary queue
Tamimi and Rey show you how to use this feature.
-
Spring cloud data flow slow consuption
Hi There I need help to understand why spring cloud data flow is very slow in reading message from solace. I run four consumers in non-exclusive mode but message reading is like 5 message in 30mins. One catch here is message size is more than 10mb but will that be problematic. Is there any network parameters to be…
-
C# consumer flow dispose
Hi I'm new to Solace + this is my first post, so be gentle :D I'm building a worker (C#) that consumes messages off a Solace Queue using the SolClient messaging API. On application shutdown, I attempt to stop & dispose the flow. See code below: _flow = session.CreateFlow(flowProperties, queue, null, HandleMessageEvent,…
-
[Demo & Live Coding] Topic filtering with message replay
Tamimi and Rey show you how to use this feature.
-
[Demo & Live Coding] Delete all messages in a queue
Tamimi and Rey show you how to use the new feature.
