This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch 2.19.x in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 0b482c4c1d860903a5ef14d7c358909d53a5acdf Author: Domenico Francesco Bruscino <[email protected]> AuthorDate: Fri Nov 19 17:22:20 2021 +0100 ARTEMIS-3576 Fix toString methods throwing exceptions (cherry picked from commit fcd512f9de9630e9f064f2b352e079d981f6218c) --- .../core/remoting/impl/netty/NettyConnection.java | 4 + .../artemis/jms/client/ActiveMQMessage.java | 15 ++- .../artemis/core/journal/impl/JournalRecord.java | 4 + .../artemis/protocol/amqp/broker/AMQPMessage.java | 7 +- .../artemis/protocol/amqp/util/NettyReadable.java | 4 + .../ra/ActiveMQRAManagedConnectionFactory.java | 2 +- .../activemq/artemis/ra/ActiveMQRAMessage.java | 5 + .../core/paging/cursor/impl/PageReader.java | 4 + .../core/persistence/config/PersistedRole.java | 15 ++- .../impl/journal/codec/DuplicateIDEncoding.java | 7 +- .../codec/PersistentAddressBindingEncoding.java | 5 + .../impl/nullpm/NullStorageLargeServerMessage.java | 2 +- .../BackupReplicationStartFailedMessage.java | 7 +- .../core/server/cluster/qourum/QuorumManager.java | 5 + .../core/server/impl/MessageReferenceImpl.java | 15 ++- tests/unit-tests/pom.xml | 4 + .../artemis/tests/unit/AllClassesTest.java | 138 +++++++++++++++++++++ 17 files changed, 225 insertions(+), 18 deletions(-) diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java index 75c092e..6d4d5d1 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java @@ -45,6 +45,8 @@ import org.apache.activemq.artemis.utils.Env; import org.apache.activemq.artemis.utils.IPV6Util; import org.jboss.logging.Logger; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + public class NettyConnection implements Connection { private static final Logger logger = Logger.getLogger(NettyConnection.class); @@ -74,6 +76,8 @@ public class NettyConnection implements Connection { final BaseConnectionLifeCycleListener<?> listener, boolean batchingEnabled, boolean directDeliver) { + checkNotNull(channel); + this.configuration = configuration; this.channel = channel; diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java index 7cc6c47..e9906cb 100644 --- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java +++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java @@ -54,6 +54,7 @@ import static org.apache.activemq.artemis.jms.client.ActiveMQDestination.QUEUE_Q import static org.apache.activemq.artemis.jms.client.ActiveMQDestination.TEMP_QUEUE_QUALIFED_PREFIX; import static org.apache.activemq.artemis.jms.client.ActiveMQDestination.TEMP_TOPIC_QUALIFED_PREFIX; import static org.apache.activemq.artemis.jms.client.ActiveMQDestination.TOPIC_QUALIFIED_PREFIX; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; /** * ActiveMQ Artemis implementation of a JMS Message. @@ -223,6 +224,8 @@ public class ActiveMQMessage implements javax.jms.Message { * Constructor for when receiving a message from the server */ public ActiveMQMessage(final ClientMessage message, final ClientSession session) { + checkNotNull(message); + this.message = message; readOnly = true; @@ -858,10 +861,14 @@ public class ActiveMQMessage implements javax.jms.Message { @Override public String toString() { StringBuffer sb = new StringBuffer("ActiveMQMessage["); - sb.append(getJMSMessageID()); - sb.append("]:"); - sb.append(message.isDurable() ? "PERSISTENT" : "NON-PERSISTENT"); - sb.append("/" + message.toString()); + if (message != null) { + sb.append(getJMSMessageID()); + sb.append("]:"); + sb.append(message.isDurable() ? "PERSISTENT" : "NON-PERSISTENT"); + sb.append("/" + message.toString()); + } else { + sb.append("]"); + } return sb.toString(); } diff --git a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalRecord.java b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalRecord.java index 0be90c2..7a2722e 100644 --- a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalRecord.java +++ b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalRecord.java @@ -16,6 +16,8 @@ */ package org.apache.activemq.artemis.core.journal.impl; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + /** * This holds the relationship a record has with other files in regard to reference counting. * Note: This class used to be called PosFiles @@ -35,6 +37,8 @@ public class JournalRecord { private ObjIntIntArrayList<JournalFile> fileUpdates; public JournalRecord(final JournalFile addFile, final int size) { + checkNotNull(addFile); + this.addFile = addFile; this.size = size; diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java index 64da6eb..ca73b64 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java @@ -1774,11 +1774,16 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache. @Override public String toString() { + MessageDataScanningStatus scanningStatus = getDataScanningStatus(); + Map<String, Object> applicationProperties = scanningStatus == MessageDataScanningStatus.SCANNED ? + getApplicationPropertiesMap(false) : Collections.EMPTY_MAP; + return this.getClass().getSimpleName() + "( [durable=" + isDurable() + ", messageID=" + getMessageID() + ", address=" + getAddress() + ", size=" + getEncodeSize() + - ", applicationProperties=" + getApplicationPropertiesMap(false) + + ", scanningStatus=" + scanningStatus + + ", applicationProperties=" + applicationProperties + ", messageAnnotations=" + getMessageAnnotationsMap(false) + ", properties=" + properties + ", extraProperties = " + getExtraProperties() + diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/util/NettyReadable.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/util/NettyReadable.java index 2d7bf55..b0679b5 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/util/NettyReadable.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/util/NettyReadable.java @@ -26,6 +26,8 @@ import org.apache.qpid.proton.codec.WritableBuffer; import io.netty.buffer.ByteBuf; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + /** * {@link ReadableBuffer} implementation that wraps a Netty {@link ByteBuf} to * allow use of Netty buffers to be used when decoding AMQP messages. @@ -37,6 +39,8 @@ public class NettyReadable implements ReadableBuffer { private final ByteBuf buffer; public NettyReadable(ByteBuf buffer) { + checkNotNull(buffer); + this.buffer = buffer; } diff --git a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAManagedConnectionFactory.java b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAManagedConnectionFactory.java index 2154a4a..be26712 100644 --- a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAManagedConnectionFactory.java +++ b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAManagedConnectionFactory.java @@ -332,7 +332,7 @@ public final class ActiveMQRAManagedConnectionFactory implements ManagedConnecti } int hash = mcfProperties.hashCode(); - hash += 31 * ra.hashCode(); + hash += 31 * (ra != null ? ra.hashCode() : 0); return hash; } diff --git a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAMessage.java b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAMessage.java index 39d9fa9..48eff16 100644 --- a/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAMessage.java +++ b/artemis-ra/src/main/java/org/apache/activemq/artemis/ra/ActiveMQRAMessage.java @@ -22,6 +22,8 @@ import javax.jms.Message; import java.util.Arrays; import java.util.Enumeration; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + /** * A wrapper for a message */ @@ -44,6 +46,9 @@ public class ActiveMQRAMessage implements Message { * @param session the session */ public ActiveMQRAMessage(final Message message, final ActiveMQRASession session) { + checkNotNull(message); + checkNotNull(session); + if (ActiveMQRALogger.LOGGER.isTraceEnabled()) { ActiveMQRALogger.LOGGER.trace("constructor(" + message + ", " + session + ")"); } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java index 83ad21e..5d8e141 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageReader.java @@ -24,6 +24,8 @@ import org.apache.activemq.artemis.core.paging.cursor.PagePosition; import org.apache.activemq.artemis.core.paging.impl.Page; import org.jboss.logging.Logger; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + public class PageReader implements PageCache { private static final Logger logger = Logger.getLogger(PageReader.class); @@ -31,6 +33,8 @@ public class PageReader implements PageCache { private final int numberOfMessages; public PageReader(Page page, int numberOfMessages) { + checkNotNull(page); + this.page = page; this.numberOfMessages = numberOfMessages; } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/config/PersistedRole.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/config/PersistedRole.java index 1af8864..38307e8 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/config/PersistedRole.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/config/PersistedRole.java @@ -24,6 +24,8 @@ import org.apache.activemq.artemis.core.journal.EncodingSupport; import org.apache.activemq.artemis.utils.BufferHelper; import org.apache.activemq.artemis.utils.DataConstants; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + public class PersistedRole implements EncodingSupport { private long storeId; @@ -36,6 +38,9 @@ public class PersistedRole implements EncodingSupport { } public PersistedRole(String username, List<String> roles) { + checkNotNull(username); + checkNotNull(roles); + this.username = username; this.roles = roles; } @@ -95,10 +100,12 @@ public class PersistedRole implements EncodingSupport { result.append("PersistedRole [storeId=").append(storeId); result.append(", username=").append(username); result.append(", roles ["); - for (int i = 0; i < roles.size(); i++) { - result.append(roles.get(i)); - if (i < roles.size() - 1) { - result.append(", "); + if (roles != null) { + for (int i = 0; i < roles.size(); i++) { + result.append(roles.get(i)); + if (i < roles.size() - 1) { + result.append(", "); + } } } result.append("]]"); diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/DuplicateIDEncoding.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/DuplicateIDEncoding.java index 1dd41ff..11b4eea 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/DuplicateIDEncoding.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/DuplicateIDEncoding.java @@ -25,6 +25,8 @@ import org.apache.activemq.artemis.utils.ByteUtil; import org.apache.activemq.artemis.utils.DataConstants; import org.apache.activemq.artemis.utils.UUID; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + public class DuplicateIDEncoding implements EncodingSupport { public SimpleString address; @@ -32,6 +34,9 @@ public class DuplicateIDEncoding implements EncodingSupport { public byte[] duplID; public DuplicateIDEncoding(final SimpleString address, final byte[] duplID) { + checkNotNull(address); + checkNotNull(duplID); + this.address = address; this.duplID = duplID; @@ -78,7 +83,7 @@ public class DuplicateIDEncoding implements EncodingSupport { // The bridge will generate IDs on these terms: // This will make them easier to read - if (address.toString().startsWith("BRIDGE") && duplID.length == 24) { + if (address != null && address.toString().startsWith("BRIDGE") && duplID.length == 24) { try { ByteBuffer buff = ByteBuffer.wrap(duplID); diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java index e23c69d..fdd74a2 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentAddressBindingEncoding.java @@ -25,6 +25,8 @@ import org.apache.activemq.artemis.core.persistence.AddressBindingInfo; import org.apache.activemq.artemis.api.core.RoutingType; import org.apache.activemq.artemis.utils.DataConstants; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + public class PersistentAddressBindingEncoding implements EncodingSupport, AddressBindingInfo { public long id; @@ -59,6 +61,9 @@ public class PersistentAddressBindingEncoding implements EncodingSupport, Addres public PersistentAddressBindingEncoding(final SimpleString name, final EnumSet<RoutingType> routingTypes, final boolean autoCreated) { + checkNotNull(name); + checkNotNull(routingTypes); + this.name = name; this.routingTypes = routingTypes; this.autoCreated = autoCreated; diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java index 68c7f88..4f63931 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java @@ -125,7 +125,7 @@ class NullStorageLargeServerMessage extends CoreMessage implements CoreLargeServ @Override public String toString() { - return "NullStorageLargeServerMessage[messageID=" + messageID + ", durable=" + durable + ", address=" + getAddress() + ",properties=" + properties.toString() + "]"; + return "NullStorageLargeServerMessage[messageID=" + messageID + ", durable=" + durable + ", address=" + getAddress() + ",properties=" + properties + "]"; } @Override diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java index fc381c2..b08e53f 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/BackupReplicationStartFailedMessage.java @@ -24,6 +24,8 @@ import java.util.Map; import org.apache.activemq.artemis.api.core.ActiveMQBuffer; import org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + /** * Informs the Backup trying to start replicating of an error. */ @@ -57,6 +59,9 @@ public final class BackupReplicationStartFailedMessage extends PacketImpl { public BackupReplicationStartFailedMessage(BackupRegistrationProblem registrationProblem) { super(BACKUP_REGISTRATION_FAILED); + + checkNotNull(registrationProblem); + problem = registrationProblem; } @@ -104,6 +109,6 @@ public final class BackupReplicationStartFailedMessage extends PacketImpl { @Override protected String getPacketString() { - return super.getPacketString() + ", problem=" + problem.name(); + return super.getPacketString() + ", problem=" + (problem != null ? problem.name() : null); } } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java index 11be907..5da3bcd 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/qourum/QuorumManager.java @@ -42,6 +42,8 @@ import org.apache.activemq.artemis.core.server.ActiveMQServerLogger; import org.apache.activemq.artemis.core.server.cluster.ClusterControl; import org.apache.activemq.artemis.core.server.cluster.ClusterController; +import static org.apache.activemq.artemis.utils.Preconditions.checkNotNull; + /** * A QourumManager can be used to register a {@link org.apache.activemq.artemis.core.server.cluster.qourum.Quorum} to receive notifications * about changes to the cluster. A {@link org.apache.activemq.artemis.core.server.cluster.qourum.Quorum} can then issue a vote to the @@ -73,6 +75,9 @@ public final class QuorumManager implements ClusterTopologyListener, ActiveMQCom private int maxClusterSize = 0; public QuorumManager(ExecutorService threadPool, ClusterController clusterController) { + checkNotNull(threadPool); + checkNotNull(clusterController); + this.clusterController = clusterController; this.executor = threadPool; } diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/MessageReferenceImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/MessageReferenceImpl.java index 4938a1b..0d4074c 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/MessageReferenceImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/MessageReferenceImpl.java @@ -321,11 +321,16 @@ public class MessageReferenceImpl extends LinkedListImpl.Node<MessageReferenceIm @Override public String toString() { - return "Reference[" + getMessage().getMessageID() + - "]:" + - (getMessage().isDurable() ? "RELIABLE" : "NON-RELIABLE") + - ":" + - getMessage(); + Message message = getMessage(); + if (message != null) { + return "Reference[" + message.getMessageID() + + "]:" + + (message.isDurable() ? "RELIABLE" : "NON-RELIABLE") + + ":" + + message; + } else { + return "Reference[]"; + } } @Override diff --git a/tests/unit-tests/pom.xml b/tests/unit-tests/pom.xml index d56f758..3f0b923 100644 --- a/tests/unit-tests/pom.xml +++ b/tests/unit-tests/pom.xml @@ -174,6 +174,10 @@ <groupId>com.google.errorprone</groupId> <artifactId>error_prone_core</artifactId> </dependency> + <dependency> + <groupId>org.mockito</groupId> + <artifactId>mockito-core</artifactId> + </dependency> </dependencies> diff --git a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/AllClassesTest.java b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/AllClassesTest.java new file mode 100644 index 0000000..6183e9c --- /dev/null +++ b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/AllClassesTest.java @@ -0,0 +1,138 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.activemq.artemis.tests.unit; + +import com.google.common.collect.ImmutableSet; +import com.google.common.reflect.ClassPath; +import org.apache.activemq.artemis.tests.util.RandomUtil; +import org.jboss.logging.Logger; +import org.junit.Assume; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; +import org.mockito.Mockito; + +import java.lang.reflect.Constructor; +import java.lang.reflect.Modifier; +import java.lang.reflect.Parameter; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.List; + +@RunWith(value = Parameterized.class) +public class AllClassesTest { + private static final Logger log = Logger.getLogger(AllClassesTest.class); + + private static ClassLoader classLoader = AllClassesTest.class.getClassLoader(); + + @Parameterized.Parameters(name = "classInfo={0}") + public static Collection getParameters() { + List<Class> parameters = new ArrayList<>(); + ClassLoader classLoader = AllClassesTest.class.getClassLoader(); + + try { + ClassPath classPath = ClassPath.from(classLoader); + ImmutableSet<ClassPath.ClassInfo> classInfos = classPath.getTopLevelClassesRecursive("org.apache.activemq.artemis"); + + for (ClassPath.ClassInfo classInfo : classInfos) { + if (!classInfo.getPackageName().contains("tests")) { + try { + Class loadedClass = classInfo.load(); + if (!loadedClass.isEnum() && !loadedClass.isInterface() && !Modifier.isAbstract(loadedClass.getModifiers())) { + parameters.add(loadedClass); + } + } catch (Throwable loadThrowable) { + log.debug("cannot load " + classInfo.getName() + ": " + loadThrowable); + } + } + } + return parameters; + } catch (Exception e) { + log.warn("Exception on loading all classes: " + e); + } + + return parameters; + } + + private Class targetClass; + + public AllClassesTest(Class targetClass) { + this.targetClass = targetClass; + } + + + @Test + public void testToString() { + Object targetInstance = newInstance(targetClass); + Assume.assumeTrue("cannot create " + targetClass.getName(), targetInstance != null); + + String targetOutput = targetInstance.toString(); + log.debug("targetOutput: " + targetOutput); + } + + private Object newInstance(Class targetClass) { + + Constructor[] targetConstructors = targetClass.getDeclaredConstructors(); + Arrays.sort(targetConstructors, (c1, c2) -> c2.getParameterCount() - c1.getParameterCount()); + for (Constructor targetConstructor : targetConstructors) { + List<Object> initArgs = new ArrayList<>(); + Parameter[] constructorParameters = targetConstructor.getParameters(); + + for (Parameter constructorParameter : constructorParameters) { + Object initArg = null; + if (constructorParameter.getType().isAssignableFrom(byte.class)) { + initArg = RandomUtil.randomByte(); + } else if (constructorParameter.getType().isAssignableFrom(byte[].class)) { + initArg = RandomUtil.randomBytes(); + } else if (constructorParameter.getType().isAssignableFrom(boolean.class)) { + initArg = RandomUtil.randomBoolean(); + } else if (constructorParameter.getType().isAssignableFrom(char.class)) { + initArg = RandomUtil.randomChar(); + } else if (constructorParameter.getType().isAssignableFrom(double.class)) { + initArg = RandomUtil.randomDouble(); + } else if (constructorParameter.getType().isAssignableFrom(float.class)) { + initArg = RandomUtil.randomFloat(); + } else if (constructorParameter.getType().isAssignableFrom(int.class)) { + initArg = RandomUtil.randomInt() / 1024; + } else if (constructorParameter.getType().isAssignableFrom(long.class)) { + initArg = RandomUtil.randomLong(); + } else if (constructorParameter.getType().isAssignableFrom(String.class)) { + initArg = RandomUtil.randomString(); + } else { + initArg = null; + } + initArgs.add(initArg); + } + + try { + return targetConstructor.newInstance(initArgs.toArray()); + } catch (Throwable createThrowable) { + log.debug("cannot construct " + targetClass.getName() + ": " + createThrowable); + } + } + + try { + return Mockito.spy(targetClass); + } catch (Throwable spyThrowable) { + log.debug("cannot spy " + targetClass.getName() + ": " + spyThrowable); + } + + return null; + } +}
