Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-9239] jakarta.jms - activemq-console changes

This commit is contained in:
Matt Pavlovich 2023-03-30 11:30:49 -05:00
parent 867254a41c
commit b1de919bf4
14 changed files with 44 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-console/src/main/java/org/apache/activemq/console/CommandContext.java
View File

@ -20,7 +20,7 @@ import java.io.OutputStream;
import java.util.Collection;
import java.util.Map;
import javax.jms.Message;
import jakarta.jms.Message;
import javax.management.AttributeList;
import javax.management.ObjectInstance;
import javax.management.ObjectName;

6
activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java
View File

@ -22,9 +22,9 @@ import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import org.apache.activemq.ActiveMQConnectionFactory;

4
activemq-console/src/main/java/org/apache/activemq/console/command/AmqBrowseCommand.java
View File

@ -23,7 +23,7 @@ import java.util.List;
import java.util.Set;
import java.util.StringTokenizer;
import javax.jms.Destination;
import jakarta.jms.Destination;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
@ -47,7 +47,7 @@ public class AmqBrowseCommand extends AbstractAmqCommand {
" --amqurl <url> Set the broker URL to connect to. Default tcp://localhost:61616",
" --msgsel <msgsel1,msglsel2> Add to the search list messages matched by the query similar to",
" the messages selector format.",
" --factory <className> Load className as the javax.jms.ConnectionFactory to use for creating connections.",
" --factory <className> Load className as the jakarta.jms.ConnectionFactory to use for creating connections.",
" --passwordFactory <className> Load className as the org.apache.activemq.console.command.PasswordFactory",
" for retrieving the password from a keystore.",
" --user <username> Username to use for JMS connections.",

4
activemq-console/src/main/java/org/apache/activemq/console/command/ConsumerCommand.java
View File

@ -22,8 +22,8 @@ import org.apache.activemq.util.ConsumerThread;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.Connection;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.Session;
import java.util.List;
import java.util.concurrent.CountDownLatch;

4
activemq-console/src/main/java/org/apache/activemq/console/command/ProducerCommand.java
View File

@ -22,8 +22,8 @@ import org.apache.activemq.util.ProducerThread;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.Connection;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.Session;
import java.util.List;
import java.util.concurrent.CountDownLatch;

12
activemq-console/src/main/java/org/apache/activemq/console/filter/AmqMessagesQueryFilter.java
View File

@ -20,12 +20,12 @@ import java.net.URI;
import java.util.Collections;
import java.util.List;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.QueueBrowser;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.QueueBrowser;
import jakarta.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

4
activemq-console/src/main/java/org/apache/activemq/console/filter/MapTransformFilter.java
View File

@ -25,8 +25,8 @@ import java.util.Map;
import java.util.Properties;
import java.util.Arrays;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import jakarta.jms.DeliveryMode;
import jakarta.jms.JMSException;
import javax.management.Attribute;
import javax.management.AttributeList;
import javax.management.ObjectInstance;

2
activemq-console/src/main/java/org/apache/activemq/console/formatter/CommandShellOutputFormatter.java
View File

@ -23,7 +23,7 @@ import java.util.Iterator;
import java.util.Map;
import java.util.Arrays;
import javax.jms.Message;
import jakarta.jms.Message;
import javax.management.Attribute;
import javax.management.AttributeList;
import javax.management.ObjectInstance;

2
activemq-console/src/main/java/org/apache/activemq/console/formatter/OutputFormatter.java
View File

@ -20,7 +20,7 @@ import java.io.OutputStream;
import java.util.Collection;
import java.util.Map;
import javax.jms.Message;
import jakarta.jms.Message;
import javax.management.AttributeList;
import javax.management.ObjectInstance;
import javax.management.ObjectName;

4
activemq-console/src/main/java/org/apache/activemq/console/util/AmqMessagesUtil.java
View File

@ -20,8 +20,8 @@ import java.net.URI;
import java.util.List;
import java.util.Set;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.Destination;
import org.apache.activemq.console.filter.AmqMessagesQueryFilter;
import org.apache.activemq.console.filter.GroupPropertiesViewFilter;

14
activemq-console/src/test/java/org/apache/activemq/console/PurgeCommandTest.java
View File

@ -23,13 +23,13 @@ import java.io.ByteArrayOutputStream;
import java.util.Arrays;
import java.util.LinkedList;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageProducer;
import jakarta.jms.Queue;
import jakarta.jms.Session;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectName;

2
activemq-console/src/test/java/org/apache/activemq/console/QueryCommandTest.java
View File

@ -19,7 +19,7 @@ package org.apache.activemq.console;
import java.io.ByteArrayOutputStream;
import java.util.Arrays;
import java.util.LinkedList;
import javax.jms.Connection;
import jakarta.jms.Connection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.command.ActiveMQDestination;

14
activemq-console/src/test/java/org/apache/activemq/simple/Consumer.java
View File

@ -26,13 +26,13 @@
*/
package org.apache.activemq.simple;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

14
activemq-console/src/test/java/org/apache/activemq/simple/Producer.java
View File

@ -25,13 +25,13 @@
*/
package org.apache.activemq.simple;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.MessageProducer;
import jakarta.jms.Session;
import jakarta.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;