This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/main by this push:
new ff134fd [AMQ-8456] Fix unit test compilation
ff134fd is described below
commit ff134fd135b176c01ee8505265d1d6ac2db74055
Author: Jean-Baptiste Onofré <[email protected]>
AuthorDate: Wed Jan 12 20:36:29 2022 +0100
[AMQ-8456] Fix unit test compilation
---
.../java/org/apache/activemq/JMSMessageTest.java | 20 ++++++++++++++++++++
.../java/org/apache/activemq/bugs/AMQ5212Test.java | 7 ++++---
.../java/org/apache/activemq/bugs/AMQ6122Test.java | 9 +++------
.../store/jdbc/JDBCIOExceptionHandlerTest.java | 2 --
4 files changed, 27 insertions(+), 11 deletions(-)
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/JMSMessageTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/JMSMessageTest.java
index a22e5e9..f4749a1 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/JMSMessageTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/JMSMessageTest.java
@@ -374,6 +374,16 @@ public class JMSMessageTest extends JmsTestSupport {
}
@Override
+ public long getJMSDeliveryTime() throws JMSException {
+ return 0;
+ }
+
+ @Override
+ public void setJMSDeliveryTime(long l) throws JMSException {
+
+ }
+
+ @Override
public int getJMSPriority() throws JMSException {
return priority;
}
@@ -489,6 +499,16 @@ public class JMSMessageTest extends JmsTestSupport {
}
@Override
+ public <T> T getBody(Class<T> aClass) throws JMSException {
+ return null;
+ }
+
+ @Override
+ public boolean isBodyAssignableTo(Class aClass) throws JMSException {
+ return true;
+ }
+
+ @Override
public void setText(String arg0) throws JMSException {
text = arg0;
}
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5212Test.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5212Test.java
index cc2602d..f5d51d1 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5212Test.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5212Test.java
@@ -29,6 +29,7 @@ import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
+import javax.jms.CompletionListener;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
@@ -123,7 +124,7 @@ public class AMQ5212Test {
}
ActiveMQTextMessage message = new
ActiveMQTextMessage();
message.setDestination(dest);
- activeMQMessageProducer.send(message, null);
+ activeMQMessageProducer.send(message,
(CompletionListener) null);
// send a duplicate
activeMQConnection.syncSendPacket(message);
@@ -164,7 +165,7 @@ public class AMQ5212Test {
ActiveMQMessageProducer activeMQMessageProducer =
(ActiveMQMessageProducer) activeMQSession.createProducer(dest);
ActiveMQTextMessage message = new ActiveMQTextMessage();
message.setDestination(dest);
- activeMQMessageProducer.send(message, null);
+ activeMQMessageProducer.send(message, (CompletionListener) null);
// send a duplicate
activeMQConnection.syncSendPacket(message);
@@ -209,7 +210,7 @@ public class AMQ5212Test {
ActiveMQMessageProducer activeMQMessageProducer =
(ActiveMQMessageProducer) activeMQSession.createProducer(dest);
ActiveMQTextMessage message = new ActiveMQTextMessage();
message.setDestination(dest);
- activeMQMessageProducer.send(message, null);
+ activeMQMessageProducer.send(message, (CompletionListener) null);
// send a duplicate
activeMQConnection.syncSendPacket(message);
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6122Test.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6122Test.java
index 220d7fe..2c316ad 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6122Test.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6122Test.java
@@ -21,10 +21,7 @@ import static org.junit.Assert.assertNotNull;
import java.util.ArrayList;
import java.util.List;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.Session;
+import javax.jms.*;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
@@ -111,7 +108,7 @@ public class AMQ6122Test {
ActiveMQMessageProducer activeMQMessageProducer =
(ActiveMQMessageProducer) activeMQSession.createProducer(dest);
ActiveMQTextMessage message = new ActiveMQTextMessage();
message.setDestination(dest);
- activeMQMessageProducer.send(message, null);
+ activeMQMessageProducer.send(message, (CompletionListener) null);
// send a duplicate
activeMQConnection.syncSendPacket(message);
@@ -149,7 +146,7 @@ public class AMQ6122Test {
@Override
public void run() {
try {
- producer.send(message, null);
+ producer.send(message, (CompletionListener) null);
} catch (JMSException e) {
e.printStackTrace();
}
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/JDBCIOExceptionHandlerTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/JDBCIOExceptionHandlerTest.java
index cd472c0..a88c50f 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/JDBCIOExceptionHandlerTest.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/JDBCIOExceptionHandlerTest.java
@@ -38,8 +38,6 @@ import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;
-import com.sun.jndi.rmi.registry.RegistryContext;
-import com.sun.jndi.rmi.registry.RegistryContextFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.ft.SyncCreateDataSource;
