-
How to use Solace-Kafka-Connectors in a Kubernetes distributed environment
Hi, I'm trying to connect my solace broker, running in a kubernetes cluster on a cloud provider, with my kafka pods also running in kubernetes on another cloud provider. In order to do so (using the solace-kafka-connectors) do i need to create my own kafka image with the connectors already inside and configured? or is…
-
Tibco BusinessWorks 6.x integration with Solace
Hi, I learnt from the link (https://docs.solace.com/Developer-Tools/Integration-Guides/Solace-JMS-Integration-TIBCO-ActiveMatrix-BusinessWorks.pdf) that Solace can be integrated with Tibco BusinessWorks 5.x. But not able to find any materials on how to integrate Solace with Tibco BusinessWorks 6.x. Is there a way to…
-
Logstash input and output plugins for Solace
Hi everyone! Just a quick note to say that I've started writing some dedicated/native plugins for Logstash using JCSMP, both an input plugin (reads messages off Solace and injects into Logstash), and output plugin (takes Logstash events and publishes as Solace messages). Logstash has been around forever, and integrates…
-
Boomi Solace Connector: Send operation failed due to maximum size limit
Hi, I am using Boomi and Solace Connector. I am gtting information from Database and mapping to XML profile and trying to push xml to Solace queue (Send) operation. Just 2000 db records it was erroring as Error : [400] SEND's operation combined incoming documents exceed allowed size of [ 1048576 bytes ]. . Did we have any…
-
Not getting data from Queue while consumed using Spring Boot ,But Solace end its showing data sent
I am facing while consume(""q-51685-stavi-pymt-rtgs-outward") the data from Solace queue not getting any data , but in Solace its showing data consumed , its happening in System integration Testing. While publishing we are able to publish the data in 2 different topics to Solace. Already 2 days gone our solace team also…
-
Subscription concurrency to speed up data consumption
Hi, In solace I pre-configured a Non-exclusive queue and now trying to consume data in spring cloud steam app , by providing spring.cloud.stream.bindings.fn-name.consumer.concurrency=4 , In logs i can see it's trying to start four subscriber but all four are getting timed out. If we make this number as 1 or remove this…
-
BOOMI : Publish Events to PubSub+ with custom headers & Listen to events and get headers
I write this post to share how to do the following things in Boomi : * Publish a message to Solace with custom headers * Listen for message and get the headers, parsing the custom headers stored in "userProperties" header Boomi is an iPaaS solution (other well known iPaaS : TIBCO Cloud Integration, Mulesoft) You can read…
-
spring cloud stream
cloud: stream: bindings: inbound: destination: TestQueue group: perf concurrency: 2 I get 403 Permission Not allowed whenever i add a group name what is causing issue ? TcpClientChannel : Error Response (403) - Permission Not Allowed - Queue
-
Solace JMS Channel closing on it's own when running on a Kubernetes cluster (Spring Boot Autoconfig)
Log snippet: {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label": "Client-109: Connected to host 'orig=host:55555, scheme=tcp://, host=host, port=55555' (smfclient 109)"} {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label":"Client-109: Channel Closed (smfclient 109)"} It basically loops like…
-
In Spring cloud , i would like to read data from pre-define queue.
Currently spring cloud app will create the queue "scst/an/some randome-id/plain/myConsumer-in-0" at server startup (some thing similar), Since i already have a queue and queue has some persistence message so how to command spring cloud to use existing queue for subscriptions.
