-
Max transacted sessions exceeded (503) error - PubSub+ Event Broker and Camel Solace component issue
Our team is currently working on a proof of concept with Apache Camel to split a file and publish the events to a Solace queue (PubSub+ Event Broker). Unfortunately, we are experiencing a persistent issue from the consuming route where, after a few minutes of consuming messages using the Solace Camel component, we start to…
-
Solace with multi threading environment
How to use Solace in a multithreading environment, similar to kafka consumers with multiple partitions.
-
Increase Single Message Maximum Size Limit of Direct Messages in localhost
Hello everyone, I am using the Solace localhost (PubSub+ standard edition) The current maximum single message size limit for direct messages is 10GB. I need a limit of at least 30GB and above for Direct messages in the localhost. Is there any way to increase this limit? Thanks in advance!
-
Debugging replay log issues
I am trying to debug replay in Solace. I see the messages in the internal replay queues, but when I tried replay on a new queue with subscriptions to the same topic, messages are not being processed. The queue is showing "Replay State" of "Active", but nothing is being replayed. Even the live feed is not going to the new…
-
PubSub+ Messaging API for Java releases
The following API has been released and available for download: * PubSub+ Messaging API for Java 1.0.0 Release Summary This is the initial release of the PubSub+ Messaging API for Java. Solace created this API to modernize our JCSMP API. This is a separate standalone API which provides modern interfaces, patterns and…
-
solace broker WSS connection issue
WSS connection is not getting established for solace. Neither with/out corporate vpn.
-
Try-Me seems to send message as byte[] array and not text
Hi, Using the the try-me functionality of the Solace Cloud Console to publish a message. The problem is that it seems to sends the message as byte array while my consumer code expects it to be a string. I don't want to change the consumer code but rather instruct Try-Me to send message as text and receive it as is. Is it…
-
Python - Additional properties for with_missing_resources_creation_strategy()
Hi, As a python subscriber to an external broker, we are only limited to create Durable Exclusive queue via SMF Api. Since there's an existing method prior to starting the receiver, with_missing_resources_creation_strategy(), by default its endpoint created on a permission for that queue is Delete. However, it is required…
-
Python - publish and subscribe message with message in the Content and not in the Attachment
In our current use case we will be expecting published messages to be stored in the Attachment or in Content from our external broker. Our python subscriber currently can read published messages via get_payload_as_string() or get_payload_as_bytes().decode("utf-8"). 1. How can we publish a message via python and stored as a…
-
JMS API connection factory route to different VPN
I don't see a set target VPN name, while creating the connection factory, so after the connection factory lookup the messages are going to the same VPN where the lookup is done, but I want to redirect the messages to different VPN. is it possible? It is like routing to different VPN for the actual data, and all the clients…
-
Azure Event Bus, RabbitMQ and PUBSUB
Hello still very new to Solace and PUBSUB. I have a Azure Microservice project using RabbitMQ as my event bus. Does Solace have its own preferred event bus?
-
Applying backpressure to a flow by blocking in the MessageEventHandler
I have a few days of free time and so I am developing a new branch of my Solace subscriber wrapper library. I thought I'd play with exposing the message stream as an IAsyncEnumerable. I decided to use a System.Threading.Channels.Channel with a bounded capacity for this. The idea is to (usually) quickly let the message…