-
topic drop messages when full
I am sending messages to a temporary topic from my jms endpoint. Jms provide a timeToLive property that configures how long the message lives on the topic. I was trying to figure out if there is a way to configure on jms to tell the broker to drop messages from the topic if the topic is full and not block it. I dont see…
-
How to test TLS connection and server certificate
If you use TLS to secure your connections (and you should use TLS as often as possible), you sometime have issues connecting to your TLS ports. Here, I will describe a way to debug that. Try to connect to a port You're not sure, if your service / port is enabled or (most probably) if all your firewall rules are in place ?…
-
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/
-
Using Client Certificate in JMSToolBox
Hi, I have a customer who is trying to use Client Certificate in JMSToolBox. I tried to configure the appropriate properties but the underlying API still tried to use basic authentication to connect to Solace. Could you provide an example? Thanks, David.
-
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…
-
Error connecting to a temp jms queue
i am using camel to connecto to my underlying solace broker. All my static queue connections work fine. eg. jms:queue:<queue_Name>?queryParams But when I make a temp queue connection it fails. jms:temp-queue:<queueName> The error is as follows Highlighted Exception Caused by:…
-
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…
-
Monthly Feature Highlight Training | April 2022
March was a big month for releases with Solace. Not only is there big API news for developers, but the release of PubSub+ Broker version 9.13.1 brought along some great features to make administrators lives easier when setting up connections to external services. Sign up to Solace Academy to get access to our April 2022…
-
This month’s Community Contributor badge recipients
As you may have noticed that we’ve announced the addition of our new Community Contributor badge and promised to award it to community members each month, I’m glad to announce the recipients for the month of October! * @harry – for writing the blog post “Sending Events in a Distributed Way to PubSub+ with a Spark-Solace…
-
Gopher in an Event-Driven playground
In this Conf42 Golang 2022 talk, @Tamimi gives a high-level overview of what an Event-Driven Architecture (EDA) is and its relevance to the real-world use cases. He shows how one can adopt a protocol and language agnostic event-driven architecture using GoLang. Watch the video to understand: Asynchronous Event APIs vs…
-
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…
-
Where can I find release notes for SolaceSystems.SolClient.Messaging C# lib from 10.7.0.0 onwards?
Sometimes having issues with the client I'm working on being a slow consumer. Using SolaceSystems.SolClient.Messaging 10.7.0.0 and difficult to upgrade due to company policies. I want to know if there's any bug fixed in the client lib after this version regarding slow consumers. I tried looking for them, but I can't find…
-
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…
-
Durable Queue Inactive Consumer Indication
Hi community, we are exploring the Active/Inactive Consumer Indication feature of solace queue. We have created a durable queue at Solace and connected two consumers with the queue. We have tried with Java and Nodejs. (1) JAVA JCSMP API public void handleEvent(Object source, FlowEventArgs event) { System.out.println("Flow…
-
Client Ack using Apache Beam
Hi - I am using Apache Beam (2.30) with Solace connector. I receive messages from Solace, process it, save it and then wish to ack to Solace once I am done with processing. I explicitly sets the status of my POJO to true once saved. So for such successfully processed messages, I wish to ack. However, I am facing issues as…
-
Go API v1.0.0 coming soon 👀
The PubSub+ Messaging API for Go will be GA towards the end of this week! Let us know if you will be using it 🙌 FYI: More details on the early access version is found here https://solace.community/group/4-solace-early-access-golang-api A couple of questions to the community Are you currently using GoLang in your…
-
What happens to demoted messages in an MNR network?
Multi-Node Routing (MNR) allows multi-broker distributing of direct messages, but what happens when you publish a persistent (guaranteed) message that matches a direct consumer locally or somewhere in the MNR network? The message will be demoted to direct for the local consumers to receive, but a published persistent…
-
Tip: Git repository search
I am sure, many of you are Git gurus 🙏 Just wanted to share what I found - if you are looking for repositories set to topics with keywords like X, Y and Z, you can simply type topic:X topic: Y topi: Z in the search text (unlike Google's X + Y + Z). For example, if you want to locate a repository of AsynAapi spring cloud…
-
Non Exclusive Queue Behavior using MQTT
Hi, we have multiple consumers connected to a durable non-exclusive queue and when we send a message to the queue , only one of the consumers gets the message. Can it be possible to achieve the same behavior using MQTT / java-paho-mqtt ?
-
How can we achieve solace message delivery of at least once with variable number of pods?
We have a kubernetes deployment having 2 pods. We want to send messages to both these pods in 1:n way (each message should be received by both) and each message should be delivered at least once(QoS1). To achieve the same, we have a topic and 4 queues created beforehand. All four queues are subscribed to the topic and…
-
How to get the number of current consumers of a durable queue ?
Hi, is there any native API (Java, NodeJS, GoLang) by which we can get the number of current consumers of a durable queue ? one way is to use SEMP API ("GET /msgVpns/{msgVpnName}/queues/{queueName}/txFlows"). We are looking if there way way to do the similar task using some native API.
-
OAuth with REST consumer
hi, I am using Solace Event Broker Version9.10.0.21; I am trying to set up Azure function as one on of the consumers but it should use OAuth for authentication. What all setup I should do, please advice as I am new to Solace. Do I have to enable OAuth Provider Authentication at the service level a first step ? Then in the…
-
[New blog post for developers] An Open Source Approach to Delaying Message Redelivery Attempts
by Thomas Kunnumpurath In this post, I’d like to introduce an open source project I developed to delay redelivery attempts when messages aren’t successfully delivered. I’ll introduce its internal design and then dive into how I took advantage of an interesting Java construct and Java Streams to build out the functionality…
-
.NET solace API (data network) to get solace timestamp
As title, is there any API for me to get current timestamp from solace ??
