-
Topic end Point in solace
Hi Team, @marc I gone throught DMR usecase and I have 2 pub application and 4 Sub application , I using spring cloud stream. I have used dynamic routing in smae. My question is when I am publishing the topic I can see the topic at consumer end like which consumer has consumerd the topic but I want to see it at Solace end…
-
Multiple binder configuration
Hi Team, I am trying to connect to solace using spring cloud stream solace binder with all the properties in application.yaml I have 1 producer on Aws service and another one in azure service in solace and I have a consumer at my local, how I can deifne multiple binder for same confumer in spring Yaml file. Please suggest.
-
Message Ordering
I have a requirement where Message ordering is the key. When 10 messages are published to solace with order numbers OD1,OD2,OD3…OD10 While consuming if the first message OD1 fails the consumer should be receiving OD1 and then OD2 so on. The consumer should not be receiving OD2 before OD1. This way the order should be…
-
Pause & Resume Solace Message consumption from a queue
Hi, we have requirement, when a particular job is running we need to stop listening to a queue to consume new messages after that job is completed we want to start consuming the messages from Queue. Using Solace Spring Cloud Stream how we can pause and resume consuming of messages from a queue. if we have some code snippet…
-
Respool to queue
I was reading the behavior for Solace redelivery to consumer while assuming I have an exclusive queue with one consumer. First : Can you please let me know if the behavior is correctly understood ? Solace redelivers messages on the transport level. Meaning the messages are redelivered only when a flow or connection is…
-
Pubsub+ Now Offers Configurable Replay Topics!
Hey Solace operations and developers! PubSub+ is taking the replay log to the next level of flexibility by allowing you to configure exactly which topic is mapped to your replay log. PubSub+ Event Broker 10.0.0 allows you to customize exactly which topics are sent to your replay log. Your broker administrator to configure…
-
Clarifitcations regarding sticky load balancing example architecture by Mathew Hobbis
Hello, I have read the example implementation of sticky load balancing by Mathew Hobbis on this link and am slightly confused about a few things. Was hoping I could get some answers to the following: Inquiry 1: Regarding "Consumer Group Clients", is this the same client as LBG Client? or is it a different service? Question…
-
Reply Topic name in InboundMessage - GOLANG API
HI, I need to get reply to topic in message received in gateway mode.. It's possible? Exist some a property? I tried thus... reply_to, _ := message.GetProperty("reply_to") but not working... returned nill... How to do for get reply topic name in the message???? I am using GOLANG API 1.0.1... Thanks for help..
-
Solace throughput scaling
What is the rate of consuming message/sec for a consumer with 1 concurrency in spring cloud stream app with solace. Just wondering what would be throughput / hour if there is just one consumer with 1 concurrency smoothly. Using Physical Solace Appliances.
-
Error running API-GOLANG app in windows 10
Hi, I am trying to execute app API-GOLANG in Windows 10, but the following error is present: # solace.dev/go/messaging/internal/ccsmp ..\..\pkg\mod\solace.dev\go\messaging@v1.0.1\internal\ccsmp\ccsmp_container.go:29:10: fatal error: solclient/solClient.h: No such file or directory 29 | #include "solclient/solClient.h" |…
-
Is there a way to get a Queue Created Date in Solace?
Hello All, I would like to know if there is a way to get the queue created date via SEMP API's or any other means in Solace? Have tried with SEMP Over Message Bus & Monitoring SEMP API but it does not speak about when the queue was created. Thanks Tejas Chowsalkar
-
Cache instance status NotAvail in Docker demo instance
Hi guys, noob question. I am trying to setup most basic cache configuration. I am running this in linux container on Windwos 10 in WSL2. Commands: _docker run -d -p 8080:8080 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env username_admin_password=admin --name=solace…
-
Docker will not work
Hello! I've been working with solace for a while now, and i've allways ran it localy on docker. I've switched to linux recently and a stange thing happened. Yesterday I was running solace ok on my machine, with docker, but today, I can not make it work. Nothing major has changed but solace just wont work on docker. This is…
-
Backpressure / message delivery and the Python API
Hi, We have a non exclusive durable queue with several consumers (compute worker) who connect using the Python API. Each consumer runs the MessageHandler in a separate thread, essentially just filling up a buffer with messages, the messages are then consumed by the main thread in the compute worker and results sent out.…
-
Is there a way to get the List of Topics, applications are using to pub and sub from a broker?
For governance purposes, there is a need to know the topics which are being created by various applications on the broker. As I know (and I might be wrong), there is no intuitive way to get a list of topics under usage on a broker. As of now, we are not using Event Portal and hence do not have an Event Catalogue.
-
Reason for Solace CLIENT_CLIENT_DISCONNECT
Recently some of the microservice AMQP applications are disconnected based on the solace event logs. However, the microservice AMQP applications did not detect any "CONNECTION_CLOSE" event. And, the applications did not trigger DISCONNECT action. Is there any documentation of the reasons and the explanation for the causes…
-
SSL connection problem
Hello again, I used the scuresession.js file of nodejs toturious. And I created a Private Certificate Authority using this command: openssl req -newkey rsa:2048 -nodes -keyout MyRootCaKey.pem -x509 -days 365 -out MyRootCaCert.pem Then I created a certificate using blew command: openssl genrsa -out client1.pem 2048 openssl…
-
How to connect the event broker using ssl connection?
Hello, solace team I am a beginner and I want to ask some simple questions. I have created a PubSub+ Software Event Broker on my local docker following blew tutorial：https://docs.solace.com/Software-Broker/SW-Broker-Set-Up/Containers/Set-Up-Docker-Container-Windows.htm And I also connected to the broker using the node js…
-
OAuth + Microsoft Azure AD
Hello guys, does anyone have experience with how to set up the Solace connection using Microsoft Azure AD? I am aware of OAuth profiles in Solace admin, but not really sure what to input there. Thank you very much, Regards, Stan.
-
How do I send a reply in Microgateway mode to a dynamic topic?
Let's say I'm running an event broker in Microgateway mode and am handling REST requests with a streaming consumer/processing application. How do I send a reply to a dynamic topic? An example of why you'd want the reply on a hierarchical topic could be a req/reply validation flow, and having a downstream application (fraud…
-
Timeout when using Docker on Arch Linux
Hello Solace community, I have a small problem when trying to run Solace PubSub+ on my docker instance. I already launched an instance on another computer with the same OS (probably not the same installed packages I can imagine) and it was working like a charm, but when I tried on this computer I just wasn't able to make…
-
How to control client publish and subscription
Hi all, I would like to ask how to limit the client on Solace message broker publishing and subscribing topics or queues. For example I have a sender_001, he can only send out topic hello/python/> and I have a receiver_001 , who can only listen to topic hello/python/> and queue hello_q . I see that there is a page on the…
-
Receive the latest message only for both direct message and persistent message - python
Hi all, recently I am engaging a project that require data streaming. Therefore, even though there is a latency in processing the message, I would like the consumer always take the latest message. I am a python developer and would be grateful if someone can tell be how to achieve the above requirement for both direct…
-
Develop the C# client for sending and receiving messages through Solace Broker
Hi Team, I am new to Solace Pubsub broker. This is my first posting. So please apology me, if my query is not clear. I can elaborate it, if it requires. We want to develop the POC to send and receive messages (Pubsub pattern) for C# (Client). How to pass a data/messages using event schema defined in the event? How to…
-
House keeping for durable exclusive queues/DTEs having no consumer for a defined time
Hi, We want to implement a housekeeping mechanism for our Solace system so that durable exclusive queues/DTEs having no consumer for a defined time are deleted. We are thinking of the following approach. We implement a poller which looks at all the Queues/DTEs and finds out all the exclusive Queues/DTEs For each of them,…
-
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…
-
Unable to setup HA group for event broker on Windows Docker
Hi I followed the guide for setting up HA group locally on my computer: When i run the docker start primary backup monitoring command the containers startup, but after 30-45 sec. the containers shutdown again. I created the network using the command: docker network create solace-net Create command for primary: docker…
-
DLQ/Error QUEUE - Spring cloud Stream
When We publish message it goes to Queue via added topic subscription , which could be consumes using listener's easy. (Message published to Topic, Consumed From queue ) But, Why there is a difference in DLQ publish, I don't think when the message is getting republished to Error Queue it is published to Topic Endpoint,…
-
Direct Message Behavior and Persistent Message Queue Configuration
Hi all, I am currently exploring the solace message broker and come across two questions. Question1: I am trying to pass images with base64 encoded and direct PubSub is adopted. Since there are some program the subscriber has to run for each message and it takes time. Therefore, I expect there will be a latency for the…
-
Spool Over Quota. Router limit exceeded
I am using a guaranteed message queue. This is sit under the default VPN. The `Configured Quota` is 5,000 MB for the queue. The `Configured Quote` is 1,500 MB for the VPN. I cannot push to the queue when the message size hit 1,500 MB. I updated the `Configured Quote` for the VPN to 10,000 MB but I still cannot push message…
