-
Replay messages - Couple of Questions
I was wondering if the messages that go into Replay log, consume any of the quota limits that are present on the VMR / Appliance example: Number of delivered but unacknowledged messages Number of replicated topics Number of topic subscriptions that can be assigned to all queues Maximum number of messages queued for…
-
Max Client Queue and Topic Endpoint Flow
Solace version: 10.2.0.26 hosted on AWS Ec2 instance. Solace default VPN had 100 as the default setting for various connections. We have updated it to 1000 and restarted the appliance. Used cmds below to restart the solace: solacectl cli enable reload Boomi EDi is used to connect to queue as listener. When we got the below…
-
Questions on sdkperf
I have some questions on the sdkperf latency result. 1) Why 95th, 99th percentile latency is N/A ? 2) How does the bucket size affect the latency measurement? 3) How does sdkperf calculates Minimum and Average Latency for subs? Is the time based on the data packet travel from client to message broker and back?
-
Solace PubSub + Mac M1 based Docker container is not working.
Hi Community, I am trying to run the arm based docker image for PubSub+ event broker and container is getting existed after running the container. FYI - I have executed the docker compose image for - solace-pubsub-standard:100.0arm_proto.0.92 Following is the docker output for container. Access: 2023-06-09…
-
What happens to replay logs when using Dynamic Message Routing?
If I'm using Dynamic Message Routing/ an event mesh and have many Solace instances connected together, what happens with the replay logs? Does every instance have a complete replay log or is it distributed across all instances? Is there any way to add redundancy to replay logs?…
-
Is is it possible to consume user-defined headers using Try me in console?
we are using PubSub+ Kafka source connector as a consumer, so is it possible to consumer the user defined header using PubSub+ Kafka source connector?
-
How to empty a queue with 200+ messages?
Hi all, We are using Solace in combination with Boomi. We're looking for a solution to empty a queue quickly. No matter how many messages are in that queue. From the Solace Cloud console, the max is 50 per page. JMS Toolbox is refusing to empty a queue when it contains 200+ messages. How to solve this? Ideally, we would…
-
How to get back the message id after publishing a message on solace topic using nodejs
hi Members, i need help to get the message id immediately after publishing a message on topic using nodejs. i can publish a message but not sure how to get the message id back after publishing. i tried to search on the google but no luck. here is the code i am using to publish. code block : const solace =…
-
HA redundancy - Monitoring node issue
I followed the steps documented in the HA redundancy section, both the primary and backup nodes are online and I can see the redundancy working. Monitoring node is offline, the show redundancy group on monitoring node shows all nodes as offline. I tried multiple times the behaviour is consistent, not sure what I am…
-
Get clarity on retry count (named delivery count) - several questions
Use Case: ========== As consumer in case of retries you naturally want to differ in your logic depending on which retry you are on. As well likely you want to log somewhere which retry you currently processing. Delivery Count: =============…
-
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…
-
How to avoid duplication of Total delivery unacked messages?
Few messages got stuck in the queue for delivered unacked messages, only if the application restarts the messages are removed from the queue. Will the broker tries to send the stuck messages again and cause a duplication of messages and if yes, how to avoid it when the application restarts or any other possible solution…
-
Configure timeout for acknowledging message
Hello folks, Our webhooks take more time to send an acknowledged response back to the broker in qos1. Can we increase the timeout limit?
-
How to get which broker is in control in HA pair (primary or backup) programmatically
How to get which broker is in control in HA pair (primary or backup) programmatically using SEMP API's or any other means but not using soladmin.
-
Consume existing Solace Queue using Python
Hi @marc @Tamimi we have existing solace queue with topic subscription enabled. need to listen and print message flowing to that queue. tried below code & got error, please help. persistent_receiver: PersistentMessageReceiver = messaging_service.create_persistent_message_receiver_builder()\…
-
Failed to consume a message from destination Queue
I am using Spring cloud stream 2021.0.2 to consume messages from queue, when some messages are sent , I can see the message get spooled continously in the queue but It is not coming inside application and processed because of below exception. Please help org.springframework.messaging.MessagingException: Incorrect type…
-
Blocking send operation
Is there a way to invoke the send method in a blocking way? I would like to wait for the ack/nack/timeout, and continue only after I have the result. My current solution is a wrapper of the original send method, that keeps track of the sent messages and waits for the event from the event broker.
-
Read Consumer response object from broker in function app
Hi, We have an Event driven app which publish a payload to a topic in solace broker from Azure function app. There is a consumer which is of REST endpoint. Once the message is delivered and processed by consumer, they send a 200 OK with an object `{"message": "SUCCESS"}` . We want to read this response object from the…
-
Failed to consume a message from destination
I have a queue A which has many topic subscriptions. We run our microservice using Spring cloud stream stack. When queue A receives messages from different topics and processing them and all of a sudden, we see below exception stacktrace is continuously printing in the logs. I am not sure about the reason, while it is…
-
Python connect to solace Pubsub+ cloud
I have service created on https://console.solace.cloud/services on GCP platform and I am trying to connect to this service from python 3.7 using solace-pubsubplus pypi package: https://pypi.org/project/solace-pubsubplus/ Here is my code snippet for connecting to the service: _def publish(message): import…
-
MQTT QoS 1 Queue name
Hello @all, when creating a queue on the Solace Broker with an MQTT Client 3.1.1 and QoS 1 the queue name consists of two parts #mqtt/{client id}/{3 digits numeric id} For example: #mqtt/MQTTFOGarticleStore/351 #mqtt/MQTTFOGarticleStore/347 When connecting with the client the numeric id changes. Is there a way we can fix…
-
SOLCLIENT_SUBCODE_DATA_OTHER - Exceeded Spool File Limit
"{'caller_description': 'From service event callback', 'return_code': 'Unknown (503)', 'sub_code': SOLCLIENT_SUBCODE_DATA_OTHER', 'error_info_sub_code': 28, 'error_info_contents': "Exceeded Spool File Limit - Topic 'my/topic'" Still haven't resolved this issue as the docs are quite ambiguous about this error code.…
-
Running Software Broker using Podman on MacOS (x86)
Here are the steps to get Solace Broker running using rootless podman. We will be using brew to install podman on the host. a) Update brew brew update b) Upgrade brew brew upgrade c) Install podman brew install podman d) Create and start your podman machine podman machine init --cpus=2 --disk-size=20 --memory=4096 -v…
-
How can I check session is connected or not (is session active/connected)? in solclientjs
Hi All, I do have few queries regarding the session lifespan in solclientjs lib. How can I check (periodically) session is active/connected or not? When connected using oauth2 and as soon as token expires then I see the session get disconnected, how does the client application get notified for disconnection instantly? I…
-
.net sdk writing directly to solcache
Is there a method of writing messages directly to topics stored in solcache without current subscribers receiving the message. Wondering if message filters is the best method of doing this.
-
How to set replyTo using sdkPerf
Hi, I am using SDK perf tool to perform the latency test. I have been able to send a binary message but how can I set replyTo topic ? Command used to send binary message: sdkperf_c -cip=server -cp=something -cu=something -ptl=mytopic_to_publish -mr=messagerate -mn=no_of_message -stl=static_response_topic -pal=mybinary.data…
-
error while creating receiver flow: Max clients exceeded for queue
We are currently building the Solution to integrate with Solace. We are still developing and not using Solace in Prod. Currently only a few developers uses this Solace and we donot have that many Sessions or connections to Solace. According to the Dashboard, it is using only 2 Active connections (But actually we have…
-
System scaling using helm chart
Hi. I have configured solace in my dev env(using helm chart) and currently it only allows upto 100 queues/endpoints creation. To scale I tried setting systemScaling values to : But it doesn't seem to be working. I setup solace in my laptop in docker and added these as --env system_scaling_maxconnectioncount=1000 --env…
-
C API for iOS simulator on m1
Are there any plans to support iOS Simulator on M1 Macs?
-
Queue binding with Service Unavailable status
I new to Solace and I'm doing some exploration to see how this would fint in my organization. The use case straight forward, post a message from a producer to solace queue and have solace forwarding it to rest consumer. This is bit complex setup with private AWS API GW, but connectivity is there. I'm having a hard time…
