-
unSubscribe to a solcache topic
Currently we use the following code to subscribe to a solcache topic: cacheSession.sendCacheRequest(Long.valueOf(10011l), "my/topic", true, CacheLiveDataAction.FLOW_THRU, new CacheRequestListener() { @Override public void onException(Long arg0, Topic arg1, JCSMPException arg2) { LOG.error("Consumer Received exception for…
-
onException in XMLMessageListener for which endPoint?
protected XMLMessageListener getXMLMsgListener() { return new XMLMessageListener() { @Override public void onException(JCSMPException arg0) { ** // Which topic is this for?** } @Override public void onReceive(BytesXMLMessage msg) { // normal message } }; } Is there any way to know which topic or queue onException got…
-
Possible to recover deleted messages??
Hi Team, Is it possible to recover the deleted messages in Queue level.
-
Message Count
Hi Everyone, Is there a way we can check the number of messages moved from a queue to Dead Message Queue ? A script which will run on daily basis with the count on number of messages moved from a queue to Dead Message queue.
-
Delete old messages on Solace
Background: For efficiency, when the router needs to store messages for slow or offline consumers, it writes groups of messages to the disk into a single (spool) file. The spool file may contain messages from multiple queues and must remain on the disk until all of the messages are consumed or deleted from the various…
-
OutOfMemoryError: parsing SMF Message (message too big): GC overhead limit exceeded
Hi, We are using Solace JMS to read data from JMS Queues and we are constantly seeing the following Error and it is bringing down the client We are running the java app with JVM Args -Xms2048m and -Xmx12288m Seems like there is a resource leak some where in the code. Thanks Sateesh
-
Problem connecting Solace broker to PubSub Monitor from RTView
Hi Guys, Have recently started working in Solace. We were trying to setup RTView monitoring for Solace. When we add Solace as standalone or HA pair, it keeps showing broker as disconnected. I have tried adding the trust store in the property files as well, but to no luck. Can anyone suggest, what am I missing here? I have…
-
Solace with Couchbase
Hi, I'm looking forward to developing a Solace - Couchbase connector for both Source/Sink types. My primary goal to post here is to have some guide/ideas on how do we monitor/configure the connector from Solace Console? Current Solace - Kafka connect is exposed at Kafka's side (uses Kafka Config) and ELK is looking at…
-
Moving Message VPN Configurations Between Software Instances
I have created VPN on one software Instance. Now I need the same configuration on another software instance. I did below: * create username sftp password **** filetransfer. ERROR: Could not read from `/cliscripts/sample_vpn.cli': Permission deniedCommand Failed
-
JCSMPXMLMessageProducer - handling unsolicited CloseFlow exception from appliance
What is the recommended approach for handling com.solacesystems.jcsmp.JCSMPTransportException: Received unsolicited CloseFlow for producer (503:Service Unavailable)? I have infinite reconnect retries configured in channel properties so was expecting reconnection to occur when the appliance came back up, but this doesn't…
-
receiving flow events in JMS
We use FlowEventHandler to confirm if we are successfully subscribed to a queue.(We use these for Fault tolerance). Is there a way to get these events in JMS ? public class CustomFlowEventHandler implements FlowEventHandler {public void handleEvent(Object o, FlowEventArgs flowEventArgs) { if(flowEventArgs.getEvent() ==…
-
Messages sent by Spring JmsTemplate not being received by normal JCSMP subscriber
I am able to successfully send and receive topic messages via Spring JMS but the messages are not being received by a normal Topic subscriber. My jms code for sending and receiving is below: @Autowired private JmsTemplate jmsTemplate; public void run(String... strings) throws Exception { for( int i = 0 ; i < 100; i++) {…
-
Solace browser code for java
Hi Can you please share some sample java code for browsing messages from solace queue created on Solace software instance.
-
Solace Client running out of memory with multiple consumers
Hi, We are using Solace JMS to read the Data from a JMS Queue and in order to keep up with the rate at which data is produced we are using 50 Consumers in worker threads and this is causing OutoFMemory Issue. Looks like as soon as we are creating the session and connection it is getting disconnected and the client/consumer…
-
Topic Endpoint Replay
Can some one provide me java sample to Replay Topic Endpoint ?
-
javax.naming.NamingException: JNDI lookup failed. Timeout happened when reading response from the r
Hi, We are using a Solace Client and able to connect to Solace JMS Queue and we started seeing the following Error all of a sudden. We didn't have this Issue for the past few months. This is happening when we try to create jmsConnection at private void init() throws JMSException, NamingException { jndiContext = new…
-
Default Admin account login for PubSub+ AWS AMI
Just curious, what is the admin password for a new AMI deployed on AWS's EC2 instance? I'm trying to login as an admin user via the web server hosted on the AMI as outlined here: https://docs.solace.com/Solace-PubSub-Manager/PubSub-Manager-Overview.htm I cannot login as admin without a password. Is there a default I can…
-
PubSub+ is on start.spring.io
I wanted to share some exciting news - Solace PubSub+ is now an option on the Spring Initializr hosted at https://start.spring.io/! Spring Initializr allows developers to generate Spring Boot projects pre-populated with the dependencies they need to get started quickly. Projects can be generated directly on the site, and…
-
Transacted sessions and order of messages
Hi all, I have a question. Suppose following publishing scenarios. All sessions are transacted, created from one particular connection, all steps are executed sequentially from one thread. Scenario 1: Session1.transaction1 --> 1,2 Session1.commit Session2.transaction2 --> 3,4 Session2.commit Session1.transaction3 --> 5,6…
-
Kafka Solace Sink Connector - Received record that had no data....discarded
Hello, I'm configuring a Solace Sink connector for Kafka with the following properties - "connector.class": "com.solace.sink.connector.SolaceSinkConnector","tasks.max": "2","topics": "nt_pop_fxrt_002_001","sol.host": "xx.xx.xxx.xxx","sol.username": "syskaf","sol.password": "","sol.vpn_name": "sysvpn16","sol.queue":…
-
XMLMessageProducer
Hello, does anyone knows how to use XMLMessageProducer with JCSMPStreamingPublishEventHandler? I tested sample code according to example on this page: https://docs.solace.com/API-Developer-Online-Ref-Documentation/java/com/solacesystems/jcsmp/XMLMessageProducer.html. Event responseReceived is returning message id different…
-
Provision your VPN with Infrastructure as Code manner
Hi Guys, I've built a tool for myself to easily backup and provision the VPN. The basic idea is to recursively GET all config from a VPN and write it down into a single JSON file, and you can do it reversely to provision the VPN (event after you modified the JSON file). Please access https://github.com/flyisland/sempv2 to…
-
Spring Cloud Stream Binder and Kerberos
I am looking to utilize the Spring Cloud Stream Binder for Solace PubSub and looking for examples of how to enable kerberos for the Solace binder connections. The examples all use username + password combinations. Any samples on how to initialize using kerberos configs?
-
Doing request/reply over Solace websockets using a custom replyTo Destination
If you have a requirement to using a custom replyTo destination for your request using the Solace Websockets API - follow along this tutorial - https://solace.com/samples/solace-samples-javascript/request-reply/ and make the following enhancements: Add the following function to the BasicRequestor.js - requestor.subscribe =…
-
Exclusive vs non-exclusive queus for FT and load balancing
I am trying to access this article but it keeps asking me to logon ... https://sftp.solace.com/Portal_Docs/#page/Solace_Messaging_Platform_Feature_Guide/09__Guaranteed_Messaging.html Is this information not freely available some where ? Otherwise how do I get credentials to login please? Thanks, Ali
-
Architecting multi queue / multi topic subscriber component
All, Need your input around what solace team advises in terms of best practices. Our Architecture: We have a java app/service that runs independently. It subscribes to multiple topics(both solcache and normal solace topics) and multiple queues. The multiple topics and queues are the messages published by other…
-
Boomi with Solace
I have a Boomi listener process which is listening to a solace queue. When ever the local atom is offline the listener is stopped. When the atom is online the listener is not running automatically.. Manually we have to deploy the listener only then the listener is connecting to solace.
-
Solace on Kubernetes
I'm using the following link to setup solace pubsub on k8s. https://github.com/SolaceProducts/solace-kubernetes-quickstart I'm trying to figure out the best way to setup persistent storage that can be used by the solace instance. Looking at the documentation I see that gke and aws are supported, however we are not using a…
-
Steps to Configure Delayed Message Consumption
Dear All, We want to introduce delay for the Messages, so we are using TTL value and Respect TTL property of a Queue, but unable to publish message using TIBCOBW Palettes since we are getting the below error. Problem is how to connect to the queue with Respect TTL parameter using TIBCO BW JMS Palette ? Thanks, Surya |
-
Does Solace cloud free trial version support SSL authentication?
Does Solace cloud free trial version support SSL authentication. If yes how to configure the same in both client side and on solace .?
