-
Does solace topic support XA Transaction.
Am successfully tested XA Transaction when sending message to a queue directly. But when publishing msg (with XA transaction only) to a topic which is subscribed a queue, behavior is different. So does solace topic support XA Transaction ? or its there only for queue ( like when sending msg directly to queue)
-
How to connect XASession of Solace JMS API with Weblogic Database XAConnection?
Hi Team, Am looking for a way to connect solace XASession with database XA connection (my datasource is on weblogic server) so that if the query execution fails, solace transaction should be rollback when db transaction.rollback is called; and same with commit statement. Or vice-versa - if solace transaction is rolled…
-
Can we copy files from Solace queue
We have a requirement to copy a csv file from Solace Queue to an Azure Data Lake location. I am new to Solace and I do not know if there are any existing services to directly copy a file from a queue instead of consuming the content of the file as a message and copying that. Please advise.
-
FlowId not matching with incoming message and silent ignoring.
Facing an issue with connecting to my OnPrem Solace server. The same issue is not seen on my local Solace using docker. I have created a Simple Spring Boot Application that produces a message on a topic and consumes the same. I am using the below version to achieve this. JDK 17 spring-boot-starter-parent: 3.2.5…
-
Issue in accessing the Solace Software Event Broker CLI
We are working on setting up the Solace Software Pub Sub + Event Broker of Standard Version 10.4.1.121 in lower environments. We are observing "Access Denied"" error when trying to login to the cli using the below command. podman exec -it solaceusqa1 /usr/sw/loads/currentload/bin/cli -A However, we are able to login to the…
-
Solace connectivity for Azure ADF
Hi Team, We have our data present in AWS Yugabyte. We are planning to use Solace for pub Sub. How we can move data to Azure Data Factory using Solace for pub Sub. Any expert please advice.
-
Visualizing of data inside Solace topic/Queue
Hi, We have a requirement to see what field values are specified in the given record sent to Solace. Is anyone aware of any tool/utility that provides data visualization? Thanks. Regards Sameer
-
Does Solace tibco EMS supports JavaRTO as consumer?
Hi Team, We are planning to migrate from TIBCO EMS to Solace. We have done some PoC and planning to Java RTO Messaging API. We have a use case where we need to sync data between Solace consumers and TIBCO Producers. We heard that Solace provides the connector for this but we are not sure if we can use it where the producer…
-
Encountered Error - Timed out waiting for credit to send Message
I using Camel AMQP client to receive messages from other EMS and publish to Solace EMS. However i encountered this error - "Timed out waiting for credit to send Message" if i set jms.sendTimeout=2000. 1) May i know how does broker issue credit to publisher? 2) Can I increase the credit at the EMS broker? at…
-
Showing exemplars on Prometheus
Hi All, I am trying to use prometheus to display data with exemplars to show traceID but I cannot seem to get it to display the exemplars I used this repo as a base and placed in prometheus and grafana tempo. #Docker Compose version: '3.5' networks: solace_msg_net: name: solace_msg_net external: false driver: bridge…
-
How to solve this error: Received disposition with role=receiver
I using AMQP Camel to read message from Queue A, add header to the message and send to topic B. There will be 200 message every 300 millisecond. Based on the log file, the JMS MessageConsumer closed every 1 seconds. I don't know why. Can someone give me hint how to prevent the MessageConsumer to close ? Camel Route…
-
MessagePublishReceiptListener is not getting the acknowledgement python API
class SolaceMessagePublishReceiptListener(MessagePublishReceiptListener): def __init__(self): self._publish_count = 0 @property def get_publish_count(self): return self._publish_count def on_publish_receipt(self, publish_receipt: 'PublishReceipt'): with lock: self._publish_count += 1 print(f"\tSOLACE -- \n", f"\tMessage:…
-
C# - Solace Queue Message not reading and missing sometime
I have referred sample code provided by the Solace team for implemented Pub/Sub Queue message (https://github.com/SolaceSamples/solace-samples-dotnet) Sample code is implemented part of Microsoft .Net 6 Worker service and scheduled to run every 30 mins. I am facing new issue and i really don't know what went wrong in my…
-
How does Queue or Topic Proxy differ from DestinationImpl?
In my previous post I am facing a class cast exception while writing the consumer code. java.lang.ClassCastException: com.solacesystems.jms.ra.outbound.QueueProxy cannot be cast to weblogic.jms.common.DestinationImplStack Trace for RuntimeException was:java.lang.ClassCastException:…
-
java.lang.ClassCastException: Solace QueueProxy cannot be cast to Weblogic DestinationImpl
Hey Guys, I was recently introduced to Solace and am trying to deploy a sample Pub/Sub application using JMS API on a local Weblogic server but ran into this class cast error which I cant seem to find a solution for. I have created a topic "MyTopic" which is subscribed by a queue, "MyQueue" and also configured the JNDI…
-
Unable to start the Solace pubsub in podman
I am trying to start the pusub in podman, but when I run the below command the container is in running state and I am unable to access the console in browser. Command: podman run -u 1000:1000 --ulimit nofile=524288:524288 -p 1943:1943 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env…
-
Golang Parallel For One Consumer?
How can I increase the number of connections for a consumer using pubsubplus-go-client? We pass a callback to ReceiveAsync for a consumer via PersistentMessageReceiver, but only one message is processed at a time.
-
Cleanup of Unused Queues
In an use-case like an mqtt client connects with CleanStart: No and Durable: Yes, the queue will be created and msgs are consumed as per the subscriptions. But when we restart the client, with a different session name will lead to creation of new queue. Now, both the old and new queues will have the same subscriptions.…
-
Message Spool Ingress Discard
May i know what is the cause for message spool ingress discards? How to prevent it? How to troubleshoot the issue?
-
SMF AD ack response error [condition = amqp:resource-limit-exceeded]
I have seen this error in logs. Can someone explains me when this error occurs and how to prevent it in future? I checked the event log of the solace software broker and found out there are warning messages — VPN_AD_MSG_SPOOL_QUOTA_EXCEED: test - Message VPN(1) test message spool quota (102400 KB) exceeded, messages…
-
Parsing characters from Binary data
Hi @marc @Aaron @all I am deserialising some stream of binary data using the payload format as — typedef struct { char messageType; // 'N' or 'G' ('N' – New Normal Order, 'G' – New Spread Order) long timestamp; // Numeric Time in nanoseconds from 01-Jan-1980 00:00:00 double orderID; // Numeric Day Unique Order Reference…
-
Binary to ASCII
Hi @marc @Aaron How do I convert the data received from queue(lvq) to ASCII or human readable format?
-
Sequence Convoy Pattern with Solace
Hi Team, In my landscape, 20+ applications are generating events that are consumed by about 50 applications. Each consumer needs to receive all the messages from the 20+ in the same order they are generated per customerID. Meaning, for customer/123 all events from 20+ should be convoyed in sequence for all consumers. Each…
-
JMSToolBox not showing messages greater than 4MB
We use JMSToolBox to browse the messages in Solace Queue since there is no built-in tool. We now faced strange behaviour likely caused by large message sizes. What happened: * We published messages >5 MB to Solace * We could see the messages in Solace Portal(message count increased) * When using JMSToolbox and looking into…
-
Release note / Change Logs for version 10.0.1.XX
May i know where to find changes log for version 10.0.1.XX ? I want to know whether there is any vulnerability patch happen in 10.0.1.XX
-
Will JCSMPInboundChannelAdapter have configurable shutdownInterruptThresholdInMillis?
Hello, we are experiencing an issue with graceful shutdown of an application. We are using spring cloud "com.solace.spring.cloud:spring-cloud-starter-stream-solace:4.1.0" There is no awaiting for the termination and messages finish in the error queue. Is there a better way to gracefully stop and resume? Will configuring…
-
Intermittent "Assured message delivery is not enabled on this channel" errors
Hi there, We've had this publisher app that sends events to topics other client apps in the firm are subscribed to using queues of their own, for years. Lately, though, we've started to notice these exceptions intermittently that we've encountered previously. The client profile has "Allow Guaranteed message send" enabled…
-
Can someone please help me to know How to generate the details mentioned below.
IP Address of the Solace messaging appliance in the form: [Protocol:]Host[:Port] (e.g. tcp:192.168.160.101:55555 ). * Client username and Message-vpn used by the sample application (e.g. browser_nse_dev) * Password for the Client username used by sample application (e.g. browser)
-
Publish unicode string using solclientjs
Hi Experts, I am trying to publish a non-ascii string to a solace topic using the solclientjs library in nodeJs, and consume the same using the golang solace messaging library, and vice-versa (i.e. golang to nodeJs). Example string: abc-nonascii_ãçï_স I understand I have three options to do this in solclientjs: as…
-
Solace Spring Cloud Stream Function (Processor pattern) with StreamBridge
Hi, I currently have a usecase wherein I have implemented a Processor pattern using the typical Bean Function<?,?> for my SCS application. I understand that a Processor pattern is a straightforward Input-Output Solace stream. But now I have an additional requirement that, within the processor, an arbitrary event message…
