activemq 参数修改

src/main/java/com/scbfkj/uni/process/ActiveMQ.java

@@ -21,8 +21,8 @@ public class ActiveMQ {
     private final ObjectMapper mapper = new ObjectMapper();
 
     public List<String> receptionMessage(
-            String host, String username, String password, String virtualHost, String queueName, Long receiveTimeout, Long pollSize, Long retry) throws JMSException {
-        JmsTemplate template = getJmsTemplate(host, username, password, virtualHost);
+            String host, String username, String password, String queueName, Long receiveTimeout, Long pollSize, Long retry) throws JMSException {
+        JmsTemplate template = getJmsTemplate(host, username, password);
 
 
         jmsTemplate.setReceiveTimeout(receiveTimeout);
@@ -67,11 +67,11 @@ public class ActiveMQ {
 
 
     public void sendMessage(
-            String host, String username, String password, String virtualHost, String queueName,
+            String host, String username, String password,  String queueName,
             Object data
     ) throws JMSException {
 
-        JmsTemplate template = getJmsTemplate(host, username, password, virtualHost);
+        JmsTemplate template = getJmsTemplate(host, username, password);
 
         try {
             if (data instanceof Object[] datas) {
@@ -111,7 +111,7 @@ public class ActiveMQ {
     }
 
 
-    private jakarta.jms.ConnectionFactory createConnectionFactory(String host, String username, String password, String virtualHost) {
+    private jakarta.jms.ConnectionFactory createConnectionFactory(String host, String username, String password) {
         ActiveMQJMSConnectionFactory connectionFactory = new ActiveMQJMSConnectionFactory(host, username, password);
 
         return connectionFactory;
@@ -125,9 +125,9 @@ public class ActiveMQ {
     }
 
 
-    private JmsTemplate getJmsTemplate(String host, String username, String password, String virtualHost) throws JMSException {
+    private JmsTemplate getJmsTemplate(String host, String username, String password) throws JMSException {
         if (jmsTemplate == null) {
-            jakarta.jms.ConnectionFactory connectionFactory = createConnectionFactory(host, username, password, virtualHost);
+            jakarta.jms.ConnectionFactory connectionFactory = createConnectionFactory(host, username, password);
             CachingConnectionFactory cachingConnectionFactory = createCachingConnectionFactory(connectionFactory);
             jmsTemplate = createJmsTemplate(cachingConnectionFactory);
         }