-
Horizontal scaling of event brokers?
I am investigating creating a HA PubSub+ broker setup, but a single primary broker will not have enough capacity for my needs. Do I need to create multiple triplet clusters and connect them? If so, how is load distributed between the clusters?
-
Getting BeanDefinitionOverrideException: Invalid Bean definition with name 'Queue_name.Group_name
Getting BeanDefinitionOverrideException: Invalid Bean definition with name 'Queue_name.Group_name.errors.recoverer' defined in null: Can not register bean definition[ErrorMessageSendingRecoverer] Help Me solve this issue
-
Solace Channel Interceptors
I am trying to implement common functionality in my methods marked with @StreamListener. I tried registering a GlobalChannelInterceptor but found that the postReceive/afterReceive methods are not triggered when a message is received. Only the preSend/postSend/afterSendCompletion callbacks are executed when sending a…
-
Any reference on how to map RabbitMQ patterns to Solace patterns
Hi, I am looking out for any reference material which describes how to migrate a messaging solution from RabbitMQ to Solace? For example, RabbitMQ describes certain messaging patterns @ https://www.rabbitmq.com/getstarted.html , what I am looking for is a short guide which helps map these patterns and how to realize them…
-
How to put a timeout on receiving messages in asynchronous mode in C Solace API?
Can anyone please share any idea. I want to pass a timeout value within which the message must be received in C Solace Api. receive(timeout) is there for Java Api. Is there anything similar in Solace C api.
-
"Request reply guaranteed messaging using Solace C Api" along with Timeout.
Hi Team, I went through this link "https://docs.solace.com/API-Developer-Online-Ref-Documentation/c/ex_2_r_r_guaranteed_requester_8c-example.html" . The link shows a way of doing it but is there any other way? I came to know about "RRGuaranteedRequestor" and "RRGuaranteedReplier". I want to create a functionality which…
-
GARBAGE CHARACTER getting added in messages received in Request/Reply messaging method.
Hi Team, I am using request and reply mechanism to send and receive messages. After I have sent the message, in the receiving Callback method i found that a garbage character is getting added at the end of the message. So on receiving the message, i am getting the garbage character, Following is the way i am sending…
-
solace running in docker not able to connect to ws port
I am running solace using docker with the below command. But I am not able to connect to websocket from TryMe!.... ws://localhost:8080 docker run -d -p 8080:8080 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env username_admin_password=admin --name=solace solace/solace-pubsub-standard
-
Which IOT Edge gateway product did you mention during the Solace EMEA community event?
This is a question for @TomF
-
SEMP v2- get if any one of the condition (where parameter) is true
http://applianceIP/SEMP/v2/monitor/msgVpns?where=eventConnectionCountThreshold.clearPercent!=40,eventIngressMsgRateThreshold.clearValue==300,enabled==true&select=msgVpnName In the above example, i am getting the results if all conditions are true/satisfied. But is there any way to get if any one or more conditions are true?
-
Boomi Solace listener: com.solacesystems.jcsmp.PropertyMismatchException: Access Type mismatch
Hi, We have successfully tested Boomi and Solace Cloud. We're now testing Boomi with a Solace broker running on an EC2 AWS instance. We basically changed the connection settings on the Boomi side. * The Boomi connection connectivity test is successful * We're able to send messages from Boomi to Solace * The Boomi listener…
-
PubSub Docker image fails to start in an LXC/LXD container
Hi, I have Docker installed in an LXC/LXD container and I'm trying to start Solace PubSub with the latest image (9.8.0.12). Unfortunately, I keep running into the Unable to raise event; rc(would block) error: Host Boot ID: cdbf8a80-964d-4368-9174-90d6a004189dStarting VMR Docker Container: Fri Jan 15 15:59:41 UTC…
-
Solace .NET API
Hi, I am able to connect Solace through Solace API from C# and I have a query whenever I consume messages it reads one message at a time. If we have more than 1000 messages at a time do we have any properties to set how many messages to consume at a time? or we need to loop to the count of messages in the queue.? Could…
-
A Bootiful Podcast - Spring Cloud Stream Lead Oleg Zhurakousky
If you're interested in hearing about the latest with Spring Cloud Stream & Spring Cloud Function be sure to checkout the latest podcast from Josh Long. In this episode he talks to Oleg Zhurakousky, the lead of the Spring Cloud Stream and Spring Cloud Function project. While you give it a listen keep in mind that the…
-
503: Transaction Failure: The number of messages in the transaction exceeds the limit [Subcode:63]))
Hi, We're a Boomi implementation partner. We want to empty a queue with 20000 messages which we don't want to process. * We tried to empty the queue with JMSToolbox. However, JMSToolbox gives the error (See screenshot below). * We also tried to delete messages from the Solace Cloud management console but there's a…
-
Solace SEMP error: "Unable to allocate a semp session"
Have you ever seen this HTTP error? This occurs when too many processes are trying to access the Solace broker using SEMP. Or, perhaps a small number of processes/applications are polling the Solace broker too quickly. This often happens in larger distributed environments, where multiple monitoring frameworks are in place.…
-
Quarkus native and solace client issue
Hello, I'm developing an application with Quarkus and Solace. Quarkus allows you to compile java to a native application. Compilation is fine, but at runtime I have this issue: 2020-11-13 12:49:18,462 ERROR [io.qua.run.Application] (main) Failed to start application (with profile dev): java.io.FileNotFoundException:…
-
Exceeding max queue spool blocks publishers?
If a client creates a queue with a topic subscription and then does not consume the queue for whatever reason, it will eventually reach its max spool usage. At this point anyone attempting to publish guaranteed messages to that topic will fail. Is there any way to prevent this publishers from being impacted in this…
-
Reprocess messages which are not Ack-back by consumer
Hello There, Using JCSMP API. This might be repetetive query, appreciate if you point me to solution. 1. I am using Guaranteed Delivery Queue 'DeliveryMode.PERSISTENT' to publish a message on queue. 2. I have Single Consume for this Queue endpoint_props.setAccessType(EndpointProperties.ACCESSTYPE_EXCLUSIVE); cons =…
-
Pattern for handling RejectedMessageError events with guaranteed messages?
Suppose I am publishing guaranteed messages. I want to ensure messages are guaranteed-in-order with at-least-once-delivery all the way from the publisher which is generating the message data, to the subscribers consuming that data. On the publisher side, I can ensure that messages have made it to the appliance by listening…
-
How to setup the ack timer for guarantee messaging
Hi All, I am trying to implement the Solace exchange pattern called Topic to Queue Mapping (https://solace.com/samples/solace-samples-dotnet/topic-to-queue-mapping/), the architecture is 1 producer, 1 queue with 2 consumer (access type is non-exclusive). Considering the loading issue, I assume the consumer will not ack…
-
Configuring Max Message TTL with the JCSMP Client?
When provisioning a queue with the JCSMP client, the EndpointProperties object contains the setRespectsMsgTTL(), but there doesn't seem to be a way to configure the max message TTL. Am I missing how to do this?
-
Approaches to consume the data from solace queues on need basis.
Hi Team, Could anyone share the solution approach for consuming the data from solace queues whenever it is needed. Lets says every 12 hrs or 24 hrs, the time frame might change as per the need. I am more looking in to pull mechanism, unlike RDP( Push). We have also MuleSoft in the approach, any feasible solutions is much…
-
JCSMP: Disconnect flow consumer from Queue to make possible other to connect
Hi. I need to unbind flow consumer from queue to make possible to run other app for connecting to the same queue.
-
Live Chat now available in PubSub+ Cloud
If you have a question while using PubSub+ Cloud or need more information about how Solace can help you become event driven, you can have a live chat with someone from Solace at any time now. Here is how to use the new feature: * If you have not already signed up for a trial account of PubSub+ Cloud, do so at…
-
We're looking for a Developer Advocate in India!
Hey Solace Community! We're looking to hire a new Developer Advocate to join our cool awesome team 😎 The location we are looking for is India; preferably Bangalore, Karnatak. Let us know if you are interested of know someone who would fit our team The job posting is here https://solace.bamboohr.com/jobs/view.php?id=241…
-
Updates on Python Samples
I have updated the Python API Samples with the new guaranteed messages samples. https://github.com/SolaceSamples/solace-samples-python/tree/master/samples Feedback welcomed!
-
Simple pub/sub inside the connector (MedTech Dev Kit) Python
I wonder how I can replace the echo device with my python code inside MedTech Dev Kit: how I can replace my code with an echo device without a BLE device
-
Websocket connection failed error.
Hi Team, We are trying to connect to SOLACE system to access Queue using Java Script. For some reason Javascript is giving following error. "Websocket connection failed error. Error during websocket handshake". Please advise. Thanks Rahul
-
Solace Python API v0.2.0 publicly released on PyPi 🎉
Now Available! The second and final round of our Python API early access is now available on Pypi for everyone in the Solace Community to use. Check it out here: https://pypi.org/project/solace-pubsubplus/ or use pip install solace-pubsubplus This release includes support for 1. Direct Messaging (from v0.1.0) 2. Guaranteed…
