-
Java API: Working with the Topic String
Hello together, we are currently starting with Solace development and want to build different use cases. First we created a topic hierarchy, where for example a source systems stores different data parts in the topic string like: ${sourceSystem}/${stage}/${businessObject}/${objectId} Now we want to extract different parts…
-
Solace + protobuf in Android application
Hi everyone! I'm absolutely new in Solace, so I would you to help me: my app has to communicate with Solace using protobuf models. Can you help, what to start with?
-
Attach protobuf message to solClient_msg_createBinaryAttachmentStream
Hi everyone! Would you be so kind to tell me, how to attach GPBMessage to Solace message? I'm using solClient_msg_createBinaryAttachmentStream (C/iOS API) function to send a message, so my question is how to serialize it to needed type?
-
@PollableBean for Reactive Suppliers in Spring Cloud Stream
Supplier beans, or functions that only publish messages in Spring Cloud Stream, are a bit special in that they aren't triggered by the receiving of events like Function or Consumer beans. This means that you often need a way to trigger them to be executed periodically. For imperative functions the framework by default…
-
How to connect to Solace broker using truststore credentials using Python
No formatter is installed for the format not-found
-
New Spring Cloud Stream Dynamic Topic Publish Sample!
Heads up for everyone using Spring Cloud Stream I created a new sample that shows how to publish to dynamic topics! I'll be creating a tutorial or blog at some point to add more explanation, but for now you can check out the code on github: * DynamicDestinationProcessor.java * application.yml Note that this is already…
-
Solace + protobuf in iOS application
Hi everyone! I'm absolutely new in Solace, so I would you to help me: my app has to communicate with Solace using protobuf models. Can you help, what to start with?
-
Writing to Solace with Spark
i have a spark dataframe and i want to write it to solace i.e. i want to send the rows of dataframe as events to solace(publishing basically) in a distributed way . like spark to kafka.
-
Programmatically get admin info
Hi - is there a way to programmatically get admin info? And is there a special permissioned rolee you would need for read only access to admin stuff? What I'm particularly interested in is finding out which clients are connected and what subscriptions they have. My Ops team does not let the Dev team have access to the…
-
Topic names in Queues
Publisher publishing to topic, which is mapped to a persistent queue for consumer. e.g publisher1/A/B/C ==> publisher1_queue(topic subscription publisher1/>) Is there a way to identify the topic name (pulisher1/A/B/C) by consumer who is subscribing to publisher1_queue ?
-
How can Message Eliding applied on Market data use case?
we would like to migrate our application to use solace for the market data updates I have read the document and find it very interesting as it provides Message Eliding. Also, it states that it is suitable for streaming market data to clients that do not need every update. let's say we have 10000 stocks need to publish if…
-
getting error trying to integrate Solace with Mulesoft using Solace JMS feature.
I have set all the properties required for the integration. But still I am getting below error ** Cannot instantiate class: com.solacesystems.jndi.SolJNDIInitialContextFactory java.lang.RuntimeException: org.mule.runtime.api.lifecycle.InitialisationException: org.mule.runtime.api.lifecycle.InitialisationException: Cannot…
-
Solace Oauth
We are trying to connect to an Oauth provider to verify tokens sent in by the client. We have changed several parameters and can not get passed this one error. C:\Users\ABC\Desktop\Solace API\solace-samples-mqtt\solace-samples-mqtt\build>staged\bin\topicPublisher tcp://host:port 1ABC_USER01 1ABC_USER01 TopicPublisher…
-
Solace + Axway | Part 5 - Transforming to Streaming APIs
The final installation of our Solace and Axway integration series is here! In this episode we take a request/response API and transform it into a realtime streaming API using our AMPLIFY Streams v2 in tech preview. Check out how we take the standard API and enable web hooks into the PubSub+ Event Broker.…
-
PubSub+ interface for kdb+
Hi everyone, Kx just released Solace PubSub+ API for kdb+. It is a product of close collaboration between Solace and Kx and we are excited to have you try it! Here are just some of the ways PubSub+ can be of use to kdb+ devs: * efficiently distribute and consume data via pub/sub model, * usage of open APIs and protocols to…
-
Solace and Axway iPaaS - Integration Series Part 4
Hey Solace community - I am back with part 4 of my blog series. In it, I explore using the Axway iPaaS, which we call Integration Builder, and the Service Now REST APIs to build a real time stream of new Incidents into the Solace PubSub+ Event Broker. Check it out and let me know if you have any questions!…
-
connect solace to kafka (not confluent)
Hi, I got solace pub/sub running locally. I can publish to a queue under a topic and consume from it via a subscription. I also have kafka/zookeeper running under WSL. I am trying to connect solace to standalone kafka by following Heinz Schaffner's video:…
-
Solace and Axway AMPLIFY API Management (APIM) via JMS - Part 3
Hey Solace users! Today we explore integration via the JMS Client in part three of our blog. Come check it out, and join us on our journey. https://devblog.axway.com/apis/axway-apim-solace-mq/
-
Solace and Axway AMPLIFY API Management (APIM) and Application Integration - Part 2
In part 2 of my blog series I explore integrating the Solace PubSub+ platform REST Client with our API Gateway. The policy we create can grab any context (message content, headers, IPs, cert attributes, etc.) and either directly use or map them to a topic to integrate with the Solace Event Broker. This could then be used…
-
Solace and Axway AMPLIFY API Management (APIM) and Application Integration - Part 1
Solace and Axway are working together to bring solutions to our customers around the globe. Evolving to an Event Driven architecture can have great benefits to your enterprise, but modernizing your enterprise architecture to embrace this disruptive transformation can be tough. Working together, Axway can enable this…
-
Solace SCSt Binder now added by start.spring.io!
Hey Solace developers, I know a bunch of you are using Spring Boot to develop Microservices. I wanted to give you all a heads up that start.spring.io now automatically adds the Solace Spring Cloud Stream Starter for you when you choose Solace PubSub+ and Cloud Stream dependencies. Go check it out! Learn more about How…
-
Subscriber not sending ack after DirectTransport set to False in CF
Hi, Our subscriber was connected directly to topic and receiving messages. We have seen loss of messages so disabled DirectTransport in CF to create non-durable topic-endpoint. Now, we don't see message get delivered by subscriber and all spooled in non-durable. ACK window size getting reduced and it become zero. Do we…
-
Configuring PubSub+ Services for HIPAA Compliance
Hey all, I recently authored a blog post as a collaborative venture between Ippon Technologies and Solace. The post is about HIPAA compliance on PubSub+ services and how you can configure your services for this kind of compliance. I would love any feedback or thoughts on this! https://blog.ippon.tech/hipaa-compliant/
-
.NET API to consume JMS?
I've been tasked with consuming messages from an established JMS. The sample code provided to me uses the Solace libraries. I'm more comfortable with C# than Java, so I'd prefer to use the .NET messaging API, if possible. Can I use the Solace .NET API to subscribe to the JMS queue and consume messages? I downloaded the…
-
How-to view payloads (Solace-Boomi)
Hi, It appears that you can't do this using the current web-based Solace Cloud interface. So, we're looking for a solution to view the payload of messages. Use case: copy/paste payloads from Solace queues into Boomi processes (manual unit test) to analyze production issues.
-
partition and offset
is there any spring samples which deal with partition , offset and grouping message concept in solace?
-
How to clear KA timer timeout issue
Hi, we are using solace as JMS channel in the TIBCO BE, when running in the engine in the cache mode , am getting below error as: com.solacesystems.jcsmp.protocol.impl.KeepaliveTimeoutHandler] Sending keepalive message (1/3) 2020 Feb 07 14:23:30:433 GMT +5 roms_inference Debug [Context_3_ReactorThread] -…
-
concurrent connection
Does anyone have idea about below error while trying to enable concurrent connection ?.. am i doing wrong in format what i put in values. Config:- solace.jms.message.consumer.concurrency.value=1-2 code:- listenerFactory.setConcurrency("${solace.jms.message.consumer.concurrency.value}"); Error:-…
-
JMSX_GROUP_SEQ exception: java.lang.NumberFormatException: JMSXGroupSeq is null
I ran into a issue where a message posted to a solace queue is not written in the logs table in the cache mode in TIBCO BE but in the normal mode am able to see logs. Attached the logs as a file. Please help me to understand the difference of them.
-
Spring Cloud Stream and Solace Bindings
I am trying to use Spring Cloud Stream bindings with spring-cloud-starter-stream-solace but encountering issues with the set up / configuration. I have created a durable queue Q.MYQUEUE which is mapped to a Topic /mytopic/topic1. It seems that the SolaceQueueProvisioner tries to create a new queue and gets a "Router does…
