-
How to connect to pre-provisioned queue in solace using spring cloud stream ?
I am using @StreamListner, created input binding of type SubscribableChannel & trying to connect to a pre-provisioned queue and used similar configurations as suggested in previous comment but i am not able to bind consumer with queue . Getting error - "EL1008E: Property or field 'isAnonymous' cannot be found on object of…
-
Solace Jdk compatible matrix
Hi TEam, I am Java developer, I am looking for Solace Jdk-compatible matrix Which solace client jar is compatible with jdk version Thanks
-
Can't switch back to primary after server reboot.
We got server reboot and after that redundancy can not switch back to primary server. Somehow backup does not see it as ready . on primary No issues on network level.
-
Configure timeout for acknowledging message
Hello folks, Our webhooks take more time to send an acknowledged response back to the broker in qos1. Can we increase the timeout limit?
-
Exceeded Spool File Limit - Topic 'my/topic'
2023-03-29 02:44:14,962 [WARNING] solace.messaging.core: [_solace_session.py:942] [[SERVICE: 0x7f78a946fbb0] - [APP ID: app_cfdbe3dc-bd2a-4558-bbe2-3ac086e12db5]] {'caller_description': 'From service event callback', 'return_code': 'Unknown (503)', 'sub_code': 'SOLCLIENT_SUBCODE_DATA_OTHER', 'error_info_sub_code': 28,…
-
Synchronous publish in python ?
Hi all, what is the easiest, most clean code to publish ONE guaranteed message in python and only proceed after the ACK from the broker has arrived ? (I know, that this usage pattern is not performant, if I have many messages to publish. My use is different). Thank you Uli
-
How to get which broker is in control in HA pair (primary or backup) programmatically
How to get which broker is in control in HA pair (primary or backup) programmatically using SEMP API's or any other means but not using soladmin.
-
Consume existing Solace Queue using Python
Hi @marc @Tamimi we have existing solace queue with topic subscription enabled. need to listen and print message flowing to that queue. tried below code & got error, please help. persistent_receiver: PersistentMessageReceiver = messaging_service.create_persistent_message_receiver_builder()\…
-
New blog post for developers | How Does PubSub+ Cloud Help you Secure Your Data in the Cloud?
Preena Patel is a technical writer at Maropost. Read More › Leave your comments below. Source: https://solace.com/?p=49002
-
any restriction on the number of subscriptions topics per Non-durable Queue level for solace 3530
Hi All, Please confirm if there is any restriction on the number of subscriptions topics per Non-durable Queue level for solace appliance 3530?
-
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.
-
Failed to consume a message from destination Queue
I am using Spring cloud stream 2021.0.2 to consume messages from queue, when some messages are sent , I can see the message get spooled continously in the queue but It is not coming inside application and processed because of below exception. Please help org.springframework.messaging.MessagingException: Incorrect type…
-
Blocking send operation
Is there a way to invoke the send method in a blocking way? I would like to wait for the ack/nack/timeout, and continue only after I have the result. My current solution is a wrapper of the original send method, that keeps track of the sent messages and waits for the event from the event broker.
-
PubSub+ Messaging API for C & Go - Support for Apple's M-series Macs - Now Available
Hello everyone, We are excited to announce that the PubSub+ Messaging API for C (also known as CCSMP) and Go now officially support Mac M-series processors! This means that developers can now build applications that take full advantage of the power and efficiency of Apple's latest generation of processors using Solace's…
-
Read Consumer response object from broker in function app
Hi, We have an Event driven app which publish a payload to a topic in solace broker from Azure function app. There is a consumer which is of REST endpoint. Once the message is delivered and processed by consumer, they send a 200 OK with an object `{"message": "SUCCESS"}` . We want to read this response object from the…
-
Failed to consume a message from destination
I have a queue A which has many topic subscriptions. We run our microservice using Spring cloud stream stack. When queue A receives messages from different topics and processing them and all of a sudden, we see below exception stacktrace is continuously printing in the logs. I am not sure about the reason, while it is…
-
Python connect to solace Pubsub+ cloud
I have service created on https://console.solace.cloud/services on GCP platform and I am trying to connect to this service from python 3.7 using solace-pubsubplus pypi package: https://pypi.org/project/solace-pubsubplus/ Here is my code snippet for connecting to the service: _def publish(message): import…
-
Connecting Solace using Python with TLS
Hi @Tamimi , kindly help with below connection error whether certificates are not loading or need to do changes in code. from solace.messaging.messaging_service import MessagingService, RetryStrategy from solace.messaging.config.transport_security_strategy import TLS from solace.messaging.config.authentication_strategy…
-
MQTT QoS 1 Queue name
Hello @all, when creating a queue on the Solace Broker with an MQTT Client 3.1.1 and QoS 1 the queue name consists of two parts #mqtt/{client id}/{3 digits numeric id} For example: #mqtt/MQTTFOGarticleStore/351 #mqtt/MQTTFOGarticleStore/347 When connecting with the client the numeric id changes. Is there a way we can fix…
-
Spring Cloud Stream Batch Consumer and Batch Producer
Batch mode is true and batch size is 10. Still when we run the application with volumes of data, the batch size grows upto 75. Any suggestions on the below properties? Properties: spring.cloud.stream.bindings.receiveMessage-in-0.consumer.batch-mode=true…
-
How to use SDKPerf tool for connecting to VPN using certificate authentication
I have created a Message VPN, on which I have enabled certificate authentication. now I want to test the configuration using SDKperf tool, does anyone know how to do that.
-
What are the steps to enable client certificate authentication via GUI
I am trying to enable to Client certificate authentication via GUI on my VPN but I can't see the steps for GUI mode, they are only provided for command line.
-
Publish Confirmation when using batch publish of Spring Cloud Stream binder for Solace PubSub+
I was posed with the question of whether it would be possible to get publish confirmation with a Batch Publish operation when using Spring Cloud Stream binder for Solace PubSub+. The answer is Yes! Just that you would have to check on the correlation data in a separate thread. Here is a sample function, the last published…
-
What is the right way to get the size of a message in solace?
What is the right way to get the size of a message in solace using Java API? I have this handler and want to get the size of msg: public void onData(MapMessage msg) { } I tried this: java.nio.ByteBuffer buffer = msg.getAttachmentByteBuffer(); int size_rem = buffer.remaining(); And also since SDTMap does not seem to be…
-
What’s Next with Ed and Ali: Episode 3 – All about PubSub+ APIs
In this episode, PubSub+ product team leaders Ed and Ali take a look at latest open API support with demos of using the PubSub+ Event Broker v2 APIs for lifecycle management integration and a great demo using IntelliJ with PubSub+ Event Portal APIs. Wrapping it all up is a discussion of Partitioned Queues, Kafka…
-
Spring cloud Stream Solace Unit Test
Solace Spring Cloud BOM 2.4.0 Solace Spring Cloud Stream Starter 3.4.0 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream</artifactId> <type>test-jar</type> <scope>test</scope> <classifier>test-binder</classifier> </dependency> <!--…
-
SOLCLIENT_SUBCODE_DATA_OTHER - Exceeded Spool File Limit
"{'caller_description': 'From service event callback', 'return_code': 'Unknown (503)', 'sub_code': SOLCLIENT_SUBCODE_DATA_OTHER', 'error_info_sub_code': 28, 'error_info_contents': "Exceeded Spool File Limit - Topic 'my/topic'" Still haven't resolved this issue as the docs are quite ambiguous about this error code.…
-
Stateless Microservices: Implementing Delayed Redelivery and Timers - (Node.js / Typescript)
Hi, I am working on a new design for our Solace Consumer/Bridge here at CIBC and I stumbled upon a very interesting article by Steve Buchko that I would like to use to inspire my own design. https://solace.com/blog/stateless-microservices-example-delayed-delivery-queues/ In principle, I would like to implement this Solace…
-
Running Software Broker using Podman on MacOS (x86)
Here are the steps to get Solace Broker running using rootless podman. We will be using brew to install podman on the host. a) Update brew brew update b) Upgrade brew brew upgrade c) Install podman brew install podman d) Create and start your podman machine podman machine init --cpus=2 --disk-size=20 --memory=4096 -v…
-
New blog post for developers | Monthly Solace Developer Community Highlights | March 2023
Below are some of the highlights in the Solace Developer Community in March: Read More › Leave your comments below. Source: https://solace.com/?p=48655
