SolConnectionFactory stuck on javax

Hi @marc ,

Any progress since your last comment?
Is there any concrete plan for a permanent solution for SolConnectionFactory that uses jakarta?

Hi Team,

i am new to solace system, as part of project requirement i want to migrate from javax.jms.ConnectionFactory to jakarta.jms.ConnectionFactory it means Springboot 2 to Springboot3. while searching in community forums found this url suits to me.

https://github.com/SolaceProducts/solace-spring-boot/tree/master/solace-spring-boot-samples/solace-jms-sample-app

could anyone please help me how to run the above git project to test locally.

Here i require two things help.

1. while running application getting below error

Parameter 0 of method cFactory in com.example.demo.ConsumerConfiguration required a bean of type 'jakarta.jms.ConnectionFactory' that could not be found.

package com.example.demo;

import java.util.Iterator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

@SpringBootApplication
public class DemoApplication {

public static void main(String[] args) {

    SpringApplication.run(DemoApplication.class, args);

}


@Service

static class MessageProducer implements CommandLineRunner {


    private static final Logger logger = LoggerFactory.getLogger(MessageProducer.class);


    @Autowired

    private JmsTemplate jmsTemplate;


    // Examples of other options to get JmsTemplate in a cloud environment with possibly multiple providers available:

    // Use this to access JmsTemplate of the first service found or look up a specific one by

    // SolaceServiceCredentials

    // @Autowired private SpringSolJmsConnectionFactoryCloudFactory springSolJmsConnectionFactoryCloudFactory;

    // @Autowired private SolaceServiceCredentials solaceServiceCredentials;

    // For backwards compatibility:

    // @Autowired(required=false) private SolaceMessagingInfo solaceMessagingInfo;


    @Value("${solace.jms.demoQueueName}")

    private String queueName;


    public void run(String... strings) throws Exception {

        String msg = "Hello World";

        logger.info("============= Sending " + msg);

        this.jmsTemplate.convertAndSend(queueName, msg);

        logger.info("Producer produces the message");

    }

}


@Component

static class MessageHandler {


    private static final Logger logger = LoggerFactory.getLogger(MessageHandler.class);


    // Retrieve the name of the queue from the application.properties file

    @JmsListener(destination = "${solace.jms.demoQueueName}", containerFactory = "cFactory", concurrency = "2")

    public void processMsg(Message<?> msg) {

    	StringBuffer msgAsStr = new StringBuffer("============= Received \nHeaders:");

    	MessageHeaders hdrs = msg.getHeaders();

    	msgAsStr.append("\nUUID: "+hdrs.getId());

    	msgAsStr.append("\nTimestamp: "+hdrs.getTimestamp());

    	Iterator<String> keyIter = hdrs.keySet().iterator();

    	while (keyIter.hasNext()) {

    		String key = keyIter.next();

        	msgAsStr.append("\n"+key+": "+hdrs.get(key));

    	}

    	msgAsStr.append("\nPayload: "+msg.getPayload());

        logger.info(msgAsStr.toString());

    }

}

}

package com.example.demo;

import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.io.UnsupportedEncodingException;

import jakarta.jms.ConnectionFactory;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.stereotype.Service;
import org.springframework.util.ErrorHandler;

@EnableJms
@Configuration
public class ConsumerConfiguration {

private static final Logger logger = LoggerFactory.getLogger(ConsumerConfiguration.class);


// Example configuration of the ConnectionFactory: we instantiate it here ourselves and set an error handler

@Bean

public DefaultJmsListenerContainerFactory cFactory(ConnectionFactory connectionFactory, DemoErrorHandler errorHandler) {

    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();

    factory.setConnectionFactory(connectionFactory);

    factory.setErrorHandler(errorHandler);

    return factory;

}


@Service

public class DemoErrorHandler implements ErrorHandler{   


    public void handleError(Throwable t) {

    	ByteArrayOutputStream os = new ByteArrayOutputStream();

    	PrintStream ps = new PrintStream(os);

    	t.printStackTrace(ps);

    	try {

			String output = os.toString("UTF8");

            logger.error("============= Error processing message: " + t.getMessage()+"\n"+output);

		} catch (UnsupportedEncodingException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}


    }

}

}

2. Using this below properties in application.properties but i could not able to test publisher and consumer messages.

solace.jms.host=tcp://192.168.133.64:55555
solace.jms.msgVpn=default
solace.jms.clientUsername=default
solace.jms.clientPassword=default

solace.jms.apiProperties.Solace_JMS_DynamicDurables=true

solace.jms.demoQueueName=tutorial/queue

logging.level.com.solacesystems=INFO