-
Disaster recovery setup
I am trying to enable Disaster recovery between 2 HA pairs. Is there a consolidated documentation of the steps to follow? I followed the default solace documentation, and there are lot of moving parts/configurations, and now my replication bridge is not coming up. I don't see anything in the logs to debug the problem.…
-
Solace with multi threading environment
How to use Solace in a multithreading environment, similar to kafka consumers with multiple partitions.
-
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…
-
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!
-
solace broker WSS connection issue
WSS connection is not getting established for solace. Neither with/out corporate vpn.
-
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…
-
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…
-
Transactional applications in event driven approach
I understand the benefits of event driven approach which is like decoupling the applications and making the integration seamless with more reliability but there is a bit of delay in as well with event driven more on the side for the call backs and so in case of an ecommerce application which has payment transaction…
-
SSL/TLS connection rejected by remote host
Below error is triggered and fills the log file event and system log files. Please assist what could be the issue. 2021-08-25T09:46:47.432+00:00 <local3.info> **** SOLACEINFO: SYSTEM: SYSTEM_SSL_CONNECTION_REJECTED: - - SSL Connection rejected: reason (Connection closed by remote host); connection to 127.0.0.1:8091 from…
-
Receiving Event Logs via the Message Broker
When receiving event logs with a consumer, there doesn't seem to be any message text/body. Does the message topic contain all of the available information, or am I missing something?
-
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…
-
Dealing with messages in Dead message Queue
Hi Team, How to process the messages in Dead msg queue and how long messages remain on solace queue?
-
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?
-
Integration Testing with Solace
All, I have a java based spring cloud stream application that publishes messages to solace topics based on an internal trigger. I am using StreamBridge to publish messages. I want to write integration test cases for it for which I need to bring up a solace server. Any idea on the best ways to do it? Thanks in advance!
-
TaskCompletionSource as CorrelationKey for guaranteed messages - safe async?
Suppose I wish to publish guaranteed messages, but I want to wrap the solace callback guts inside a library which is a little more modern - for example, using the TAP. Is there any reason why something like the following would be unsafe? For this example, assume send blocking is enabled (although I think this could be…
-
Latency test between 2 appliances in 2 Diff DC
Hi Team, Looking of suggestion to do a latency test across DC **solace connectivity **connected via Bridge component. Solace (DC 1) <> BRIDGE bi directional <> Solace (DC2) How can we use sdkperf in this case , where publisher and consumer not connected to same DC ? Any suggestion is very much appreciated!
-
Error creating consumers: intern error creating consumers (503: mac client exceeded for durable topi
Analysis: I have increased max bind count from 1 to 50!! Is it correct? Kindly help!!
-
Delete all subscriptions from a queue in one shot
Hello, Is there anyway to delete all subscriptions in one shot from a queue using Legacy SEMP and SEMP V2? @nram @Aaron Thank you
-
Solace/Boomi moves all messages to DMQ if a single message fails after x retries
It appears that our Solace test instance moves all messages to the DMQ if a single message fails after x retries. Example: Queue X contains 100 messages Queue X settings: retries = 3 Boomi listener retrieves 1 message from the queue, which fails. Then Boomi retries the messages 3 times (OK), but then Solace moves all 100…
-
FlowHandle received incoming message (flow stopped or duplicate received)
Hi All, When I try to configure Solace for multiple VPN connections, I am getting below exception while publishing message to ConsumerFlow. Please help. "FlowHandle received incoming message (flow stopped or duplicate received), ignoring. Could not reply for correlationId: 3926add4-4aab-4472-b7ab-4d460e0ecf30","exception"
-
Solace PubSub+ Messaging API for OpenMAMA releases
The following has been released and is available for download: * Solace PubSub+ Messaging API for OpenMAMA 7.4.3.9 Please refer to the product release notes for information on new features, changed functionality, resolved issues, known issues and upgrade considerations. Release Summary The following fix has been introduced…
-
FlowHandle received incoming message (flow stopped or duplicate received)
Hi All, When I try to configure Solace for multiple VPN connections, I am getting below exception while publishing message to ConsumerFlow. Please help. "FlowHandle received incoming message (flow stopped or duplicate received), ignoring. Could not reply for correlationId: 3926add4-4aab-4472-b7ab-4d460e0ecf30","exception"
-
Correct handling of keepalive with go-amqp
Hi Solace Community, as long as the SMF API for golang is not available, we would like to create a reference implementation using golang with AMQP and PubSub+. Instead of QPID, we want to use https://github.com/Azure/go-amqp, because it does not require C bindings and looks way more easy to handle. The example on github…
-
Configuring Solace with Ansible : ERROR! couldn't resolve module/action 'solace_client_username'
Hi there, I am trying to use Ansible to configure solace (create client usernames and acl-profles) however i get an Error (at least one right now). The error says: ERROR! couldn't resolve module/action 'solace_client_username'. This often indicates a misspelling, missing collection, or incorrect module path.The error…
-
measure size of queued messages - how identify how many messages >10k shipped ?
measure size of queued messages. How identify how many messages >10k shipped ? i only see the queue but not the size of message. show queue ...
-
Subscribing to EVENTS published by Broker
Under the reserved topics section of docs - have a question This is pretty close to tracking lifecycle changes of Broker managed objects as events at runtime, really great. However, I did not receive any events even with a wild-card subscription '#LOG/>' in 'try-me' tab on the PS+ manager tool. The doc says - "Subscribed…
-
Config-Sync not successful after failover to backup node
Hello All Recently we have issue on config-sync in Solace HA setup. solace usual setup with primary / backup / Monitor. there is no issue with Redundancy, when we move primary to backup. The same time Config-sync show down one of the environment. same setup with 5 set of solace HA was up and running no issue. except the…
-
SolAdmin releases
Version 8.16.0.3 This maintenance release of SolAdmin includes: * The Commons Collections component was updated to address CVE-2015-6420 and CVE-2017-15708 and internal test code that included a hard-coded secret was removed. (reference # SOL-38177) * SolAdmin now uses Pre-emptive Basic Negotiation when sending requests to…
