-
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…
-
Solace PubSub+ for VMware Tanzu is released
The following Solace PubSub+ Platform product has been released and is available for download: * Solace PubSub+ for VMware Tanzu 2.9.0 Please refer to the product release notes for information on new features, changed functionality, resolved issues, known issues and upgrade considerations. Release Summary: **Solace PubSub+…
-
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…
-
Dockerfile custom entry point not working in 9+?
I am trying to create a Dockerfile with my VPN pre-populated through a configuration script called configure.sh. Dockerfile: FROM <hidden>/solace-pubsub-enterprise:9.12.1.17 ADD config /config ADD wait-for-it.sh /wait-for-it.sh ADD configure.sh /configure.sh ADD start.sh /start.sh USER root RUN chmod +x /wait-for-it.sh RUN…
-
Docker and AMQP (TryMe)
I am new to solace and have used docker to create solace container on my laptop. I am able to connect using "Try Me UI" with the address "ws://localhost:8008" and all works fine including sending messages, however, when i try connecting using AMQP protocol with the broker url "amqp://localhost:5672", it cannot establish…
-
Increase Message VPN limit
I am running docker for Mac as described here https://docs.solace.com/Solace-SW-Broker-Set-Up/Docker-Containers/Set-Up-Docker-Container-macOS.htm Container starts OK. But will not allow me to create more than 3 VPN - it responds "Message VPN limit reached". I cannot find any relevant documentation covering this…
-
Solace PubSub+ Messaging API for Go v1.0.1
This patch releases fixes the issue with `go mod vendor`. Previously, vendoring with the v1.0.0 of the API did not work due to a bug with go mod that pruned C libraries. Tagging @ambuj501 and @dpurwo
-
AMQPS with Client Certificates using .Net and Docker Container
Hi Team, I am trying to send message using AMQPS protocol and also along with this using client certificate for client authentication. With the below code, I am able to send the message to solace broker. However, after disabling the Basic Authentication and enabling Client Authentication, the message send fails with the…
-
setting max bind count
Hi, I have to set max bind count value as 200 in our Production environment. But my solace admin is saying that the client limit setup was already restricted in prod at 175. Prod Client Limit - clientProfileName: 5-pymt maxConnectionCountPerClientUsername: 175 serviceSmfMaxConnectionCountPerClientUsername: 175 So my query…
-
Load Balancing on One Topic Multiple Consumer
Hi all, I am new to Solace. Recently I am working on a project that assume the publisher only work on one topic and there is multiple consumer listen to the same topic. The project will be deployed to a k8s and I expect there would be a scaling on the consumer side. My design at this point is one publisher publishing a…
-
Solace PubSub+ API for JavaScript releases
version 10.5.1 maintenance release Release Summary * Bugfix: Using the new binary mode of the 10.5.0 API (with SolClientFactory profile set to version10_5), calls to Message.setBinaryAttachment() may not work correctly if passed a Uint8Array rather than an ArrayBuffer. (SOL-38220) Download https://solace.com/downloads/
-
Session connect timeout
Hi Solace community, First time posting here :) I'm having trouble connecting to solace broker with the C API. I'm getting the a Session connect timeout. SDK NOTICE Wed Apr 06 13:23:14.084 2022 solClient.c:10952 (7f0651038700) Connect attempt for host 'IP:55555' for session '(c0,s1)_default(client name…
-
Solace MQTT
Hi community, I have two queries for using MQTT with Solace (1) Can we set TTL for QoS 1 , so that for the created Queue , the same TTL is associated with it ? (2) Can we bind second consumer to an exclusive queue which has been already created before by another consumer ? We noticed with java-mqtt-paho library, when we…
-
Solace PubSub+ Messaging API for Go releases
The following product has been released and is available for download: · Solace PubSub+ Messaging API for Go 1.0.0 Release Summary This is the first release of the PubSub+ Messaging API for Go. Solace created this API to support the growing Go ecosystem and to address customer demand to create applications in Go that can…
-
Non-Exclusive Queue using AMQP
Hi, can it be possible to create non-exclusive queue using amqp in solace ? I am exploring Apache Qpid JMS 2.0 over AMQP 1.0 I checked solace-samples-amqp-qpid-jms2/QueueConsumer.java at master · SolaceSamples/solace-samples-amqp-qpid-jms2 (github.com) and it creates an exclusive queue and connects the consumer to the…
-
Window size(prefetch) control of unacknowledged message in Node.js
The messages in our system need to be processed in sequential (we expect the message to be handled one after another) and we are trying to build a queue consumer with the liberary solclientjs. (https://www.npmjs.com/package/solclientjs) I read some blogs and posts that mentioned two keywords the flow windowSize and…
-
Native C# Client for Web Sockets
Hi all! I need to connect via WebSockets to an on-prem Solace Broker from my native app (UWP written in C#). I also need to add I the Connect() HTTP request a specific HTTP Header "Authorization" with a Bearer token that I generate in the app. I cannot see a way to configure the Solace C# SDK to perform such a custom…
-
1:n behavior using AMQP
Hi, we have multiple instances of application and when we publish a message, all instances should get the message. we can achieve the same using native soalce api using queue and topic. We create multiple queues and subscribe the same topic to each queue. And each instance of the application consumes from the respective…
-
Channel immediately getting closed after connecting to host
main impl.TcpClientChannel:55 - Client-1: Client channel (smfclient 1) starting KA timer main impl.KeepaliveTimeoutHandler:28 - Created new KA timer handler main impl.TcpChannel:300 - Scheduling KA timer in 3000ms main impl.ChannelOpStrategyClient:381 - ** Got CLIENTCTRL, updating P2PINBOX to…
