readFieldsAsMap(Object object) {
* {@link java.lang.reflect.InaccessibleObjectException}, false otherwise.
*/
public static boolean isInaccessibleObjectException(Throwable failure) {
- return failure != null && INACCESSIBLE_OBJECT_EXCEPTION_CLASS_NAME.equals(failure.getClass().getName());
+ return isInaccessibleObjectException(getType(failure));
}
- private ReflectionUtils() {
+ /**
+ * Checks whether the specified {@link Class} represents
+ * {@link java.lang.reflect.InaccessibleObjectException}.
+ *
+ * This method is useful when dealing with reflection operations that may fail due to module system
+ * restrictions introduced in JDK 9+. It avoids direct dependency on the presence of the class, which
+ * may not be available in earlier JDK versions.
+ *
+ * Example Usage
+ * {@code
+ * Class exceptionClass = SomeException.class;
+ * if (ReflectionUtils.isInaccessibleObjectException(exceptionClass)) {
+ * System.err.println("The class represents InaccessibleObjectException");
+ * } else {
+ * System.out.println("The class does not represent InaccessibleObjectException");
+ * }
+ * }
+ *
+ * @param throwableClass The {@link Class} to check.
+ * @return true if the specified {@link Class} represents
+ * {@link java.lang.reflect.InaccessibleObjectException}, false otherwise.
+ */
+ public static boolean isInaccessibleObjectException(Class throwableClass) {
+ return isInaccessibleObjectException(getTypeName(throwableClass));
}
+ static boolean isInaccessibleObjectException(String className) {
+ return INACCESSIBLE_OBJECT_EXCEPTION_CLASS_NAME.equals(className);
+ }
+
+ private ReflectionUtils() {
+ }
}
\ No newline at end of file
diff --git a/microsphere-java-core/src/main/java/io/microsphere/reflect/TypeUtils.java b/microsphere-java-core/src/main/java/io/microsphere/reflect/TypeUtils.java
index e0b2a6e60..d105b4059 100644
--- a/microsphere-java-core/src/main/java/io/microsphere/reflect/TypeUtils.java
+++ b/microsphere-java-core/src/main/java/io/microsphere/reflect/TypeUtils.java
@@ -646,7 +646,9 @@ static List doResolveActualTypeArgumentsInFastPath(Type type) {
}
@Nonnull
- private static Map resolveTypeArgumentsMap(Type type, List hierarchicalTypes, int hierarchicalTypesSize, Class baseClass, TypeVariable[] baseTypeParameters) {
+ private static Map resolveTypeArgumentsMap(Type type, List hierarchicalTypes,
+ int hierarchicalTypesSize, Class baseClass,
+ TypeVariable[] baseTypeParameters) {
int size = hierarchicalTypesSize + 1;
@@ -663,14 +665,18 @@ private static Map resolveTypeArgumentsMap(Type type, Lis
return typeArgumentsMap;
}
- private static void resolveTypeArgumentsMap(Type type, List hierarchicalTypes, int index, int hierarchicalTypesSize, Map typeArgumentsMap, Class baseClass, TypeVariable[] baseTypeParameters) {
+ private static void resolveTypeArgumentsMap(Type type, List hierarchicalTypes, int index,
+ int hierarchicalTypesSize, Map typeArgumentsMap,
+ Class baseClass, TypeVariable[] baseTypeParameters) {
ParameterizedType pType = asParameterizedType(type);
if (pType != null) {
resolveTypeArgumentsMap(pType, hierarchicalTypes, index, hierarchicalTypesSize, typeArgumentsMap, baseClass, baseTypeParameters);
}
}
- private static void resolveTypeArgumentsMap(ParameterizedType type, List hierarchicalTypes, int index, int hierarchicalTypesSize, Map typeArgumentsMap, Class baseClass, TypeVariable[] baseTypeParameters) {
+ private static void resolveTypeArgumentsMap(ParameterizedType type, List hierarchicalTypes, int index,
+ int hierarchicalTypesSize, Map typeArgumentsMap,
+ Class baseClass, TypeVariable[] baseTypeParameters) {
Class klass = asClass(type);
int baseTypeArgumentsLength = baseTypeParameters.length;
@@ -1192,7 +1198,7 @@ public static List resolveTypeArguments(Class targetClass) {
return emptyList();
}
List typeArguments = newLinkedList();
- while (targetClass != null && targetClass != Object.class) {
+ while (targetClass != Object.class) {
typeArguments.addAll(resolveTypeArguments(targetClass.getGenericSuperclass()));
typeArguments.addAll(resolveTypeArguments(targetClass.getGenericInterfaces()));
targetClass = targetClass.getSuperclass();
diff --git a/microsphere-java-core/src/main/java/io/microsphere/util/Assert.java b/microsphere-java-core/src/main/java/io/microsphere/util/Assert.java
index 362d81bad..262f56136 100644
--- a/microsphere-java-core/src/main/java/io/microsphere/util/Assert.java
+++ b/microsphere-java-core/src/main/java/io/microsphere/util/Assert.java
@@ -502,4 +502,7 @@ public static void assertFieldMatchType(Object object, String fieldName, Class messageSupplier) {
return messageSupplier == null ? null : messageSupplier.get();
}
-}
+
+ private Assert() {
+ }
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/main/java/io/microsphere/util/StringUtils.java b/microsphere-java-core/src/main/java/io/microsphere/util/StringUtils.java
index b8e92bf57..f5e8da389 100644
--- a/microsphere-java-core/src/main/java/io/microsphere/util/StringUtils.java
+++ b/microsphere-java-core/src/main/java/io/microsphere/util/StringUtils.java
@@ -173,7 +173,7 @@ public static String[] split(@Nullable String value, @Nullable String delimiter)
List result = new ArrayList<>();
if (delimiterLength == 0) {
- for (int i = 0; i < value.length(); i++) {
+ for (int i = 0; i < length; i++) {
result.add(value.substring(i, i + 1));
}
} else {
@@ -882,6 +882,5 @@ static String trimWhitespace(String str, boolean includeLeading, boolean include
}
private StringUtils() {
- super();
}
-}
+}
\ No newline at end of file
diff --git a/microsphere-annotation-processor/src/test/java/io/microsphere/annotation/processor/model/ArrayTypeModel.java b/microsphere-java-core/src/main/java/io/microsphere/util/ThrowableUtils.java
similarity index 62%
rename from microsphere-annotation-processor/src/test/java/io/microsphere/annotation/processor/model/ArrayTypeModel.java
rename to microsphere-java-core/src/main/java/io/microsphere/util/ThrowableUtils.java
index fc6c057f3..8f6d32c23 100644
--- a/microsphere-annotation-processor/src/test/java/io/microsphere/annotation/processor/model/ArrayTypeModel.java
+++ b/microsphere-java-core/src/main/java/io/microsphere/util/ThrowableUtils.java
@@ -14,23 +14,27 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package io.microsphere.annotation.processor.model;
+
+package io.microsphere.util;
/**
- * Array Type Model
+ * The uitlities class for {@link Throwable}
*
+ * @author Mercy
+ * @see Throwable
* @since 1.0.0
*/
-public class ArrayTypeModel {
-
- private int[] integers; // Primitive type array
-
- private String[] strings; // Simple type array
-
- private PrimitiveTypeModel[] primitiveTypeModels; // Complex type array
+public abstract class ThrowableUtils implements Utils {
- private Model[] models; // Hierarchical Complex type array
+ public static Throwable getRootCause(Throwable throwable) {
+ Throwable rootCause = throwable;
+ while (rootCause.getCause() != null) {
+ rootCause = rootCause.getCause();
+ }
+ return rootCause;
+ }
- private Color[] colors; // Enum type array
+ private ThrowableUtils() {
+ }
}
diff --git a/microsphere-java-core/src/test/java/io/microsphere/classloading/BannedArtifactClassLoadingExecutorTest.java b/microsphere-java-core/src/test/java/io/microsphere/classloading/BannedArtifactClassLoadingExecutorTest.java
index f5e15dff7..f94a96960 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/classloading/BannedArtifactClassLoadingExecutorTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/classloading/BannedArtifactClassLoadingExecutorTest.java
@@ -18,6 +18,15 @@
import org.junit.jupiter.api.Test;
+import java.io.IOException;
+import java.net.URL;
+import java.util.Enumeration;
+
+import static io.microsphere.classloading.BannedArtifactClassLoadingExecutor.loadBannedArtifactConfig;
+import static io.microsphere.classloading.BannedArtifactClassLoadingExecutor.loadBannedArtifactConfigs;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
/**
* {@link BannedArtifactClassLoadingExecutor} Test
*
@@ -26,10 +35,25 @@
*/
class BannedArtifactClassLoadingExecutorTest {
- private BannedArtifactClassLoadingExecutor detector = new BannedArtifactClassLoadingExecutor();
-
@Test
void testDetect() {
+ BannedArtifactClassLoadingExecutor detector = new BannedArtifactClassLoadingExecutor();
detector.execute();
}
-}
+
+ @Test
+ void testLoadBannedArtifactConfigsOnFailed() {
+ ClassLoader classLoader = new ClassLoader() {
+ @Override
+ public Enumeration getResources(String name) throws IOException {
+ throw new IOException("For testing");
+ }
+ };
+ assertTrue(loadBannedArtifactConfigs(classLoader).isEmpty());
+ }
+
+ @Test
+ void testLoadBannedArtifactConfigOnFailed() {
+ assertThrows(IllegalArgumentException.class, () -> loadBannedArtifactConfig("invalid-definition"));
+ }
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/test/java/io/microsphere/collection/AbstractDequeTest.java b/microsphere-java-core/src/test/java/io/microsphere/collection/AbstractDequeTest.java
index eb6aa11fe..df8696b1b 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/collection/AbstractDequeTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/collection/AbstractDequeTest.java
@@ -3,9 +3,7 @@
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
-import java.util.Iterator;
import java.util.NoSuchElementException;
-import java.util.Objects;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNull;
@@ -28,107 +26,7 @@ class AbstractDequeTest {
@BeforeEach
void setUp() {
-
- deque = new AbstractDeque() {
-
- private String value;
-
- @Override
- public Iterator iterator() {
- return new Iterator() {
-
- private int cursor = 0;
-
- @Override
- public boolean hasNext() {
- return cursor == 0;
- }
-
- @Override
- public String next() {
- if (cursor++ == 0) {
- return value;
- } else {
- throw new NoSuchElementException();
- }
- }
-
- @Override
- public void remove() {
- if (cursor <= 1) {
- value = null;
- } else {
- throw new NoSuchElementException();
- }
- }
- };
- }
-
- @Override
- public Iterator descendingIterator() {
- return iterator();
- }
-
- @Override
- public boolean offerFirst(String s) {
- if (value == null) {
- value = s;
- return true;
- }
- return false;
- }
-
- @Override
- public boolean offerLast(String s) {
- return offerFirst(s);
- }
-
- @Override
- public String pollFirst() {
- String s = value;
- value = null;
- return s;
- }
-
- @Override
- public String pollLast() {
- return pollFirst();
- }
-
- @Override
- public String getFirst() {
- return value;
- }
-
- @Override
- public String getLast() {
- return getFirst();
- }
-
- @Override
- public String peekFirst() {
- return value;
- }
-
- @Override
- public String peekLast() {
- return value;
- }
-
- @Override
- public boolean removeLastOccurrence(Object o) {
- if (Objects.equals(o, value)) {
- value = null;
- return true;
- }
- return false;
- }
-
- @Override
- public int size() {
- return 1;
- }
- };
+ deque = new TestDeque<>(1);
}
@Test
@@ -189,7 +87,7 @@ void testPeekLast() {
@Test
void testRemoveFirstOccurrence() {
- assertTrue(deque.removeFirstOccurrence(null));
+ assertFalse(deque.removeFirstOccurrence(null));
deque.add(TEST_VALUE);
assertFalse(deque.removeFirstOccurrence(""));
assertTrue(deque.removeFirstOccurrence(TEST_VALUE));
diff --git a/microsphere-java-core/src/test/java/io/microsphere/collection/DelegatingIteratorTest.java b/microsphere-java-core/src/test/java/io/microsphere/collection/DelegatingIteratorTest.java
new file mode 100644
index 000000000..f29382d37
--- /dev/null
+++ b/microsphere-java-core/src/test/java/io/microsphere/collection/DelegatingIteratorTest.java
@@ -0,0 +1,100 @@
+/*
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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 io.microsphere.collection;
+
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.util.Iterator;
+import java.util.List;
+import java.util.NoSuchElementException;
+
+import static io.microsphere.collection.ListUtils.ofArrayList;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+/**
+ * {@link DelegatingIterator} Test
+ *
+ * @author Mercy
+ * @see DelegatingIterator
+ * @since 1.0.0
+ */
+class DelegatingIteratorTest {
+
+ private Iterator iterator;
+
+ private DelegatingIterator delegatingIterator;
+
+ @BeforeEach
+ void setUp() {
+ List list = ofArrayList("1", "2", "3");
+ this.iterator = list.iterator();
+ this.delegatingIterator = new DelegatingIterator<>(this.iterator);
+ }
+
+ @Test
+ void testHasNext() {
+ assertTrue(delegatingIterator.hasNext());
+ }
+
+ @Test
+ void testNext() {
+ assertEquals("1", this.delegatingIterator.next());
+ assertEquals("2", this.delegatingIterator.next());
+ assertEquals("3", this.delegatingIterator.next());
+ assertThrows(NoSuchElementException.class, this.delegatingIterator::next);
+ }
+
+ @Test
+ void testRemove() {
+ while (this.delegatingIterator.hasNext()) {
+ this.delegatingIterator.next();
+ this.delegatingIterator.remove();
+ }
+ }
+
+ @Test
+ void testForEachRemaining() {
+ this.delegatingIterator.forEachRemaining(Assertions::assertNotNull);
+ }
+
+ @Test
+ void testGetDelegate() {
+ assertSame(this.delegatingIterator.getDelegate(), this.iterator);
+ }
+
+ @Test
+ void testHashCode() {
+ assertEquals(this.delegatingIterator.hashCode(), this.iterator.hashCode());
+ }
+
+ @Test
+ void testEquals() {
+ assertEquals(this.delegatingIterator, this.iterator);
+ }
+
+ @Test
+ void testToString() {
+ assertEquals(this.delegatingIterator.toString(), this.iterator.toString());
+ }
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/test/java/io/microsphere/collection/TestDeque.java b/microsphere-java-core/src/test/java/io/microsphere/collection/TestDeque.java
new file mode 100644
index 000000000..f14674a7b
--- /dev/null
+++ b/microsphere-java-core/src/test/java/io/microsphere/collection/TestDeque.java
@@ -0,0 +1,194 @@
+/*
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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 io.microsphere.collection;
+
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.Spliterator;
+import java.util.function.Consumer;
+import java.util.function.Predicate;
+import java.util.stream.Stream;
+
+import static java.lang.Integer.MAX_VALUE;
+
+/**
+ * {@link AbstractDeque} class for testing
+ *
+ * @author Mercy
+ * @see AbstractDeque
+ * @since 1.0.0
+ */
+public class TestDeque extends AbstractDeque {
+
+ private final int maxCapacity;
+
+ private final LinkedList delegate = new LinkedList<>();
+
+ public TestDeque() {
+ this(MAX_VALUE);
+ }
+
+ public TestDeque(int maxCapacity) {
+ this.maxCapacity = maxCapacity;
+ }
+
+ @Override
+ public void addFirst(E e) {
+ super.addFirst(e);
+ }
+
+ @Override
+ public void addLast(E e) {
+ super.addLast(e);
+ }
+
+ @Override
+ public E removeFirst() {
+ return super.removeFirst();
+ }
+
+ @Override
+ public E removeLast() {
+ return super.removeLast();
+ }
+
+ @Override
+ public boolean removeFirstOccurrence(Object o) {
+ return super.removeFirstOccurrence(o);
+ }
+
+ @Override
+ public void push(E e) {
+ super.push(e);
+ }
+
+ @Override
+ public E pop() {
+ return super.pop();
+ }
+
+ @Override
+ public boolean offer(E e) {
+ return super.offer(e);
+ }
+
+ @Override
+ public E poll() {
+ return super.poll();
+ }
+
+ @Override
+ public E peek() {
+ return super.peek();
+ }
+
+ @Override
+ public Iterator iterator() {
+ return delegate.iterator();
+ }
+
+ @Override
+ public void forEach(Consumer action) {
+ delegate.forEach(action);
+ }
+
+ @Override
+ public boolean removeIf(Predicate filter) {
+ return delegate.removeIf(filter);
+ }
+
+ @Override
+ public Spliterator spliterator() {
+ return delegate.spliterator();
+ }
+
+ @Override
+ public Stream stream() {
+ return delegate.stream();
+ }
+
+ @Override
+ public Stream parallelStream() {
+ return delegate.parallelStream();
+ }
+
+ @Override
+ public Iterator descendingIterator() {
+ return delegate.descendingIterator();
+ }
+
+ @Override
+ public boolean offerFirst(E e) {
+ if (isFull()) {
+ return false;
+ }
+ return delegate.offerFirst(e);
+ }
+
+ @Override
+ public boolean offerLast(E e) {
+ if (isFull()) {
+ return false;
+ }
+ return delegate.offerLast(e);
+ }
+
+ @Override
+ public E pollFirst() {
+ return delegate.pollFirst();
+ }
+
+ @Override
+ public E pollLast() {
+ return delegate.pollLast();
+ }
+
+ @Override
+ public E getFirst() {
+ return delegate.getFirst();
+ }
+
+ @Override
+ public E getLast() {
+ return delegate.getLast();
+ }
+
+ @Override
+ public E peekFirst() {
+ return delegate.peekFirst();
+ }
+
+ @Override
+ public E peekLast() {
+ return delegate.peekLast();
+ }
+
+ @Override
+ public boolean removeLastOccurrence(Object o) {
+ return delegate.removeLastOccurrence(o);
+ }
+
+ @Override
+ public int size() {
+ return delegate.size();
+ }
+
+ public boolean isFull() {
+ return this.size() >= this.maxCapacity;
+ }
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/test/java/io/microsphere/concurrent/ExecutorUtilsTest.java b/microsphere-java-core/src/test/java/io/microsphere/concurrent/ExecutorUtilsTest.java
index ec6866136..26d821203 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/concurrent/ExecutorUtilsTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/concurrent/ExecutorUtilsTest.java
@@ -1,17 +1,24 @@
package io.microsphere.concurrent;
import io.microsphere.AbstractTestCase;
+import io.microsphere.util.ShutdownHookUtils;
+import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import java.util.Iterator;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
+import java.util.concurrent.PriorityBlockingQueue;
import static io.microsphere.concurrent.CustomizedThreadFactory.newThreadFactory;
import static io.microsphere.concurrent.ExecutorUtils.shutdown;
import static io.microsphere.concurrent.ExecutorUtils.shutdownOnExit;
+import static io.microsphere.reflect.FieldUtils.getStaticFieldValue;
import static java.util.concurrent.Executors.newSingleThreadExecutor;
+import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
/**
@@ -27,19 +34,41 @@ class ExecutorUtilsTest extends AbstractTestCase {
@BeforeEach
void setUp() {
- executorService = newSingleThreadExecutor(newThreadFactory("ExecutorUtilsTest-", true));
- executorService.execute(() -> log("Running..."));
+ this.executorService = newSingleThreadExecutor(newThreadFactory("ExecutorUtilsTest-", true));
+ this.executorService.execute(() -> log("Running..."));
+ }
+
+ @AfterEach
+ void tearDown() {
+ this.executorService.shutdown();
}
@Test
- void testShutdownOnExit() {
- shutdownOnExit(executorService, executorService, executorService);
+ void testShutdownOnExit() throws InterruptedException {
+ shutdownOnExit(this.executorService, this.executorService, this.executorService);
+ PriorityBlockingQueue shutdownHookCallbacks = getStaticFieldValue(ShutdownHookUtils.class, "shutdownHookCallbacks");
+ assertNotNull(shutdownHookCallbacks);
+
+ Iterator iterator = shutdownHookCallbacks.iterator();
+ String classNamePrefix = ExecutorUtils.class.getName() + "$$Lambda/";
+ while (iterator.hasNext()) {
+ Runnable callback = iterator.next();
+ Class callbackClass = callback.getClass();
+ String callbackClassName = callbackClass.getName();
+ if (callbackClassName.startsWith(classNamePrefix)) {
+ callback.run();
+ iterator.remove();
+ }
+ }
+ if (this.executorService.awaitTermination(50, MILLISECONDS)) {
+ assertTrue(this.executorService.isShutdown());
+ }
}
@Test
void testShutdownForExecutor() {
- assertTrue(shutdown((Executor) executorService));
- assertTrue(shutdown((Executor) executorService));
+ assertTrue(shutdown((Executor) this.executorService));
+ assertTrue(shutdown((Executor) this.executorService));
}
@Test
@@ -49,8 +78,8 @@ void testShutdownForExecutorOnNull() {
@Test
void testShutdownForExecutorService() {
- assertTrue(shutdown(executorService));
- assertTrue(shutdown(executorService));
+ assertTrue(shutdown(this.executorService));
+ assertTrue(shutdown(this.executorService));
}
@Test
diff --git a/microsphere-java-core/src/test/java/io/microsphere/convert/AbstractConverterTest.java b/microsphere-java-core/src/test/java/io/microsphere/convert/AbstractConverterTest.java
index b8a2273d3..5148e64ad 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/convert/AbstractConverterTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/convert/AbstractConverterTest.java
@@ -44,8 +44,14 @@ protected Object doConvert(Object source) throws Throwable {
@Override
protected Integer resolvePriority() {
+ super.resolvePriority();
return null;
}
+
+ @Override
+ public int getPriority() {
+ return super.getPriority();
+ }
};
}
@@ -76,4 +82,8 @@ void testGetConverter() {
assertNotEquals(this.converter, new Object());
}
+ @Test
+ void testEquals() {
+ assertEquals(this.converter, this.converter);
+ }
}
diff --git a/microsphere-java-core/src/test/java/io/microsphere/json/JSONUtilsTest.java b/microsphere-java-core/src/test/java/io/microsphere/json/JSONUtilsTest.java
index 76420059c..d50fa6507 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/json/JSONUtilsTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/json/JSONUtilsTest.java
@@ -46,6 +46,7 @@
import static io.microsphere.collection.Sets.ofSet;
import static io.microsphere.json.JSONObject.NULL;
import static io.microsphere.json.JSONUtils.append;
+import static io.microsphere.json.JSONUtils.appendName;
import static io.microsphere.json.JSONUtils.convertValue;
import static io.microsphere.json.JSONUtils.determineElementClass;
import static io.microsphere.json.JSONUtils.escape;
@@ -99,219 +100,219 @@ void setUp() {
@Test
void testAppendOnBoolean() {
- append(jsonBuilder, "name", true);
- assertEquals("\"name\":true", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", true);
+ assertEquals("\"name\":true", this.jsonBuilder.toString());
}
@Test
void testAppendOnByte() {
- append(jsonBuilder, "name", (byte) 1);
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", (byte) 1);
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnShort() {
- append(jsonBuilder, "name", (short) 1);
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", (short) 1);
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnInt() {
- append(jsonBuilder, "name", 1);
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", 1);
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnLong() {
- append(jsonBuilder, "name", 1L);
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", 1L);
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnFloat() {
- append(jsonBuilder, "name", 1.0f);
- assertEquals("\"name\":1.0", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", 1.0f);
+ assertEquals("\"name\":1.0", this.jsonBuilder.toString());
}
@Test
void testAppendOnDouble() {
- append(jsonBuilder, "name", 1.0);
- assertEquals("\"name\":1.0", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", 1.0);
+ assertEquals("\"name\":1.0", this.jsonBuilder.toString());
}
@Test
void testAppendOnChar() {
- append(jsonBuilder, "name", 'a');
- assertEquals("\"name\":\"a\"", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", 'a');
+ assertEquals("\"name\":\"a\"", this.jsonBuilder.toString());
}
@Test
void testAppendOnBooleanObject() {
- append(jsonBuilder, "name", TRUE);
- assertEquals("\"name\":true", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", TRUE);
+ assertEquals("\"name\":true", this.jsonBuilder.toString());
}
@Test
void testAppendOnByteObject() {
- append(jsonBuilder, "name", valueOf((byte) 1));
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", valueOf((byte) 1));
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnShortObject() {
- append(jsonBuilder, "name", Short.valueOf((short) 1));
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", Short.valueOf((short) 1));
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnIntegerObject() {
- append(jsonBuilder, "name", Integer.valueOf(1));
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", Integer.valueOf(1));
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnLongObject() {
- append(jsonBuilder, "name", Long.valueOf(1L));
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", Long.valueOf(1L));
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnFloatObject() {
- append(jsonBuilder, "name", Float.valueOf(1.0f));
- assertEquals("\"name\":1.0", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", Float.valueOf(1.0f));
+ assertEquals("\"name\":1.0", this.jsonBuilder.toString());
}
@Test
void testAppendOnDoubleObject() {
- append(jsonBuilder, "name", Double.valueOf(1.0));
- assertEquals("\"name\":1.0", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", Double.valueOf(1.0));
+ assertEquals("\"name\":1.0", this.jsonBuilder.toString());
}
@Test
void testAppendOnCharacterObject() {
- append(jsonBuilder, "name", valueOf('a'));
- assertEquals("\"name\":\"a\"", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", valueOf('a'));
+ assertEquals("\"name\":\"a\"", this.jsonBuilder.toString());
}
@Test
void testAppendOnString() {
- append(jsonBuilder, "name", "a");
- assertEquals("\"name\":\"a\"", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", "a");
+ assertEquals("\"name\":\"a\"", this.jsonBuilder.toString());
}
@Test
void testAppendOnType() {
- append(jsonBuilder, "name", String.class);
- assertEquals("\"name\":\"java.lang.String\"", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", String.class);
+ assertEquals("\"name\":\"java.lang.String\"", this.jsonBuilder.toString());
}
@Test
void testAppendOnBooleanObjectArray() {
- append(jsonBuilder, "name", new Boolean[]{TRUE, FALSE});
- assertEquals("\"name\":[true,false]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Boolean[]{TRUE, FALSE});
+ assertEquals("\"name\":[true,false]", this.jsonBuilder.toString());
}
@Test
void testAppendOnByteObjectArray() {
- append(jsonBuilder, "name", new Byte[]{(byte) 1, (byte) 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Byte[]{(byte) 1, (byte) 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnShortObjectArray() {
- append(jsonBuilder, "name", new Short[]{(short) 1, (short) 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Short[]{(short) 1, (short) 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnIntegerObjectArray() {
- append(jsonBuilder, "name", new Integer[]{1, 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Integer[]{1, 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnLongObjectArray() {
- append(jsonBuilder, "name", new Long[]{1L, 2L});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Long[]{1L, 2L});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnFloatObjectArray() {
- append(jsonBuilder, "name", new Float[]{1.0f, 2.0f});
- assertEquals("\"name\":[1.0,2.0]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Float[]{1.0f, 2.0f});
+ assertEquals("\"name\":[1.0,2.0]", this.jsonBuilder.toString());
}
@Test
void testAppendOnDoubleObjectArray() {
- append(jsonBuilder, "name", new Double[]{1.0, 2.0});
- assertEquals("\"name\":[1.0,2.0]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Double[]{1.0, 2.0});
+ assertEquals("\"name\":[1.0,2.0]", this.jsonBuilder.toString());
}
@Test
void testAppendOnCharacterObjectArray() {
- append(jsonBuilder, "name", new Character[]{'a', 'b'});
- assertEquals("\"name\":[\"a\",\"b\"]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new Character[]{'a', 'b'});
+ assertEquals("\"name\":[\"a\",\"b\"]", this.jsonBuilder.toString());
}
@Test
void testAppendOnBooleanArray() {
- append(jsonBuilder, "name", new boolean[]{true, false});
- assertEquals("\"name\":[true,false]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new boolean[]{true, false});
+ assertEquals("\"name\":[true,false]", this.jsonBuilder.toString());
}
@Test
void testAppendOnByteArray() {
- append(jsonBuilder, "name", new byte[]{1, 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new byte[]{1, 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnShortArray() {
- append(jsonBuilder, "name", new short[]{1, 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new short[]{1, 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnIntegerArray() {
- append(jsonBuilder, "name", new int[]{1, 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new int[]{1, 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnLongArray() {
- append(jsonBuilder, "name", new long[]{1, 2});
- assertEquals("\"name\":[1,2]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new long[]{1, 2});
+ assertEquals("\"name\":[1,2]", this.jsonBuilder.toString());
}
@Test
void testAppendOnFloatArray() {
- append(jsonBuilder, "name", new float[]{1.0f, 2.0f});
- assertEquals("\"name\":[1.0,2.0]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new float[]{1.0f, 2.0f});
+ assertEquals("\"name\":[1.0,2.0]", this.jsonBuilder.toString());
}
@Test
void testAppendOnDoubleArray() {
- append(jsonBuilder, "name", new double[]{1.0, 2.0});
- assertEquals("\"name\":[1.0,2.0]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new double[]{1.0, 2.0});
+ assertEquals("\"name\":[1.0,2.0]", this.jsonBuilder.toString());
}
@Test
void testAppendOnCharArray() {
- append(jsonBuilder, "name", new char[]{'a', 'b'});
- assertEquals("\"name\":[\"a\",\"b\"]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new char[]{'a', 'b'});
+ assertEquals("\"name\":[\"a\",\"b\"]", this.jsonBuilder.toString());
}
@Test
void testAppendOnStringArray() {
- append(jsonBuilder, "name", new String[]{"a", "b"});
- assertEquals("\"name\":[\"a\",\"b\"]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", new String[]{"a", "b"});
+ assertEquals("\"name\":[\"a\",\"b\"]", this.jsonBuilder.toString());
}
@Test
void testAppendOnObjectAsArray() {
Object value = new boolean[]{TRUE, FALSE};
- append(jsonBuilder, "name", value);
- assertEquals("\"name\":[true,false]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", value);
+ assertEquals("\"name\":[true,false]", this.jsonBuilder.toString());
}
@Test
@@ -328,44 +329,58 @@ void testAppendOnObjectAsMap() {
"string", "8",
"strings", new String[]{"9", "10"}
);
- append(jsonBuilder, "name", value);
+ append(this.jsonBuilder, "name", value);
}
@Test
void testAppendOnObjectAsIterable() {
Object value = ofList(true, (byte) 1, '2', 3.0, 4.0f, 5L, 6, (short) 7, "8", ofArray("9", "10"));
- append(jsonBuilder, "name", value);
- assertEquals("\"name\":[true,1,\"2\",3.0,4.0,5,6,7,\"8\",[\"9\",\"10\"]]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", value);
+ assertEquals("\"name\":[true,1,\"2\",3.0,4.0,5,6,7,\"8\",[\"9\",\"10\"]]", this.jsonBuilder.toString());
}
@Test
void testAppendOnObjectAsString() {
Object value = "s";
- append(jsonBuilder, "name", value);
- assertEquals("\"name\":\"s\"", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", value);
+ assertEquals("\"name\":\"s\"", this.jsonBuilder.toString());
}
@Test
void testAppendOnObjectAsInteger() {
Object value = 1;
- append(jsonBuilder, "name", value);
- assertEquals("\"name\":1", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", value);
+ assertEquals("\"name\":1", this.jsonBuilder.toString());
}
@Test
void testAppendOnGenericArray() {
TimeUnit[] values = ofArray(DAYS, HOURS, MINUTES);
- append(jsonBuilder, "name", values);
- assertEquals("\"name\":[\"DAYS\",\"HOURS\",\"MINUTES\"]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", values);
+ assertEquals("\"name\":[\"DAYS\",\"HOURS\",\"MINUTES\"]", this.jsonBuilder.toString());
}
@Test
void testAppendOnTypeArray() {
Class[] classes = ofArray(String.class, Integer.class);
- append(jsonBuilder, "name", classes);
- assertEquals("\"name\":[\"java.lang.String\",\"java.lang.Integer\"]", jsonBuilder.toString());
+ append(this.jsonBuilder, "name", classes);
+ assertEquals("\"name\":[\"java.lang.String\",\"java.lang.Integer\"]", this.jsonBuilder.toString());
}
+ @Test
+ void testAppendName() {
+ appendName(this.jsonBuilder, null);
+ assertEquals(EMPTY_STRING, this.jsonBuilder.toString());
+
+ appendName(this.jsonBuilder, "");
+ assertEquals(EMPTY_STRING, this.jsonBuilder.toString());
+
+ appendName(this.jsonBuilder, " ");
+ assertEquals(EMPTY_STRING, this.jsonBuilder.toString());
+
+ appendName(this.jsonBuilder, "name");
+ assertEquals("\"name\":", this.jsonBuilder.toString());
+ }
@Test
void testIsUnknownClass() {
diff --git a/microsphere-java-core/src/test/java/io/microsphere/management/ManagementUtilsTest.java b/microsphere-java-core/src/test/java/io/microsphere/management/ManagementUtilsTest.java
index 7f682bc44..bb40748ba 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/management/ManagementUtilsTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/management/ManagementUtilsTest.java
@@ -1,14 +1,11 @@
package io.microsphere.management;
import io.microsphere.AbstractTestCase;
-import io.microsphere.process.ProcessIdResolver;
import org.junit.jupiter.api.Test;
-import java.util.List;
-
+import static io.microsphere.management.ManagementUtils.currentProcessId;
import static io.microsphere.management.ManagementUtils.getCurrentProcessId;
-import static io.microsphere.process.ProcessIdResolver.UNKNOWN_PROCESS_ID;
-import static io.microsphere.util.ServiceLoaderUtils.loadServicesList;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
/**
@@ -22,16 +19,9 @@ class ManagementUtilsTest extends AbstractTestCase {
@Test
void testGetCurrentProcessId() {
- long currentProcessId = getCurrentProcessId();
- assertTrue(currentProcessId > 0);
- }
-
- @Test
- void testLog() {
- List resolvers = loadServicesList(ProcessIdResolver.class);
- for (ProcessIdResolver resolver : resolvers) {
- ManagementUtils.log(resolver, UNKNOWN_PROCESS_ID);
- }
+ long processId = getCurrentProcessId();
+ assertTrue(processId > 0);
+ assertEquals(currentProcessId, getCurrentProcessId());
}
-}
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/test/java/io/microsphere/net/DelegatingURLConnectionTest.java b/microsphere-java-core/src/test/java/io/microsphere/net/DelegatingURLConnectionTest.java
index 7cfa84144..b2554b3ed 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/net/DelegatingURLConnectionTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/net/DelegatingURLConnectionTest.java
@@ -16,7 +16,6 @@
*/
package io.microsphere.net;
-import io.microsphere.io.IOUtils;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -27,11 +26,16 @@
import java.util.List;
import java.util.Map;
+import static io.microsphere.io.IOUtils.copyToString;
+import static io.microsphere.net.ServiceLoaderURLStreamHandlerFactory.attach;
+import static io.microsphere.net.console.HandlerTest.TEST_CONSOLE_URL;
import static java.lang.System.currentTimeMillis;
+import static java.lang.System.out;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertSame;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -96,207 +100,213 @@ void testGetReadTimeout() {
@Test
void testGetURL() {
- assertEquals(url, urlConnection.getURL());
+ assertEquals(url, this.urlConnection.getURL());
}
@Test
void testGetContentLength() {
- assertEquals(19, urlConnection.getContentLength());
+ assertEquals(19, this.urlConnection.getContentLength());
}
@Test
void testGetContentLengthLong() {
- assertEquals(19, urlConnection.getContentLengthLong());
+ assertEquals(19, this.urlConnection.getContentLengthLong());
}
@Test
void testGetContentType() {
- assertEquals("content/unknown", urlConnection.getContentType());
+ assertEquals("content/unknown", this.urlConnection.getContentType());
}
@Test
void testGetContentEncoding() {
- assertNull(urlConnection.getContentEncoding());
+ assertNull(this.urlConnection.getContentEncoding());
}
@Test
void testGetExpiration() {
- assertEquals(0, urlConnection.getExpiration());
+ assertEquals(0, this.urlConnection.getExpiration());
}
@Test
void testGetDate() {
- assertEquals(0, urlConnection.getDate());
+ assertEquals(0, this.urlConnection.getDate());
}
@Test
void testGetLastModified() {
- assertFalse(urlConnection.getLastModified() > currentTimeMillis());
+ assertFalse(this.urlConnection.getLastModified() > currentTimeMillis());
}
@Test
void testGetHeaderField() {
- assertNull(urlConnection.getHeaderField(NOT_EXISTS_HEADER_NAME));
- assertEquals("19", urlConnection.getHeaderField(CONTENT_LENGTH_HEADER_NAME));
- assertNotNull(urlConnection.getHeaderField(LAST_MODIFIED_HEADER_NAME));
+ assertNull(this.urlConnection.getHeaderField(NOT_EXISTS_HEADER_NAME));
+ assertEquals("19", this.urlConnection.getHeaderField(CONTENT_LENGTH_HEADER_NAME));
+ assertNotNull(this.urlConnection.getHeaderField(LAST_MODIFIED_HEADER_NAME));
}
@Test
void testGetHeaderFields() {
- assertNotNull(urlConnection.getHeaderFields());
+ assertNotNull(this.urlConnection.getHeaderFields());
}
@Test
void testGetHeaderFieldInt() {
- assertEquals(19, urlConnection.getHeaderFieldInt(CONTENT_LENGTH_HEADER_NAME, 10));
- assertEquals(1, urlConnection.getHeaderFieldInt(NOT_EXISTS_HEADER_NAME, 1));
+ assertEquals(19, this.urlConnection.getHeaderFieldInt(CONTENT_LENGTH_HEADER_NAME, 10));
+ assertEquals(1, this.urlConnection.getHeaderFieldInt(NOT_EXISTS_HEADER_NAME, 1));
}
@Test
void testGetHeaderFieldLong() {
- assertEquals(19, urlConnection.getHeaderFieldLong(CONTENT_LENGTH_HEADER_NAME, 10));
- assertEquals(1, urlConnection.getHeaderFieldLong(NOT_EXISTS_HEADER_NAME, 1));
+ assertEquals(19, this.urlConnection.getHeaderFieldLong(CONTENT_LENGTH_HEADER_NAME, 10));
+ assertEquals(1, this.urlConnection.getHeaderFieldLong(NOT_EXISTS_HEADER_NAME, 1));
}
@Test
void testGetHeaderFieldDate() {
long now = currentTimeMillis();
- assertTrue(now > urlConnection.getHeaderFieldDate(LAST_MODIFIED_HEADER_NAME, now));
- assertEquals(now, urlConnection.getHeaderFieldDate(NOT_EXISTS_HEADER_NAME, now));
+ assertTrue(now > this.urlConnection.getHeaderFieldDate(LAST_MODIFIED_HEADER_NAME, now));
+ assertEquals(now, this.urlConnection.getHeaderFieldDate(NOT_EXISTS_HEADER_NAME, now));
}
@Test
void testGetHeaderFieldKey() {
- assertEquals(CONTENT_LENGTH_HEADER_NAME, urlConnection.getHeaderFieldKey(0));
- assertEquals(LAST_MODIFIED_HEADER_NAME, urlConnection.getHeaderFieldKey(1));
- assertNull(urlConnection.getHeaderFieldKey(2));
+ assertEquals(CONTENT_LENGTH_HEADER_NAME, this.urlConnection.getHeaderFieldKey(0));
+ assertEquals(LAST_MODIFIED_HEADER_NAME, this.urlConnection.getHeaderFieldKey(1));
+ assertNull(this.urlConnection.getHeaderFieldKey(2));
}
@Test
void testGetHeaderFieldWithInt() {
- assertEquals("19", urlConnection.getHeaderField(0));
- assertNotNull(urlConnection.getHeaderField(1));
- assertNull(urlConnection.getHeaderFieldKey(2));
+ assertEquals("19", this.urlConnection.getHeaderField(0));
+ assertNotNull(this.urlConnection.getHeaderField(1));
+ assertNull(this.urlConnection.getHeaderFieldKey(2));
}
@Test
void testGetContent() throws IOException {
- urlConnection.getContent();
+ this.urlConnection.getContent();
}
@Test
void testGetContentWithClassArray() throws IOException {
- urlConnection.getContent(new Class[0]);
+ this.urlConnection.getContent(new Class[0]);
}
@Test
void testGetPermission() throws IOException {
- assertNotNull(urlConnection.getPermission());
+ assertNotNull(this.urlConnection.getPermission());
}
@Test
void testGetInputStream() throws Exception {
String encoding = "UTF-8";
String data = "name = 测试名称";
- assertEquals(data, IOUtils.toString(urlConnection.getInputStream(), encoding));
+ assertEquals(data, copyToString(this.urlConnection.getInputStream(), encoding));
}
@Test
- void testGetOutputStream() throws Exception {
- assertThrows(Exception.class, urlConnection::getOutputStream);
+ void testGetOutputStream() throws IOException {
+ assertThrows(Exception.class, this.urlConnection::getOutputStream);
+
+ attach();
+ URL url = new URL(TEST_CONSOLE_URL);
+ URLConnection delegate = url.openConnection();
+ this.urlConnection = new DelegatingURLConnection(delegate);
+ assertSame(out, this.urlConnection.getOutputStream());
}
@Test
void testToString() {
- assertNotNull(urlConnection.toString());
+ assertNotNull(this.urlConnection.toString());
}
@Test
void testSetDoInput() {
- urlConnection.setDoInput(true);
+ this.urlConnection.setDoInput(true);
}
@Test
void testGetDoInput() {
testSetDoInput();
- assertTrue(urlConnection.getDoInput());
+ assertTrue(this.urlConnection.getDoInput());
}
@Test
void testSetDoOutput() {
- urlConnection.setDoOutput(true);
+ this.urlConnection.setDoOutput(true);
}
@Test
void testGetDoOutput() {
testSetDoOutput();
- assertTrue(urlConnection.getDoOutput());
+ assertTrue(this.urlConnection.getDoOutput());
}
@Test
void testSetAllowUserInteraction() {
- urlConnection.setAllowUserInteraction(true);
+ this.urlConnection.setAllowUserInteraction(true);
}
@Test
void testGetAllowUserInteraction() {
testSetAllowUserInteraction();
- assertTrue(urlConnection.getAllowUserInteraction());
+ assertTrue(this.urlConnection.getAllowUserInteraction());
}
@Test
void testSetUseCaches() {
- urlConnection.setUseCaches(true);
+ this.urlConnection.setUseCaches(true);
}
@Test
void testGetUseCaches() {
testSetUseCaches();
- assertTrue(urlConnection.getUseCaches());
+ assertTrue(this.urlConnection.getUseCaches());
}
@Test
void testSetIfModifiedSince() {
long now = currentTimeMillis();
- urlConnection.setIfModifiedSince(now);
+ this.urlConnection.setIfModifiedSince(now);
}
@Test
void testGetIfModifiedSince() {
testSetIfModifiedSince();
- assertTrue(currentTimeMillis() >= urlConnection.getIfModifiedSince());
+ assertTrue(currentTimeMillis() >= this.urlConnection.getIfModifiedSince());
}
@Test
void testSetDefaultUseCaches() {
- urlConnection.setDefaultUseCaches(true);
+ this.urlConnection.setDefaultUseCaches(true);
}
@Test
void testGetDefaultUseCaches() {
- urlConnection.setDefaultUseCaches(true);
- assertTrue(urlConnection.getDefaultUseCaches());
+ this.urlConnection.setDefaultUseCaches(true);
+ assertTrue(this.urlConnection.getDefaultUseCaches());
}
@Test
void testSetRequestProperty() {
- urlConnection.setRequestProperty("key-1", "value-1");
+ this.urlConnection.setRequestProperty("key-1", "value-1");
}
@Test
void testAddRequestProperty() {
- urlConnection.addRequestProperty("key-1", "value-1-1");
- urlConnection.addRequestProperty("key-2", "value-2");
+ this.urlConnection.addRequestProperty("key-1", "value-1-1");
+ this.urlConnection.addRequestProperty("key-2", "value-2");
}
@Test
void testGetRequestProperty() {
- assertNull(urlConnection.getRequestProperty("key-1"));
+ assertNull(this.urlConnection.getRequestProperty("key-1"));
}
@Test
void testGetRequestProperties() {
- Map> requestProperties = urlConnection.getRequestProperties();
+ Map> requestProperties = this.urlConnection.getRequestProperties();
assertNotNull(requestProperties);
}
}
diff --git a/microsphere-java-core/src/test/java/io/microsphere/reflect/ReflectionUtilsTest.java b/microsphere-java-core/src/test/java/io/microsphere/reflect/ReflectionUtilsTest.java
index 9087a231b..6d8c42b7b 100644
--- a/microsphere-java-core/src/test/java/io/microsphere/reflect/ReflectionUtilsTest.java
+++ b/microsphere-java-core/src/test/java/io/microsphere/reflect/ReflectionUtilsTest.java
@@ -1,24 +1,33 @@
package io.microsphere.reflect;
import io.microsphere.AbstractTestCase;
+import io.microsphere.test.Data;
import org.junit.jupiter.api.Test;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import static io.microsphere.collection.Lists.ofList;
+import static io.microsphere.reflect.ReflectionUtils.INACCESSIBLE_OBJECT_EXCEPTION_CLASS;
+import static io.microsphere.reflect.ReflectionUtils.INACCESSIBLE_OBJECT_EXCEPTION_CLASS_NAME;
import static io.microsphere.reflect.ReflectionUtils.getCallerClass;
import static io.microsphere.reflect.ReflectionUtils.getCallerClassInGeneralJVM;
import static io.microsphere.reflect.ReflectionUtils.getCallerClassInSunJVM;
import static io.microsphere.reflect.ReflectionUtils.getCallerClassName;
import static io.microsphere.reflect.ReflectionUtils.getCallerClassNameInGeneralJVM;
import static io.microsphere.reflect.ReflectionUtils.getCallerClassNameInSunJVM;
+import static io.microsphere.reflect.ReflectionUtils.isInaccessibleObjectException;
import static io.microsphere.reflect.ReflectionUtils.isSupportedSunReflectReflection;
import static io.microsphere.reflect.ReflectionUtils.readFieldsAsMap;
import static io.microsphere.reflect.ReflectionUtils.toList;
+import static io.microsphere.reflect.ReflectionUtils.toObject;
+import static io.microsphere.util.ArrayUtils.ofArray;
import static java.util.Arrays.asList;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* {@link ReflectionUtils} Test
@@ -30,7 +39,7 @@
class ReflectionUtilsTest extends AbstractTestCase {
@Test
- void testGetCallerClassX() throws Exception {
+ void testGetCallerClassX() {
Class expectedClass = ReflectionUtilsTest.class;
Class callerClass = getCallerClass();
@@ -90,5 +99,36 @@ void testReadFieldsAsMap() {
value.put("c", "c");
map = readFieldsAsMap(value);
assertFalse(map.isEmpty());
+
+ T t = new T();
+ t.self = t;
+ t.other = new T();
+
+ map = readFieldsAsMap(t);
+ assertFalse(map.isEmpty());
+ }
+
+ @Test
+ void testToObject() {
+ assertNull(toObject(null));
+ assertEquals("test", toObject("test"));
+ assertEquals(ofList("a", "b", "c"), toObject(ofArray("a", "b", "c")));
+ }
+
+ @Test
+ void testIsInaccessibleObjectException() {
+ assertFalse(isInaccessibleObjectException(new RuntimeException()));
+ assertFalse(isInaccessibleObjectException((Throwable) null));
+ assertFalse(isInaccessibleObjectException((Class) null));
+ assertFalse(isInaccessibleObjectException(Class.class));
+ assertEquals(INACCESSIBLE_OBJECT_EXCEPTION_CLASS != null, isInaccessibleObjectException(INACCESSIBLE_OBJECT_EXCEPTION_CLASS));
+ assertTrue(isInaccessibleObjectException(INACCESSIBLE_OBJECT_EXCEPTION_CLASS_NAME));
+ }
+
+ static class T extends Data {
+
+ private T self;
+
+ private T other;
}
}
diff --git a/microsphere-java-core/src/test/java/io/microsphere/util/ThrowableUtilsTest.java b/microsphere-java-core/src/test/java/io/microsphere/util/ThrowableUtilsTest.java
new file mode 100644
index 000000000..883f8e5e1
--- /dev/null
+++ b/microsphere-java-core/src/test/java/io/microsphere/util/ThrowableUtilsTest.java
@@ -0,0 +1,64 @@
+/*
+ * 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
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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 io.microsphere.util;
+
+
+import io.microsphere.lang.function.ThrowableAction;
+import org.junit.jupiter.api.Test;
+
+import static io.microsphere.lang.function.ThrowableAction.execute;
+import static io.microsphere.util.ThrowableUtils.getRootCause;
+import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+/**
+ * {@link ThrowableUtils} Test
+ *
+ * @author Mercy
+ * @see ThrowableUtils
+ * @since 1.0.0
+ */
+class ThrowableUtilsTest {
+
+ @Test
+ void testGetRootCause() {
+ Throwable rootCause = new Throwable("Root Cause");
+ Throwable throwable = new Throwable("Throwable", rootCause);
+ assertSame(rootCause, getRootCause(throwable));
+
+ ThrowableAction action = () -> {
+ throw throwable;
+ };
+
+ execute(action, e -> {
+ assertSame(rootCause, getRootCause(e));
+ });
+
+ assertThrows(NullPointerException.class, () -> {
+ try {
+ ThrowableAction a = () -> {
+ String s = null;
+ s.toString();
+ };
+ a.execute();
+ } catch (Throwable e) {
+ throw getRootCause(e);
+ }
+ });
+ }
+}
\ No newline at end of file
diff --git a/microsphere-java-core/src/test/resources/junit-platform.properties b/microsphere-java-core/src/test/resources/junit-platform.properties
index 1cebb76d5..993f2b029 100644
--- a/microsphere-java-core/src/test/resources/junit-platform.properties
+++ b/microsphere-java-core/src/test/resources/junit-platform.properties
@@ -1 +1,3 @@
-junit.jupiter.extensions.autodetection.enabled = true
\ No newline at end of file
+junit.jupiter.extensions.autodetection.enabled = true
+
+junit.jupiter.execution.parallel.enabled = true
\ No newline at end of file
diff --git a/microsphere-java-dependencies/pom.xml b/microsphere-java-dependencies/pom.xml
index 1f36e1c37..aba268cdb 100644
--- a/microsphere-java-dependencies/pom.xml
+++ b/microsphere-java-dependencies/pom.xml
@@ -23,7 +23,7 @@
io.github.microsphere-projects
- microsphere-annotation-processor
+ microsphere-java-annotations
${revision}
@@ -33,6 +33,30 @@
${revision}