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-client changes

This commit is contained in:
Matt Pavlovich 2023-03-30 11:28:48 -05:00
parent 770032d483
commit f022aeac58
117 changed files with 581 additions and 578 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-client-jakarta/pom.xml
View File

@ -26,6 +26,9 @@
<packaging>bundle</packaging>
<name>ActiveMQ :: Client Jakarta</name>
<description>Jakarta transition module for ActiveMQ Client implementation</description>
<properties>
<maven.javadoc.skip>true</maven.javadoc.skip>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.activemq</groupId>

2
activemq-client/src/main/grammar/SelectorParser.jj
View File

@ -53,7 +53,7 @@ package org.apache.activemq.selector;
import java.io.*;
import java.util.*;
import javax.jms.InvalidSelectorException;
import jakarta.jms.InvalidSelectorException;
import org.apache.activemq.filter.*;
import org.apache.activemq.filter.FunctionCallExpression.invalidFunctionExpressionException;

80
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -37,23 +37,23 @@ import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import javax.jms.Connection;
import javax.jms.ConnectionConsumer;
import javax.jms.ConnectionMetaData;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueSession;
import javax.jms.ServerSessionPool;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicSession;
import javax.jms.XAConnection;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionConsumer;
import jakarta.jms.ConnectionMetaData;
import jakarta.jms.Destination;
import jakarta.jms.ExceptionListener;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.JMSException;
import jakarta.jms.Queue;
import jakarta.jms.QueueConnection;
import jakarta.jms.QueueSession;
import jakarta.jms.ServerSessionPool;
import jakarta.jms.Session;
import jakarta.jms.Topic;
import jakarta.jms.TopicConnection;
import jakarta.jms.TopicSession;
import jakarta.jms.XAConnection;
import org.apache.activemq.advisory.DestinationSource;
import org.apache.activemq.blob.BlobTransferPolicy;
@ -436,9 +436,9 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* @param newClientID the unique client identifier
* @throws JMSException if the JMS provider fails to set the client ID for
* this connection due to some internal error.
* @throws javax.jms.InvalidClientIDException if the JMS client specifies an
* @throws jakarta.jms.InvalidClientIDException if the JMS client specifies an
* invalid or duplicate client ID.
* @throws javax.jms.IllegalStateException if the JMS client attempts to set
* @throws jakarta.jms.IllegalStateException if the JMS client attempts to set
* a connection's client ID at the wrong time or when it has
* been administratively configured.
*/
@ -474,7 +474,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* @return the connection metadata
* @throws JMSException if the JMS provider fails to get the connection
* metadata for this connection.
* @see javax.jms.ConnectionMetaData
* @see jakarta.jms.ConnectionMetaData
*/
@Override
public ConnectionMetaData getMetaData() throws JMSException {
@ -492,7 +492,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* this connection.
* @throws JMSException if the JMS provider fails to get the
* <CODE>ExceptionListener</CODE> for this connection.
* @see javax.jms.Connection#setExceptionListener(ExceptionListener)
* @see jakarta.jms.Connection#setExceptionListener(ExceptionListener)
*/
@Override
public ExceptionListener getExceptionListener() throws JMSException {
@ -560,7 +560,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
*
* @throws JMSException if the JMS provider fails to start message delivery
* due to some internal error.
* @see javax.jms.Connection#stop()
* @see jakarta.jms.Connection#stop()
*/
@Override
public void start() throws JMSException {
@ -603,7 +603,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
*
* @throws JMSException if the JMS provider fails to stop message delivery
* due to some internal error.
* @see javax.jms.Connection#start()
* @see jakarta.jms.Connection#start()
*/
@Override
public void stop() throws JMSException {
@ -799,11 +799,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* create a connection consumer due to some internal error
* or invalid arguments for <CODE>sessionPool</CODE> and
* <CODE>messageSelector</CODE>.
* @throws javax.jms.InvalidDestinationException if an invalid destination
* @throws jakarta.jms.InvalidDestinationException if an invalid destination
* is specified.
* @throws javax.jms.InvalidSelectorException if the message selector is
* @throws jakarta.jms.InvalidSelectorException if the message selector is
* invalid.
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
* @since 1.1
*/
@Override
@ -833,11 +833,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* create a connection consumer due to some internal error
* or invalid arguments for <CODE>sessionPool</CODE> and
* <CODE>messageSelector</CODE>.
* @throws javax.jms.InvalidDestinationException if an invalid destination
* @throws jakarta.jms.InvalidDestinationException if an invalid destination
* is specified.
* @throws javax.jms.InvalidSelectorException if the message selector is
* @throws jakarta.jms.InvalidSelectorException if the message selector is
* invalid.
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
* @since 1.1
*/
public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages,
@ -868,7 +868,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
/**
*
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
* @since 2.0
*/
@Override
@ -879,7 +879,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
/**
*
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
* @since 2.0
*/
@Override
@ -1214,11 +1214,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* to create a connection consumer due to some internal
* error or invalid arguments for <CODE>sessionPool</CODE>
* and <CODE>messageSelector</CODE>.
* @throws javax.jms.InvalidDestinationException if an invalid topic is
* @throws jakarta.jms.InvalidDestinationException if an invalid topic is
* specified.
* @throws javax.jms.InvalidSelectorException if the message selector is
* @throws jakarta.jms.InvalidSelectorException if the message selector is
* invalid.
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
*/
@Override
public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException {
@ -1243,11 +1243,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* to create a connection consumer due to some internal
* error or invalid arguments for <CODE>sessionPool</CODE>
* and <CODE>messageSelector</CODE>.
* @throws javax.jms.InvalidDestinationException if an invalid queue is
* @throws jakarta.jms.InvalidDestinationException if an invalid queue is
* specified.
* @throws javax.jms.InvalidSelectorException if the message selector is
* @throws jakarta.jms.InvalidSelectorException if the message selector is
* invalid.
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
*/
@Override
public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException {
@ -1272,11 +1272,11 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* create a connection consumer due to some internal error
* or invalid arguments for <CODE>sessionPool</CODE> and
* <CODE>messageSelector</CODE>.
* @throws javax.jms.InvalidDestinationException if an invalid destination
* @throws jakarta.jms.InvalidDestinationException if an invalid destination
* is specified.
* @throws javax.jms.InvalidSelectorException if the message selector is
* @throws jakarta.jms.InvalidSelectorException if the message selector is
* invalid.
* @see javax.jms.ConnectionConsumer
* @see jakarta.jms.ConnectionConsumer
* @since 1.1
*/
@Override

22
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionConsumer.java
View File

@ -19,12 +19,12 @@ package org.apache.activemq;
import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.ConnectionConsumer;
import javax.jms.IllegalStateException;
import javax.jms.JMSException;
import javax.jms.ServerSession;
import javax.jms.ServerSessionPool;
import javax.jms.Session;
import jakarta.jms.ConnectionConsumer;
import jakarta.jms.IllegalStateException;
import jakarta.jms.JMSException;
import jakarta.jms.ServerSession;
import jakarta.jms.ServerSessionPool;
import jakarta.jms.Session;
import org.apache.activemq.command.ConsumerInfo;
import org.apache.activemq.command.MessageDispatch;
@ -45,11 +45,11 @@ import org.apache.activemq.command.MessageDispatch;
* minimizes resource use at the expense of some serialization of message
* processing.
*
* @see javax.jms.Connection#createConnectionConsumer
* @see javax.jms.Connection#createDurableConnectionConsumer
* @see javax.jms.QueueConnection#createConnectionConsumer
* @see javax.jms.TopicConnection#createConnectionConsumer
* @see javax.jms.TopicConnection#createDurableConnectionConsumer
* @see jakarta.jms.Connection#createConnectionConsumer
* @see jakarta.jms.Connection#createDurableConnectionConsumer
* @see jakarta.jms.QueueConnection#createConnectionConsumer
* @see jakarta.jms.TopicConnection#createConnectionConsumer
* @see jakarta.jms.TopicConnection#createDurableConnectionConsumer
*/
public class ActiveMQConnectionConsumer implements ConnectionConsumer, ActiveMQDispatcher {

20
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
View File

@ -24,15 +24,15 @@ import java.security.PrivilegedAction;
import java.util.*;
import java.util.concurrent.RejectedExecutionHandler;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.ExceptionListener;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import jakarta.jms.Connection;
import jakarta.jms.ConnectionFactory;
import jakarta.jms.ExceptionListener;
import jakarta.jms.JMSContext;
import jakarta.jms.JMSException;
import jakarta.jms.QueueConnection;
import jakarta.jms.QueueConnectionFactory;
import jakarta.jms.TopicConnection;
import jakarta.jms.TopicConnectionFactory;
import javax.naming.Context;
import org.apache.activemq.blob.BlobTransferPolicy;
@ -57,7 +57,7 @@ import org.slf4j.LoggerFactory;
* QueueConnections and TopicConnections.
*
*
* @see javax.jms.ConnectionFactory
* @see jakarta.jms.ConnectionFactory
*/
public class ActiveMQConnectionFactory extends JNDIBaseStorable implements ConnectionFactory, QueueConnectionFactory, TopicConnectionFactory, StatsCapable, Cloneable {
private static final Logger LOG = LoggerFactory.getLogger(ActiveMQConnectionFactory.class);

2
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnectionMetaData.java
View File

@ -21,7 +21,7 @@ import java.util.Vector;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import javax.jms.ConnectionMetaData;
import jakarta.jms.ConnectionMetaData;
/**
* A <CODE>ConnectionMetaData</CODE> object provides information describing

12
activemq-client/src/main/java/org/apache/activemq/ActiveMQConsumer.java
View File

@ -16,12 +16,12 @@
*/
package org.apache.activemq;
import javax.jms.JMSConsumer;
import javax.jms.JMSException;
import javax.jms.JMSRuntimeException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import jakarta.jms.JMSConsumer;
import jakarta.jms.JMSException;
import jakarta.jms.JMSRuntimeException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import org.apache.activemq.util.JMSExceptionSupport;

44
activemq-client/src/main/java/org/apache/activemq/ActiveMQContext.java
View File

@ -20,27 +20,27 @@ import java.io.Serializable;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import javax.jms.BytesMessage;
import javax.jms.ConnectionMetaData;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.IllegalStateRuntimeException;
import javax.jms.JMSConsumer;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.JMSProducer;
import javax.jms.JMSRuntimeException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.Session;
import javax.jms.StreamMessage;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
import javax.jms.TextMessage;
import javax.jms.Topic;
import jakarta.jms.BytesMessage;
import jakarta.jms.ConnectionMetaData;
import jakarta.jms.Destination;
import jakarta.jms.ExceptionListener;
import jakarta.jms.IllegalStateRuntimeException;
import jakarta.jms.JMSConsumer;
import jakarta.jms.JMSContext;
import jakarta.jms.JMSException;
import jakarta.jms.JMSProducer;
import jakarta.jms.JMSRuntimeException;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.ObjectMessage;
import jakarta.jms.Queue;
import jakarta.jms.QueueBrowser;
import jakarta.jms.Session;
import jakarta.jms.StreamMessage;
import jakarta.jms.TemporaryQueue;
import jakarta.jms.TemporaryTopic;
import jakarta.jms.TextMessage;
import jakarta.jms.Topic;
import org.apache.activemq.util.JMSExceptionSupport;
@ -53,7 +53,7 @@ import org.apache.activemq.util.JMSExceptionSupport;
* single-threaded context for sending and receiving messages.
*
*
* @see javax.jms.JMSContext
* @see jakarta.jms.JMSContext
*/
public class ActiveMQContext implements JMSContext {

4
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageAuditNoSync.java
View File

@ -18,8 +18,8 @@ package org.apache.activemq;
import java.io.Serializable;
import javax.jms.JMSException;
import javax.jms.Message;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.command.MessageId;

26
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
View File

@ -30,13 +30,13 @@ import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.TransactionRolledBackException;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.TransactionRolledBackException;
import org.apache.activemq.blob.BlobDownloader;
import org.apache.activemq.command.ActiveMQBlobMessage;
@ -96,10 +96,10 @@ import org.slf4j.LoggerFactory;
* throw an exception.
*
*
* @see javax.jms.MessageConsumer
* @see javax.jms.QueueReceiver
* @see javax.jms.TopicSubscriber
* @see javax.jms.Session
* @see jakarta.jms.MessageConsumer
* @see jakarta.jms.QueueReceiver
* @see jakarta.jms.TopicSubscriber
* @see jakarta.jms.Session
*/
public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsCapable, ActiveMQDispatcher {
@ -415,7 +415,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
* set
* @throws JMSException if the JMS provider fails to get the message
* listener due to some internal error.
* @see javax.jms.MessageConsumer#setMessageListener(javax.jms.MessageListener)
* @see jakarta.jms.MessageConsumer#setMessageListener(jakarta.jms.MessageListener)
*/
@Override
public MessageListener getMessageListener() throws JMSException {
@ -436,7 +436,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
* @param listener the listener to which the messages are to be delivered
* @throws JMSException if the JMS provider fails to receive the next
* message due to some internal error.
* @see javax.jms.MessageConsumer#getMessageListener
* @see jakarta.jms.MessageConsumer#getMessageListener
*/
@Override
public void setMessageListener(MessageListener listener) throws JMSException {

22
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java
View File

@ -20,12 +20,12 @@ import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.atomic.AtomicLong;
import javax.jms.CompletionListener;
import javax.jms.Destination;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.JMSException;
import javax.jms.Message;
import jakarta.jms.CompletionListener;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ProducerAck;
@ -67,9 +67,9 @@ import org.slf4j.LoggerFactory;
* JMS API does not define the accuracy provided.
*
*
* @see javax.jms.TopicPublisher
* @see javax.jms.QueueSender
* @see javax.jms.Session#createProducer
* @see jakarta.jms.TopicPublisher
* @see jakarta.jms.QueueSender
* @see jakarta.jms.Session#createProducer
*/
public class ActiveMQMessageProducer extends ActiveMQMessageProducerSupport implements StatsCapable, Disposable {
@ -216,7 +216,7 @@ public class ActiveMQMessageProducer extends ActiveMQMessageProducerSupport impl
* specified.
* @throws InvalidDestinationException if a client uses this method with an
* invalid destination.
* @see javax.jms.Session#createProducer
* @see jakarta.jms.Session#createProducer
* @since 1.1
*/
@Override
@ -234,7 +234,7 @@ public class ActiveMQMessageProducer extends ActiveMQMessageProducerSupport impl
* specified.
* @throws InvalidDestinationException if a client uses this method with an
* invalid destination.
* @see javax.jms.Session#createProducer
* @see jakarta.jms.Session#createProducer
* @since 2.0
*/
@Override

88
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducerSupport.java
View File

@ -18,14 +18,14 @@ package org.apache.activemq;
import java.util.Set;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.IllegalStateException;
import javax.jms.IllegalStateRuntimeException;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageFormatRuntimeException;
import javax.jms.MessageProducer;
import jakarta.jms.DeliveryMode;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateException;
import jakarta.jms.IllegalStateRuntimeException;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageFormatRuntimeException;
import jakarta.jms.MessageProducer;
/**
* A useful base class for implementing a {@link MessageProducer}
@ -63,7 +63,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Gets the delivery delay value for this <CODE>MessageProducer</CODE>.
*
* @return the delivery delay for this messageProducer
* @throws javax.jms.JMSException if the JMS provider fails to determine if deliver delay is
* @throws jakarta.jms.JMSException if the JMS provider fails to determine if deliver delay is
* disabled due to some internal error.
*/
@Override
@ -87,7 +87,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Message IDs are enabled by default.
*
* @param disableMessageID indicates if message IDs are disabled
* @throws javax.jms.JMSException if the JMS provider fails to close the producer due to
* @throws jakarta.jms.JMSException if the JMS provider fails to close the producer due to
* some internal error.
*/
public void setDisableMessageID(boolean disableMessageID) throws JMSException {
@ -99,7 +99,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Gets an indication of whether message IDs are disabled.
*
* @return an indication of whether message IDs are disabled
* @throws javax.jms.JMSException if the JMS provider fails to determine if message IDs are
* @throws jakarta.jms.JMSException if the JMS provider fails to determine if message IDs are
* disabled due to some internal error.
*/
public boolean getDisableMessageID() throws JMSException {
@ -123,7 +123,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Message timestamps are enabled by default.
*
* @param disableMessageTimestamp indicates if message timestamps are disabled
* @throws javax.jms.JMSException if the JMS provider fails to close the producer due to
* @throws jakarta.jms.JMSException if the JMS provider fails to close the producer due to
* some internal error.
*/
public void setDisableMessageTimestamp(boolean disableMessageTimestamp) throws JMSException {
@ -135,7 +135,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Gets an indication of whether message timestamps are disabled.
*
* @return an indication of whether message timestamps are disabled
* @throws javax.jms.JMSException if the JMS provider fails to close the producer due to
* @throws jakarta.jms.JMSException if the JMS provider fails to close the producer due to
* some internal error.
*/
public boolean getDisableMessageTimestamp() throws JMSException {
@ -151,16 +151,16 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* @param newDeliveryMode the message delivery mode for this message producer; legal
* values are <code>DeliveryMode.NON_PERSISTENT</code> and
* <code>DeliveryMode.PERSISTENT</code>
* @throws javax.jms.JMSException if the JMS provider fails to set the delivery mode due to
* @throws jakarta.jms.JMSException if the JMS provider fails to set the delivery mode due to
* some internal error.
* @see javax.jms.MessageProducer#getDeliveryMode
* @see javax.jms.DeliveryMode#NON_PERSISTENT
* @see javax.jms.DeliveryMode#PERSISTENT
* @see javax.jms.Message#DEFAULT_DELIVERY_MODE
* @see jakarta.jms.MessageProducer#getDeliveryMode
* @see jakarta.jms.DeliveryMode#NON_PERSISTENT
* @see jakarta.jms.DeliveryMode#PERSISTENT
* @see jakarta.jms.Message#DEFAULT_DELIVERY_MODE
*/
public void setDeliveryMode(int newDeliveryMode) throws JMSException {
if (newDeliveryMode != DeliveryMode.PERSISTENT && newDeliveryMode != DeliveryMode.NON_PERSISTENT) {
throw new javax.jms.IllegalStateException("unknown delivery mode: " + newDeliveryMode);
throw new jakarta.jms.IllegalStateException("unknown delivery mode: " + newDeliveryMode);
}
checkClosed();
this.defaultDeliveryMode = newDeliveryMode;
@ -170,7 +170,7 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Gets the producer's default delivery mode.
*
* @return the message delivery mode for this message producer
* @throws javax.jms.JMSException if the JMS provider fails to close the producer due to
* @throws jakarta.jms.JMSException if the JMS provider fails to close the producer due to
* some internal error.
*/
public int getDeliveryMode() throws JMSException {
@ -188,10 +188,10 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
*
* @param newDefaultPriority the message priority for this message producer; must be a
* value between 0 and 9
* @throws javax.jms.JMSException if the JMS provider fails to set the delivery mode due to
* @throws jakarta.jms.JMSException if the JMS provider fails to set the delivery mode due to
* some internal error.
* @see javax.jms.MessageProducer#getPriority
* @see javax.jms.Message#DEFAULT_PRIORITY
* @see jakarta.jms.MessageProducer#getPriority
* @see jakarta.jms.Message#DEFAULT_PRIORITY
*/
public void setPriority(int newDefaultPriority) throws JMSException {
if (newDefaultPriority < 0 || newDefaultPriority > 9) {
@ -205,9 +205,9 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Gets the producer's default priority.
*
* @return the message priority for this message producer
* @throws javax.jms.JMSException if the JMS provider fails to close the producer due to
* @throws jakarta.jms.JMSException if the JMS provider fails to close the producer due to
* some internal error.
* @see javax.jms.MessageProducer#setPriority
* @see jakarta.jms.MessageProducer#setPriority
*/
public int getPriority() throws JMSException {
checkClosed();
@ -221,10 +221,10 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* Time to live is set to zero by default.
*
* @param timeToLive the message time to live in milliseconds; zero is unlimited
* @throws javax.jms.JMSException if the JMS provider fails to set the time to live due to
* @throws jakarta.jms.JMSException if the JMS provider fails to set the time to live due to
* some internal error.
* @see javax.jms.MessageProducer#getTimeToLive
* @see javax.jms.Message#DEFAULT_TIME_TO_LIVE
* @see jakarta.jms.MessageProducer#getTimeToLive
* @see jakarta.jms.Message#DEFAULT_TIME_TO_LIVE
*/
public void setTimeToLive(long timeToLive) throws JMSException {
if (timeToLive < 0L) {
@ -239,9 +239,9 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* that a produced message should be retained by the message system.
*
* @return the message time to live in milliseconds; zero is unlimited
* @throws javax.jms.JMSException if the JMS provider fails to get the time to live due to
* @throws jakarta.jms.JMSException if the JMS provider fails to get the time to live due to
* some internal error.
* @see javax.jms.MessageProducer#setTimeToLive
* @see jakarta.jms.MessageProducer#setTimeToLive
*/
public long getTimeToLive() throws JMSException {
checkClosed();
@ -253,17 +253,17 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* delivery mode, priority, and time to live.
*
* @param message the message to send
* @throws javax.jms.JMSException if the JMS provider fails to send the message due to some
* @throws jakarta.jms.JMSException if the JMS provider fails to send the message due to some
* internal error.
* @throws javax.jms.MessageFormatException if an invalid message is specified.
* @throws javax.jms.InvalidDestinationException if a client uses this method with a <CODE>
* @throws jakarta.jms.MessageFormatException if an invalid message is specified.
* @throws jakarta.jms.InvalidDestinationException if a client uses this method with a <CODE>
* MessageProducer</CODE> with an invalid destination.
* @throws UnsupportedOperationException
* if a client uses this method with a <CODE>
* MessageProducer</CODE> that did not specify a
* destination at creation time.
* @see javax.jms.Session#createProducer
* @see javax.jms.MessageProducer
* @see jakarta.jms.Session#createProducer
* @see jakarta.jms.MessageProducer
* @since 1.1
*/
public void send(Message message) throws JMSException {
@ -282,16 +282,16 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
* @param deliveryMode the delivery mode to use
* @param priority the priority for this message
* @param timeToLive the message's lifetime (in milliseconds)
* @throws javax.jms.JMSException if the JMS provider fails to send the message due to some
* @throws jakarta.jms.JMSException if the JMS provider fails to send the message due to some
* internal error.
* @throws javax.jms.MessageFormatException if an invalid message is specified.
* @throws javax.jms.InvalidDestinationException if a client uses this method with a <CODE>
* @throws jakarta.jms.MessageFormatException if an invalid message is specified.
* @throws jakarta.jms.InvalidDestinationException if a client uses this method with a <CODE>
* MessageProducer</CODE> with an invalid destination.
* @throws UnsupportedOperationException
* if a client uses this method with a <CODE>
* MessageProducer</CODE> that did not specify a
* destination at creation time.
* @see javax.jms.Session#createProducer
* @see jakarta.jms.Session#createProducer
* @since 1.1
*/
public void send(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException {
@ -314,16 +314,16 @@ public abstract class ActiveMQMessageProducerSupport implements MessageProducer,
*
* @param destination the destination to send this message to
* @param message the message to send
* @throws javax.jms.JMSException if the JMS provider fails to send the message due to some
* @throws jakarta.jms.JMSException if the JMS provider fails to send the message due to some
* internal error.
* @throws javax.jms.MessageFormatException if an invalid message is specified.
* @throws javax.jms.InvalidDestinationException if a client uses this method with an invalid destination.
* @throws jakarta.jms.MessageFormatException if an invalid message is specified.
* @throws jakarta.jms.InvalidDestinationException if a client uses this method with an invalid destination.
* @throws UnsupportedOperationException
* if a client uses this method with a <CODE>
* MessageProducer</CODE> that specified a destination at
* creation time.
* @see javax.jms.Session#createProducer
* @see javax.jms.MessageProducer
* @see jakarta.jms.Session#createProducer
* @see jakarta.jms.MessageProducer
*/
public void send(Destination destination, Message message) throws JMSException {
this.send(destination,

18
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java
View File

@ -21,15 +21,15 @@ import java.lang.reflect.Modifier;
import java.net.MalformedURLException;
import java.util.Enumeration;
import javax.jms.BytesMessage;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageEOFException;
import javax.jms.ObjectMessage;
import javax.jms.StreamMessage;
import javax.jms.TextMessage;
import jakarta.jms.BytesMessage;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.MessageEOFException;
import jakarta.jms.ObjectMessage;
import jakarta.jms.StreamMessage;
import jakarta.jms.TextMessage;
import org.apache.activemq.blob.BlobDownloader;
import org.apache.activemq.command.ActiveMQBlobMessage;

24
activemq-client/src/main/java/org/apache/activemq/ActiveMQProducer.java
View File

@ -22,18 +22,18 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Set;
import javax.jms.BytesMessage;
import javax.jms.CompletionListener;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.IllegalStateRuntimeException;
import javax.jms.JMSException;
import javax.jms.JMSProducer;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageFormatRuntimeException;
import javax.jms.ObjectMessage;
import javax.jms.TextMessage;
import jakarta.jms.BytesMessage;
import jakarta.jms.CompletionListener;
import jakarta.jms.DeliveryMode;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateRuntimeException;
import jakarta.jms.JMSException;
import jakarta.jms.JMSProducer;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.MessageFormatRuntimeException;
import jakarta.jms.ObjectMessage;
import jakarta.jms.TextMessage;
import org.apache.activemq.util.JMSExceptionSupport;
import org.apache.activemq.util.TypeConversionSupport;

14
activemq-client/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java
View File

@ -19,8 +19,8 @@ package org.apache.activemq;
import java.util.Enumeration;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.jms.*;
import javax.jms.IllegalStateException;
import jakarta.jms.*;
import jakarta.jms.IllegalStateException;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerId;
@ -46,10 +46,10 @@ import org.apache.activemq.selector.SelectorParser;
* </CODE>
* or a <CODE>QueueSession</CODE>.
*
* @see javax.jms.Session#createBrowser
* @see javax.jms.QueueSession#createBrowser
* @see javax.jms.QueueBrowser
* @see javax.jms.QueueReceiver
* @see jakarta.jms.Session#createBrowser
* @see jakarta.jms.QueueSession#createBrowser
* @see jakarta.jms.QueueBrowser
* @see jakarta.jms.QueueReceiver
*/
public class ActiveMQQueueBrowser implements QueueBrowser, Enumeration {
@ -183,7 +183,7 @@ public class ActiveMQQueueBrowser implements QueueBrowser, Enumeration {
}
try {
javax.jms.Message answer = consumer.receiveNoWait();
jakarta.jms.Message answer = consumer.receiveNoWait();
if (answer != null) {
return answer;
}

16
activemq-client/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java
View File

@ -16,9 +16,9 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueReceiver;
import jakarta.jms.JMSException;
import jakarta.jms.Queue;
import jakarta.jms.QueueReceiver;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerId;
@ -45,11 +45,11 @@ import org.apache.activemq.command.ConsumerId;
* </CODE>
* is provided to support existing code.
*
* @see javax.jms.Session#createConsumer(javax.jms.Destination, String)
* @see javax.jms.Session#createConsumer(javax.jms.Destination)
* @see javax.jms.QueueSession#createReceiver(Queue, String)
* @see javax.jms.QueueSession#createReceiver(Queue)
* @see javax.jms.MessageConsumer
* @see jakarta.jms.Session#createConsumer(jakarta.jms.Destination, String)
* @see jakarta.jms.Session#createConsumer(jakarta.jms.Destination)
* @see jakarta.jms.QueueSession#createReceiver(Queue, String)
* @see jakarta.jms.QueueSession#createReceiver(Queue)
* @see jakarta.jms.MessageConsumer
*/
public class ActiveMQQueueReceiver extends ActiveMQMessageConsumer implements QueueReceiver {

18
activemq-client/src/main/java/org/apache/activemq/ActiveMQQueueSender.java
View File

@ -17,10 +17,10 @@
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueSender;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.Queue;
import jakarta.jms.QueueSender;
import org.apache.activemq.command.ActiveMQDestination;
@ -66,8 +66,8 @@ import org.apache.activemq.command.ActiveMQDestination;
* object is recommended when creating new code. The <CODE>QueueSender</CODE>
* is provided to support existing code.
*
* @see javax.jms.MessageProducer
* @see javax.jms.QueueSession#createSender(Queue)
* @see jakarta.jms.MessageProducer
* @see jakarta.jms.QueueSession#createSender(Queue)
*/
public class ActiveMQQueueSender extends ActiveMQMessageProducer implements QueueSender {
@ -102,9 +102,9 @@ public class ActiveMQQueueSender extends ActiveMQMessageProducer implements Queu
* @param message the message to send
* @throws JMSException if the JMS provider fails to send the message due to
* some internal error.
* @see javax.jms.MessageProducer#getDeliveryMode()
* @see javax.jms.MessageProducer#getTimeToLive()
* @see javax.jms.MessageProducer#getPriority()
* @see jakarta.jms.MessageProducer#getDeliveryMode()
* @see jakarta.jms.MessageProducer#getTimeToLive()
* @see jakarta.jms.MessageProducer#getPriority()
*/
public void send(Queue queue, Message message) throws JMSException {

44
activemq-client/src/main/java/org/apache/activemq/ActiveMQQueueSession.java
View File

@ -18,28 +18,28 @@ package org.apache.activemq;
import java.io.Serializable;
import javax.jms.BytesMessage;
import javax.jms.Destination;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.StreamMessage;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicSubscriber;
import jakarta.jms.BytesMessage;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.JMSException;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.MessageProducer;
import jakarta.jms.ObjectMessage;
import jakarta.jms.Queue;
import jakarta.jms.QueueBrowser;
import jakarta.jms.QueueReceiver;
import jakarta.jms.QueueSender;
import jakarta.jms.QueueSession;
import jakarta.jms.StreamMessage;
import jakarta.jms.TemporaryQueue;
import jakarta.jms.TemporaryTopic;
import jakarta.jms.TextMessage;
import jakarta.jms.Topic;
import jakarta.jms.TopicSubscriber;
/**
* A QueueSession implementation that throws IllegalStateExceptions when Topic

90
activemq-client/src/main/java/org/apache/activemq/ActiveMQSession.java
View File

@ -30,33 +30,33 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.BytesMessage;
import javax.jms.Destination;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.InvalidSelectorException;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.StreamMessage;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.jms.TransactionRolledBackException;
import jakarta.jms.BytesMessage;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.InvalidSelectorException;
import jakarta.jms.JMSException;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.MessageProducer;
import jakarta.jms.ObjectMessage;
import jakarta.jms.Queue;
import jakarta.jms.QueueBrowser;
import jakarta.jms.QueueReceiver;
import jakarta.jms.QueueSender;
import jakarta.jms.QueueSession;
import jakarta.jms.Session;
import jakarta.jms.StreamMessage;
import jakarta.jms.TemporaryQueue;
import jakarta.jms.TemporaryTopic;
import jakarta.jms.TextMessage;
import jakarta.jms.Topic;
import jakarta.jms.TopicPublisher;
import jakarta.jms.TopicSession;
import jakarta.jms.TopicSubscriber;
import jakarta.jms.TransactionRolledBackException;
import org.apache.activemq.blob.BlobDownloader;
import org.apache.activemq.blob.BlobTransferPolicy;
@ -180,10 +180,10 @@ import org.slf4j.LoggerFactory;
* integrating the JMS API into their application server products.
*
*
* @see javax.jms.Session
* @see javax.jms.QueueSession
* @see javax.jms.TopicSession
* @see javax.jms.XASession
* @see jakarta.jms.Session
* @see jakarta.jms.QueueSession
* @see jakarta.jms.TopicSession
* @see jakarta.jms.XASession
*/
public class ActiveMQSession implements Session, QueueSession, TopicSession, StatsCapable, ActiveMQDispatcher {
@ -553,7 +553,7 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* acknowledgement mode for the session. If the session is
* transacted, returns SESSION_TRANSACTED.
* @throws JMSException
* @see javax.jms.Connection#createSession(boolean,int)
* @see jakarta.jms.Connection#createSession(boolean,int)
* @since 1.1 exception JMSException if there is some internal error.
*/
@Override
@ -570,14 +570,14 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* due to some internal error.
* @throws TransactionRolledBackException if the transaction is rolled back
* due to some internal error during commit.
* @throws javax.jms.IllegalStateException if the method is not called by a
* @throws jakarta.jms.IllegalStateException if the method is not called by a
* transacted session.
*/
@Override
public void commit() throws JMSException {
checkClosed();
if (!getTransacted()) {
throw new javax.jms.IllegalStateException("Not a transacted session");
throw new jakarta.jms.IllegalStateException("Not a transacted session");
}
if (LOG.isDebugEnabled()) {
LOG.debug(getSessionId() + " Transaction Commit :" + transactionContext.getTransactionId());
@ -591,14 +591,14 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
*
* @throws JMSException if the JMS provider fails to roll back the
* transaction due to some internal error.
* @throws javax.jms.IllegalStateException if the method is not called by a
* @throws jakarta.jms.IllegalStateException if the method is not called by a
* transacted session.
*/
@Override
public void rollback() throws JMSException {
checkClosed();
if (!getTransacted()) {
throw new javax.jms.IllegalStateException("Not a transacted session");
throw new jakarta.jms.IllegalStateException("Not a transacted session");
}
if (LOG.isDebugEnabled()) {
LOG.debug(getSessionId() + " Transaction Rollback, txid:" + transactionContext.getTransactionId());
@ -828,9 +828,9 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* @return the message listener associated with this session
* @throws JMSException if the JMS provider fails to get the message
* listener due to an internal error.
* @see javax.jms.Session#setMessageListener(javax.jms.MessageListener)
* @see javax.jms.ServerSessionPool
* @see javax.jms.ServerSession
* @see jakarta.jms.Session#setMessageListener(jakarta.jms.MessageListener)
* @see jakarta.jms.ServerSessionPool
* @see jakarta.jms.ServerSession
*/
@Override
public MessageListener getMessageListener() throws JMSException {
@ -855,9 +855,9 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* @param listener the message listener to associate with this session
* @throws JMSException if the JMS provider fails to set the message
* listener due to an internal error.
* @see javax.jms.Session#getMessageListener()
* @see javax.jms.ServerSessionPool
* @see javax.jms.ServerSession
* @see jakarta.jms.Session#getMessageListener()
* @see jakarta.jms.ServerSessionPool
* @see jakarta.jms.ServerSession
*/
@Override
public void setMessageListener(MessageListener listener) throws JMSException {
@ -878,7 +878,7 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* Optional operation, intended to be used only by Application Servers, not
* by ordinary JMS clients.
*
* @see javax.jms.ServerSession
* @see jakarta.jms.ServerSession
*/
@Override
public void run() {
@ -1813,9 +1813,9 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
*
* @throws JMSException if the JMS provider fails to acknowledge the
* messages due to some internal error.
* @throws javax.jms.IllegalStateException if this method is called on a
* @throws jakarta.jms.IllegalStateException if this method is called on a
* closed session.
* @see javax.jms.Session#CLIENT_ACKNOWLEDGE
* @see jakarta.jms.Session#CLIENT_ACKNOWLEDGE
*/
public void acknowledge() throws JMSException {
for (Iterator<ActiveMQMessageConsumer> iter = consumers.iterator(); iter.hasNext();) {

4
activemq-client/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java
View File

@ -18,7 +18,7 @@
package org.apache.activemq;
import java.util.List;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ConsumerId;
import org.apache.activemq.command.MessageDispatch;
import org.apache.activemq.thread.Task;
@ -31,7 +31,7 @@ import org.slf4j.LoggerFactory;
* A utility class used by the Session for dispatching messages asynchronously
* to consumers
*
* @see javax.jms.Session
* @see jakarta.jms.Session
*/
public class ActiveMQSessionExecutor implements Task {
private static final Logger LOG = LoggerFactory.getLogger(ActiveMQSessionExecutor.class);

2
activemq-client/src/main/java/org/apache/activemq/ActiveMQSslConnectionFactory.java
View File

@ -29,7 +29,7 @@ import java.net.URL;
import java.security.KeyStore;
import java.security.SecureRandom;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import javax.net.ssl.KeyManager;
import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.TrustManager;

20
activemq-client/src/main/java/org/apache/activemq/ActiveMQTopicPublisher.java
View File

@ -17,10 +17,10 @@
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Topic;
import javax.jms.TopicPublisher;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.Topic;
import jakarta.jms.TopicPublisher;
import org.apache.activemq.command.ActiveMQDestination;
@ -114,9 +114,9 @@ public class ActiveMQTopicPublisher extends ActiveMQMessageProducer implements
* @throws java.lang.UnsupportedOperationException
* if a client uses this method with a <CODE>TopicPublisher
* </CODE> that did not specify a topic at creation time.
* @see javax.jms.MessageProducer#getDeliveryMode()
* @see javax.jms.MessageProducer#getTimeToLive()
* @see javax.jms.MessageProducer#getPriority()
* @see jakarta.jms.MessageProducer#getDeliveryMode()
* @see jakarta.jms.MessageProducer#getTimeToLive()
* @see jakarta.jms.MessageProducer#getPriority()
*/
public void publish(Message message) throws JMSException {
@ -162,9 +162,9 @@ public class ActiveMQTopicPublisher extends ActiveMQMessageProducer implements
* some internal error.
* @throws MessageFormatException if an invalid message is specified.
* @throws InvalidDestinationException if a client uses this method with an invalid topic.
* @see javax.jms.MessageProducer#getDeliveryMode()
* @see javax.jms.MessageProducer#getTimeToLive()
* @see javax.jms.MessageProducer#getPriority()
* @see jakarta.jms.MessageProducer#getDeliveryMode()
* @see jakarta.jms.MessageProducer#getTimeToLive()
* @see jakarta.jms.MessageProducer#getPriority()
*/
public void publish(Topic topic, Message message) throws JMSException {

42
activemq-client/src/main/java/org/apache/activemq/ActiveMQTopicSession.java
View File

@ -18,27 +18,27 @@ package org.apache.activemq;
import java.io.Serializable;
import javax.jms.BytesMessage;
import javax.jms.Destination;
import javax.jms.IllegalStateException;
import javax.jms.InvalidDestinationException;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.StreamMessage;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import jakarta.jms.BytesMessage;
import jakarta.jms.Destination;
import jakarta.jms.IllegalStateException;
import jakarta.jms.InvalidDestinationException;
import jakarta.jms.JMSException;
import jakarta.jms.MapMessage;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.MessageProducer;
import jakarta.jms.ObjectMessage;
import jakarta.jms.Queue;
import jakarta.jms.QueueBrowser;
import jakarta.jms.StreamMessage;
import jakarta.jms.TemporaryQueue;
import jakarta.jms.TemporaryTopic;
import jakarta.jms.TextMessage;
import jakarta.jms.Topic;
import jakarta.jms.TopicPublisher;
import jakarta.jms.TopicSession;
import jakarta.jms.TopicSubscriber;
/**
* A TopicSession implementation that throws IllegalStateExceptions when Queue

18
activemq-client/src/main/java/org/apache/activemq/ActiveMQTopicSubscriber.java
View File

@ -17,9 +17,9 @@
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Topic;
import javax.jms.TopicSubscriber;
import jakarta.jms.JMSException;
import jakarta.jms.Topic;
import jakarta.jms.TopicSubscriber;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ConsumerId;
@ -88,12 +88,12 @@ import org.apache.activemq.command.ConsumerId;
* use of <CODE>Session.CreateDurableSubscriber</CODE> is recommended. The
* <CODE>TopicSubscriber</CODE> is provided to support existing code.
*
* @see javax.jms.Session#createConsumer
* @see javax.jms.Session#createDurableSubscriber
* @see javax.jms.TopicSession
* @see javax.jms.TopicSession#createSubscriber
* @see javax.jms.TopicSubscriber
* @see javax.jms.MessageConsumer
* @see jakarta.jms.Session#createConsumer
* @see jakarta.jms.Session#createDurableSubscriber
* @see jakarta.jms.TopicSession
* @see jakarta.jms.TopicSession#createSubscriber
* @see jakarta.jms.TopicSubscriber
* @see jakarta.jms.MessageConsumer
*/
public class ActiveMQTopicSubscriber extends ActiveMQMessageConsumer implements

30
activemq-client/src/main/java/org/apache/activemq/ActiveMQXAConnection.java
View File

@ -16,14 +16,14 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.XAConnection;
import javax.jms.XAQueueConnection;
import javax.jms.XAQueueSession;
import javax.jms.XASession;
import javax.jms.XATopicConnection;
import javax.jms.XATopicSession;
import jakarta.jms.JMSException;
import jakarta.jms.Session;
import jakarta.jms.XAConnection;
import jakarta.jms.XAQueueConnection;
import jakarta.jms.XAQueueSession;
import jakarta.jms.XASession;
import jakarta.jms.XATopicConnection;
import jakarta.jms.XATopicSession;
import org.apache.activemq.management.JMSStatsImpl;
import org.apache.activemq.transport.Transport;
@ -40,13 +40,13 @@ import org.apache.activemq.util.IdGenerator;
* than use these XA interfaces directly.
*
*
* @see javax.jms.Connection
* @see javax.jms.ConnectionFactory
* @see javax.jms.QueueConnection
* @see javax.jms.TopicConnection
* @see javax.jms.TopicConnectionFactory
* @see javax.jms.QueueConnection
* @see javax.jms.QueueConnectionFactory
* @see jakarta.jms.Connection
* @see jakarta.jms.ConnectionFactory
* @see jakarta.jms.QueueConnection
* @see jakarta.jms.TopicConnection
* @see jakarta.jms.TopicConnectionFactory
* @see jakarta.jms.QueueConnection
* @see jakarta.jms.QueueConnectionFactory
*/
public class ActiveMQXAConnection extends ActiveMQConnection implements XATopicConnection, XAQueueConnection, XAConnection {

16
activemq-client/src/main/java/org/apache/activemq/ActiveMQXAConnectionFactory.java
View File

@ -19,14 +19,14 @@ package org.apache.activemq;
import java.net.URI;
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.XAConnection;
import javax.jms.XAConnectionFactory;
import javax.jms.XAJMSContext;
import javax.jms.XAQueueConnection;
import javax.jms.XAQueueConnectionFactory;
import javax.jms.XATopicConnection;
import javax.jms.XATopicConnectionFactory;
import jakarta.jms.JMSException;
import jakarta.jms.XAConnection;
import jakarta.jms.XAConnectionFactory;
import jakarta.jms.XAJMSContext;
import jakarta.jms.XAQueueConnection;
import jakarta.jms.XAQueueConnectionFactory;
import jakarta.jms.XATopicConnection;
import jakarta.jms.XATopicConnectionFactory;
import org.apache.activemq.management.JMSStatsImpl;
import org.apache.activemq.transport.Transport;

22
activemq-client/src/main/java/org/apache/activemq/ActiveMQXASession.java
View File

@ -17,13 +17,13 @@
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TopicSession;
import javax.jms.TransactionInProgressException;
import javax.jms.XAQueueSession;
import javax.jms.XATopicSession;
import jakarta.jms.JMSException;
import jakarta.jms.QueueSession;
import jakarta.jms.Session;
import jakarta.jms.TopicSession;
import jakarta.jms.TransactionInProgressException;
import jakarta.jms.XAQueueSession;
import jakarta.jms.XATopicSession;
import javax.transaction.xa.XAResource;
import org.apache.activemq.command.SessionId;
@ -57,10 +57,10 @@ import org.apache.activemq.command.SessionId;
* than use these XA interfaces directly.
*
*
* @see javax.jms.Session
* @see javax.jms.QueueSession
* @see javax.jms.TopicSession
* @see javax.jms.XASession
* @see jakarta.jms.Session
* @see jakarta.jms.QueueSession
* @see jakarta.jms.TopicSession
* @see jakarta.jms.XASession
*/
public class ActiveMQXASession extends ActiveMQSession implements QueueSession, TopicSession, XAQueueSession, XATopicSession {

16
activemq-client/src/main/java/org/apache/activemq/ActiveMQXASslConnectionFactory.java
View File

@ -19,14 +19,14 @@ package org.apache.activemq;
import java.net.URI;
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.XAConnection;
import javax.jms.XAConnectionFactory;
import javax.jms.XAJMSContext;
import javax.jms.XAQueueConnection;
import javax.jms.XAQueueConnectionFactory;
import javax.jms.XATopicConnection;
import javax.jms.XATopicConnectionFactory;
import jakarta.jms.JMSException;
import jakarta.jms.XAConnection;
import jakarta.jms.XAConnectionFactory;
import jakarta.jms.XAJMSContext;
import jakarta.jms.XAQueueConnection;
import jakarta.jms.XAQueueConnectionFactory;
import jakarta.jms.XATopicConnection;
import jakarta.jms.XATopicConnectionFactory;
import org.apache.activemq.management.JMSStatsImpl;
import org.apache.activemq.transport.Transport;

2
activemq-client/src/main/java/org/apache/activemq/AdvisoryConsumer.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.advisory.AdvisorySupport;
import org.apache.activemq.command.ActiveMQDestination;

2
activemq-client/src/main/java/org/apache/activemq/AlreadyClosedException.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An exception which is closed if you try to access a resource which has already

2
activemq-client/src/main/java/org/apache/activemq/AsyncCallback.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.ExceptionListener;
import jakarta.jms.ExceptionListener;
/**
* <p>

2
activemq-client/src/main/java/org/apache/activemq/BlobMessage.java
View File

@ -21,7 +21,7 @@ import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* Represents a message which has a typically out of band Binary Large Object

4
activemq-client/src/main/java/org/apache/activemq/ClientInternalExceptionListener.java
View File

@ -18,7 +18,7 @@
package org.apache.activemq;
/**
* An exception listener similar to the standard <code>javax.jms.ExceptionListener</code>
* An exception listener similar to the standard <code>jakarta.jms.ExceptionListener</code>
* which can be used by client code to be notified of exceptions thrown by container components
* (e.g. an EJB container in case of Message Driven Beans) during asynchronous processing of a message.
* <p>
@ -38,4 +38,4 @@ public interface ClientInternalExceptionListener
* @param exception the exception describing the problem
*/
void onException(Throwable exception);
}
}

2
activemq-client/src/main/java/org/apache/activemq/Closeable.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* Provides a uniform interface that can be used to close all the JMS obejcts

2
activemq-client/src/main/java/org/apache/activemq/ConfigurationException.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An exception thrown when a service is not correctly configured

2
activemq-client/src/main/java/org/apache/activemq/ConnectionClosedException.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.IllegalStateException;
import jakarta.jms.IllegalStateException;
/**
* An exception thrown when attempt is made to use a connection when the connection has been closed.

2
activemq-client/src/main/java/org/apache/activemq/ConnectionFailedException.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq;
import java.io.IOException;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An exception thrown when the a connection failure is detected (peer might

16
activemq-client/src/main/java/org/apache/activemq/CustomDestination.java
View File

@ -16,14 +16,14 @@
*/
package org.apache.activemq;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.TopicPublisher;
import javax.jms.TopicSubscriber;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageProducer;
import jakarta.jms.QueueReceiver;
import jakarta.jms.QueueSender;
import jakarta.jms.TopicPublisher;
import jakarta.jms.TopicSubscriber;
/**
* Represents a hook to allow the support of custom destinations

2
activemq-client/src/main/java/org/apache/activemq/DestinationDoesNotExistException.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An exception thrown on a send if a destination does not exist.

6
activemq-client/src/main/java/org/apache/activemq/EnhancedConnection.java
View File

@ -17,9 +17,9 @@
*/
package org.apache.activemq;
import javax.jms.TopicConnection;
import javax.jms.QueueConnection;
import javax.jms.JMSException;
import jakarta.jms.TopicConnection;
import jakarta.jms.QueueConnection;
import jakarta.jms.JMSException;
import org.apache.activemq.advisory.DestinationSource;

2
activemq-client/src/main/java/org/apache/activemq/Message.java
View File

@ -21,7 +21,7 @@ package org.apache.activemq;
*
*
*/
public interface Message extends javax.jms.Message {
public interface Message extends jakarta.jms.Message {
/**
* Returns the MIME type of this mesage. This can be used in selectors to filter on

2
activemq-client/src/main/java/org/apache/activemq/MessageAvailableConsumer.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.MessageConsumer;
import jakarta.jms.MessageConsumer;
/**
* An extended JMS interface that adds the ability to be notified when a

2
activemq-client/src/main/java/org/apache/activemq/MessageAvailableListener.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.MessageConsumer;
import jakarta.jms.MessageConsumer;
/**
* A listener which is notified if a message is available for processing via the

2
activemq-client/src/main/java/org/apache/activemq/MessageDispatchChannel.java
View File

@ -17,7 +17,7 @@
package org.apache.activemq;
import java.util.List;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.MessageDispatch;
public interface MessageDispatchChannel {

10
activemq-client/src/main/java/org/apache/activemq/MessageTransformer.java
View File

@ -16,11 +16,11 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageProducer;
import jakarta.jms.Session;
/**
* A plugin strategy for transforming a message before it is sent by the JMS client or before it is

4
activemq-client/src/main/java/org/apache/activemq/MessageTransformerSupport.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq;
import javax.jms.JMSException;
import javax.jms.Message;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
/**
* A useful base class for message transformers.

2
activemq-client/src/main/java/org/apache/activemq/NotStartedException.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq;
import javax.jms.IllegalStateException;
import jakarta.jms.IllegalStateException;
/**
* An exception thrown when an operation is invoked on a service

2
activemq-client/src/main/java/org/apache/activemq/SimplePriorityMessageDispatchChannel.java
View File

@ -258,7 +258,7 @@ public class SimplePriorityMessageDispatchChannel implements MessageDispatchChan
}
protected int getPriority(MessageDispatch message) {
int priority = javax.jms.Message.DEFAULT_PRIORITY;
int priority = jakarta.jms.Message.DEFAULT_PRIORITY;
if (message.getMessage() != null) {
priority = Math.max(message.getMessage().getPriority(), 0);
priority = Math.min(priority, 9);

20
activemq-client/src/main/java/org/apache/activemq/TransactionContext.java
View File

@ -21,9 +21,9 @@ import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import javax.jms.JMSException;
import javax.jms.TransactionInProgressException;
import javax.jms.TransactionRolledBackException;
import jakarta.jms.JMSException;
import jakarta.jms.TransactionInProgressException;
import jakarta.jms.TransactionRolledBackException;
import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
@ -56,10 +56,10 @@ import org.slf4j.LoggerFactory;
* JMS provider may choose to implement this functionality from scratch. <p/>
*
*
* @see javax.jms.Session
* @see javax.jms.QueueSession
* @see javax.jms.TopicSession
* @see javax.jms.XASession
* @see jakarta.jms.Session
* @see jakarta.jms.QueueSession
* @see jakarta.jms.TopicSession
* @see jakarta.jms.XASession
*/
public class TransactionContext implements XAResource {
@ -229,7 +229,7 @@ public class TransactionContext implements XAResource {
/**
* Start a local transaction.
* @throws javax.jms.JMSException on internal error
* @throws jakarta.jms.JMSException on internal error
*/
public void begin() throws JMSException {
@ -261,7 +261,7 @@ public class TransactionContext implements XAResource {
*
* @throws JMSException if the JMS provider fails to roll back the
* transaction due to some internal error.
* @throws javax.jms.IllegalStateException if the method is not called by a
* @throws jakarta.jms.IllegalStateException if the method is not called by a
* transacted session.
*/
public void rollback() throws JMSException {
@ -297,7 +297,7 @@ public class TransactionContext implements XAResource {
*
* @throws JMSException if the JMS provider fails to commit the transaction
* due to some internal error.
* @throws javax.jms.IllegalStateException if the method is not called by a
* @throws jakarta.jms.IllegalStateException if the method is not called by a
* transacted session.
*/
public void commit() throws JMSException {

4
activemq-client/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java
View File

@ -18,8 +18,8 @@ package org.apache.activemq.advisory;
import java.util.ArrayList;
import javax.jms.Destination;
import javax.jms.JMSException;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import org.apache.activemq.ActiveMQMessageTransformation;
import org.apache.activemq.command.ActiveMQDestination;

2
activemq-client/src/main/java/org/apache/activemq/advisory/ConsumerEvent.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.advisory;
import java.util.EventObject;
import javax.jms.Destination;
import jakarta.jms.Destination;
import org.apache.activemq.command.ConsumerId;

12
activemq-client/src/main/java/org/apache/activemq/advisory/ConsumerEventSource.java
View File

@ -19,12 +19,12 @@ package org.apache.activemq.advisory;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageListener;
import jakarta.jms.Session;
import org.apache.activemq.ActiveMQMessageConsumer;
import org.apache.activemq.Service;

12
activemq-client/src/main/java/org/apache/activemq/advisory/DestinationSource.java
View File

@ -20,12 +20,12 @@ import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.Session;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQMessage;

2
activemq-client/src/main/java/org/apache/activemq/advisory/ProducerEvent.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.advisory;
import java.util.EventObject;
import javax.jms.Destination;
import jakarta.jms.Destination;
import org.apache.activemq.command.ProducerId;

14
activemq-client/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java
View File

@ -19,13 +19,13 @@ package org.apache.activemq.advisory;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Session;
import jakarta.jms.Connection;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.Message;
import jakarta.jms.MessageConsumer;
import jakarta.jms.MessageListener;
import jakarta.jms.Session;
import org.apache.activemq.Service;
import org.apache.activemq.command.ActiveMQDestination;

2
activemq-client/src/main/java/org/apache/activemq/blob/BlobDownloadStrategy.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.blob;
import java.io.IOException;
import java.io.InputStream;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;
/**

2
activemq-client/src/main/java/org/apache/activemq/blob/BlobDownloader.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.blob;
import java.io.IOException;
import java.io.InputStream;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/blob/BlobUploadStrategy.java
View File

@ -21,7 +21,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/blob/BlobUploader.java
View File

@ -21,7 +21,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/blob/DefaultBlobDownloadStrategy.java
View File

@ -20,7 +20,7 @@ import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;
/**

2
activemq-client/src/main/java/org/apache/activemq/blob/DefaultBlobUploadStrategy.java
View File

@ -24,7 +24,7 @@ import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/blob/DefaultStrategy.java
View File

@ -19,7 +19,7 @@ package org.apache.activemq.blob;
import java.net.MalformedURLException;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/blob/FileSystemBlobStrategy.java
View File

@ -25,7 +25,7 @@ import java.net.MalformedURLException;
import java.net.URISyntaxException;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQBlobMessage;

2
activemq-client/src/main/java/org/apache/activemq/broker/scheduler/CronParser.java
View File

@ -22,7 +22,7 @@ import java.util.Collections;
import java.util.List;
import java.util.StringTokenizer;
import javax.jms.MessageFormatException;
import jakarta.jms.MessageFormatException;
public class CronParser {

2
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBlobMessage.java
View File

@ -21,7 +21,7 @@ import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.BlobMessage;
import org.apache.activemq.blob.BlobDownloader;

24
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQBytesMessage.java
View File

@ -26,12 +26,12 @@ import java.util.Arrays;
import java.util.zip.Deflater;
import java.util.zip.Inflater;
import javax.jms.BytesMessage;
import javax.jms.JMSException;
import javax.jms.MessageEOFException;
import javax.jms.MessageFormatException;
import javax.jms.MessageNotReadableException;
import javax.jms.MessageNotWriteableException;
import jakarta.jms.BytesMessage;
import jakarta.jms.JMSException;
import jakarta.jms.MessageEOFException;
import jakarta.jms.MessageFormatException;
import jakarta.jms.MessageNotReadableException;
import jakarta.jms.MessageNotWriteableException;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.util.ByteArrayInputStream;
@ -84,12 +84,12 @@ import org.apache.activemq.util.JMSExceptionSupport;
* <CODE>MessageNotWriteableException</CODE> is thrown.
*
* @openwire:marshaller code=24
* @see javax.jms.Session#createBytesMessage()
* @see javax.jms.MapMessage
* @see javax.jms.Message
* @see javax.jms.ObjectMessage
* @see javax.jms.StreamMessage
* @see javax.jms.TextMessage
* @see jakarta.jms.Session#createBytesMessage()
* @see jakarta.jms.MapMessage
* @see jakarta.jms.Message
* @see jakarta.jms.ObjectMessage
* @see jakarta.jms.StreamMessage
* @see jakarta.jms.TextMessage
*/
public class ActiveMQBytesMessage extends ActiveMQMessage implements BytesMessage {

12
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQDestination.java
View File

@ -30,12 +30,12 @@ import java.util.Properties;
import java.util.Set;
import java.util.StringTokenizer;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
import javax.jms.Topic;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.Queue;
import jakarta.jms.TemporaryQueue;
import jakarta.jms.TemporaryTopic;
import jakarta.jms.Topic;
import org.apache.activemq.filter.AnyDestination;
import org.apache.activemq.filter.DestinationFilter;

20
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMapMessage.java
View File

@ -30,10 +30,10 @@ import java.util.Map;
import java.util.zip.DeflaterOutputStream;
import java.util.zip.InflaterInputStream;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageFormatException;
import javax.jms.MessageNotWriteableException;
import jakarta.jms.JMSException;
import jakarta.jms.MapMessage;
import jakarta.jms.MessageFormatException;
import jakarta.jms.MessageNotWriteableException;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.util.ByteArrayInputStream;
@ -91,12 +91,12 @@ import org.fusesource.hawtbuf.UTF8Buffer;
* as a <code>char</code> must throw a <code>NullPointerException</code>.
*
* @openwire:marshaller code="25"
* @see javax.jms.Session#createMapMessage()
* @see javax.jms.BytesMessage
* @see javax.jms.Message
* @see javax.jms.ObjectMessage
* @see javax.jms.StreamMessage
* @see javax.jms.TextMessage
* @see jakarta.jms.Session#createMapMessage()
* @see jakarta.jms.BytesMessage
* @see jakarta.jms.Message
* @see jakarta.jms.ObjectMessage
* @see jakarta.jms.StreamMessage
* @see jakarta.jms.TextMessage
*/
public class ActiveMQMapMessage extends ActiveMQMessage implements MapMessage {

10
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
View File

@ -24,11 +24,11 @@ import java.util.List;
import java.util.Map;
import java.util.Vector;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageFormatException;
import javax.jms.MessageNotWriteableException;
import jakarta.jms.DeliveryMode;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.MessageFormatException;
import jakarta.jms.MessageNotWriteableException;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ScheduledMessage;

22
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQObjectMessage.java
View File

@ -29,8 +29,8 @@ import java.util.List;
import java.util.zip.DeflaterOutputStream;
import java.util.zip.InflaterInputStream;
import javax.jms.JMSException;
import javax.jms.ObjectMessage;
import jakarta.jms.JMSException;
import jakarta.jms.ObjectMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.util.ByteArrayInputStream;
@ -57,13 +57,13 @@ import org.apache.activemq.wireformat.WireFormat;
* written to.
*
* @openwire:marshaller code="26"
* @see javax.jms.Session#createObjectMessage()
* @see javax.jms.Session#createObjectMessage(Serializable)
* @see javax.jms.BytesMessage
* @see javax.jms.MapMessage
* @see javax.jms.Message
* @see javax.jms.StreamMessage
* @see javax.jms.TextMessage
* @see jakarta.jms.Session#createObjectMessage()
* @see jakarta.jms.Session#createObjectMessage(Serializable)
* @see jakarta.jms.BytesMessage
* @see jakarta.jms.MapMessage
* @see jakarta.jms.Message
* @see jakarta.jms.StreamMessage
* @see jakarta.jms.TextMessage
*/
public class ActiveMQObjectMessage extends ActiveMQMessage implements ObjectMessage, TransientInitializer {
@ -169,8 +169,8 @@ public class ActiveMQObjectMessage extends ActiveMQMessage implements ObjectMess
* @param newObject the message's data
* @throws JMSException if the JMS provider fails to set the object due to
* some internal error.
* @throws javax.jms.MessageFormatException if object serialization fails.
* @throws javax.jms.MessageNotWriteableException if the message is in
* @throws jakarta.jms.MessageFormatException if object serialization fails.
* @throws jakarta.jms.MessageNotWriteableException if the message is in
* read-only mode.
*/

4
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQQueue.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq.command;
import javax.jms.JMSException;
import javax.jms.Queue;
import jakarta.jms.JMSException;
import jakarta.jms.Queue;
/**
*

24
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQStreamMessage.java
View File

@ -27,12 +27,12 @@ import java.io.OutputStream;
import java.util.zip.DeflaterOutputStream;
import java.util.zip.InflaterInputStream;
import javax.jms.JMSException;
import javax.jms.MessageEOFException;
import javax.jms.MessageFormatException;
import javax.jms.MessageNotReadableException;
import javax.jms.MessageNotWriteableException;
import javax.jms.StreamMessage;
import jakarta.jms.JMSException;
import jakarta.jms.MessageEOFException;
import jakarta.jms.MessageFormatException;
import jakarta.jms.MessageNotReadableException;
import jakarta.jms.MessageNotWriteableException;
import jakarta.jms.StreamMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.util.ByteArrayInputStream;
@ -102,12 +102,12 @@ import org.apache.activemq.util.MarshallingSupport;
* as a <code>char</code> must throw a <code>NullPointerException</code>.
*
* @openwire:marshaller code="27"
* @see javax.jms.Session#createStreamMessage()
* @see javax.jms.BytesMessage
* @see javax.jms.MapMessage
* @see javax.jms.Message
* @see javax.jms.ObjectMessage
* @see javax.jms.TextMessage
* @see jakarta.jms.Session#createStreamMessage()
* @see jakarta.jms.BytesMessage
* @see jakarta.jms.MapMessage
* @see jakarta.jms.Message
* @see jakarta.jms.ObjectMessage
* @see jakarta.jms.TextMessage
*/
public class ActiveMQStreamMessage extends ActiveMQMessage implements StreamMessage {

2
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQTempDestination.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.command;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.ActiveMQConnection;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

4
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQTempQueue.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq.command;
import javax.jms.JMSException;
import javax.jms.TemporaryQueue;
import jakarta.jms.JMSException;
import jakarta.jms.TemporaryQueue;
/**
* @org.apache.xbean.XBean element="tempQueue" description="An ActiveMQ Temporary Queue Destination"

4
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQTempTopic.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq.command;
import javax.jms.JMSException;
import javax.jms.TemporaryTopic;
import jakarta.jms.JMSException;
import jakarta.jms.TemporaryTopic;
/**
* @org.apache.xbean.XBean element="tempTopic" description="An ActiveMQ Temporary Topic Destination"

6
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java
View File

@ -25,9 +25,9 @@ import java.util.HashMap;
import java.util.zip.DeflaterOutputStream;
import java.util.zip.InflaterInputStream;
import javax.jms.JMSException;
import javax.jms.MessageNotWriteableException;
import javax.jms.TextMessage;
import jakarta.jms.JMSException;
import jakarta.jms.MessageNotWriteableException;
import jakarta.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.util.ByteArrayInputStream;

4
activemq-client/src/main/java/org/apache/activemq/command/ActiveMQTopic.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq.command;
import javax.jms.JMSException;
import javax.jms.Topic;
import jakarta.jms.JMSException;
import jakarta.jms.Topic;
/**
* @org.apache.xbean.XBean element="topic" description="An ActiveMQ Topic

8
activemq-client/src/main/java/org/apache/activemq/command/DefaultUnresolvedDestinationTransformer.java
View File

@ -16,10 +16,10 @@
*/
package org.apache.activemq.command;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.Topic;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
import jakarta.jms.Queue;
import jakarta.jms.Topic;
import java.lang.reflect.Method;
public class DefaultUnresolvedDestinationTransformer implements UnresolvedDestinationTransformer {

2
activemq-client/src/main/java/org/apache/activemq/command/Message.java
View File

@ -27,7 +27,7 @@ import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.zip.DeflaterOutputStream;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.advisory.AdvisorySupport;

2
activemq-client/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
View File

@ -23,7 +23,7 @@ import org.apache.activemq.util.JMSExceptionSupport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import java.io.IOException;
import java.util.Arrays;

4
activemq-client/src/main/java/org/apache/activemq/command/UnresolvedDestinationTransformer.java
View File

@ -16,8 +16,8 @@
*/
package org.apache.activemq.command;
import javax.jms.Destination;
import javax.jms.JMSException;
import jakarta.jms.Destination;
import jakarta.jms.JMSException;
public interface UnresolvedDestinationTransformer {

2
activemq-client/src/main/java/org/apache/activemq/filter/ArithmeticExpression.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.filter;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An expression which performs an operation on two expression values

2
activemq-client/src/main/java/org/apache/activemq/filter/BooleanExpression.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.filter;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**

2
activemq-client/src/main/java/org/apache/activemq/filter/BooleanFunctionCallExpr.java
View File

@ -52,7 +52,7 @@ public class BooleanFunctionCallExpr extends FunctionCallExpression implements B
* @return the boolean evaluation of the function call expression.
*/
public boolean matches(MessageEvaluationContext message_ctx) throws javax.jms.JMSException {
public boolean matches(MessageEvaluationContext message_ctx) throws jakarta.jms.JMSException {
Boolean result;
result = (Boolean) evaluate(message_ctx);

2
activemq-client/src/main/java/org/apache/activemq/filter/ComparisonExpression.java
View File

@ -21,7 +21,7 @@ import java.util.List;
import java.util.Set;
import java.util.regex.Pattern;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* A filter performing a comparison of two objects

2
activemq-client/src/main/java/org/apache/activemq/filter/ConstantExpression.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.filter;
import java.math.BigDecimal;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* Represents a constant expression

2
activemq-client/src/main/java/org/apache/activemq/filter/DestinationFilter.java
View File

@ -19,7 +19,7 @@ package org.apache.activemq.filter;
import java.io.IOException;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.util.JMSExceptionSupport;

2
activemq-client/src/main/java/org/apache/activemq/filter/DestinationPath.java
View File

@ -20,7 +20,7 @@ package org.apache.activemq.filter;
import java.util.ArrayList;
import java.util.List;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.Message;

2
activemq-client/src/main/java/org/apache/activemq/filter/Expression.java
View File

@ -17,7 +17,7 @@
package org.apache.activemq.filter;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**

2
activemq-client/src/main/java/org/apache/activemq/filter/FunctionCallExpression.java
View File

@ -190,7 +190,7 @@ public class FunctionCallExpression implements Expression {
*/
public Object evaluate(MessageEvaluationContext message_ctx)
throws javax.jms.JMSException {
throws jakarta.jms.JMSException {
return this.filterFunc.evaluate(this, message_ctx);
}

2
activemq-client/src/main/java/org/apache/activemq/filter/LogicExpression.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.filter;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import java.util.ArrayList;
import java.util.List;

2
activemq-client/src/main/java/org/apache/activemq/filter/MultiExpressionEvaluator.java
View File

@ -23,7 +23,7 @@ import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* A MultiExpressionEvaluator is used to evaluate multiple expressions in single

2
activemq-client/src/main/java/org/apache/activemq/filter/NoLocalExpression.java
View File

@ -18,7 +18,7 @@ package org.apache.activemq.filter;
import java.io.IOException;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.util.JMSExceptionSupport;

2
activemq-client/src/main/java/org/apache/activemq/filter/PropertyExpression.java
View File

@ -22,7 +22,7 @@ import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.Message;

2
activemq-client/src/main/java/org/apache/activemq/filter/UnaryExpression.java
View File

@ -22,7 +22,7 @@ import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* An expression which performs an operation on two expression values

2
activemq-client/src/main/java/org/apache/activemq/filter/XPathExpression.java
View File

@ -24,7 +24,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
import javax.xml.XMLConstants;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;

2
activemq-client/src/main/java/org/apache/activemq/filter/XQueryExpression.java
View File

@ -16,7 +16,7 @@
*/
package org.apache.activemq.filter;
import javax.jms.JMSException;
import jakarta.jms.JMSException;
/**
* Used to evaluate an XQuery Expression in a JMS selector.

2
activemq-client/src/main/java/org/apache/activemq/filter/function/FilterFunction.java
View File

@ -55,6 +55,6 @@ public interface FilterFunction {
* @param message - the context within which to evaluate the call.
*/
public Object evaluate(FunctionCallExpression expr, MessageEvaluationContext message)
throws javax.jms.JMSException;
throws jakarta.jms.JMSException;
}

2
activemq-client/src/main/java/org/apache/activemq/filter/function/inListFunction.java
View File

@ -72,7 +72,7 @@ public class inListFunction implements FilterFunction {
*/
public Object evaluate(FunctionCallExpression expr, MessageEvaluationContext message_ctx)
throws javax.jms.JMSException {
throws jakarta.jms.JMSException {
java.util.List arr;
int cur;
Object cand;

2
activemq-client/src/main/java/org/apache/activemq/filter/function/makeListFunction.java
View File

@ -63,7 +63,7 @@ public class makeListFunction implements FilterFunction {
*/
public Object evaluate(FunctionCallExpression expr, MessageEvaluationContext message)
throws javax.jms.JMSException {
throws jakarta.jms.JMSException {
java.util.ArrayList ele_arr;
int num_arg;
int cur;

Some files were not shown because too many files have changed in this diff Show More