From d2f684ce663c34bd4cced473e7c903cc9b73bc7f Mon Sep 17 00:00:00 2001 From: RedKale <22250530@qq.com> Date: Wed, 24 Feb 2016 11:25:03 +0800 Subject: [PATCH] --- src/org/redkale/boot/ClassFilter.java | 1 + src/org/redkale/boot/NodeServer.java | 1 + src/org/redkale/convert/Writer.java | 1 + src/org/redkale/convert/bson/BsonFactory.java | 1 + src/org/redkale/net/Server.java | 1 + src/org/redkale/net/Transport.java | 2 +- src/org/redkale/net/sncp/ServiceWrapper.java | 1 + src/org/redkale/net/sncp/SncpServer.java | 1 + src/org/redkale/source/EntityCache.java | 1 + src/org/redkale/source/FilterNode.java | 1 + src/org/redkale/util/Attribute.java | 3 +++ src/org/redkale/util/ObjectPool.java | 2 +- 12 files changed, 14 insertions(+), 2 deletions(-) diff --git a/src/org/redkale/boot/ClassFilter.java b/src/org/redkale/boot/ClassFilter.java index 239b98b49..7ae0b1f86 100644 --- a/src/org/redkale/boot/ClassFilter.java +++ b/src/org/redkale/boot/ClassFilter.java @@ -27,6 +27,7 @@ import java.util.regex.*; * @author zhangjx * @param 泛型 */ +@SuppressWarnings("unchecked") public final class ClassFilter { private final Set> entrys = new HashSet<>(); diff --git a/src/org/redkale/boot/NodeServer.java b/src/org/redkale/boot/NodeServer.java index be1e93766..28c913f09 100644 --- a/src/org/redkale/boot/NodeServer.java +++ b/src/org/redkale/boot/NodeServer.java @@ -38,6 +38,7 @@ import org.redkale.util.*; * * @author zhangjx */ +@SuppressWarnings("unchecked") public abstract class NodeServer { //INFO日志的换行符 diff --git a/src/org/redkale/convert/Writer.java b/src/org/redkale/convert/Writer.java index e0069b1fa..190201a8e 100644 --- a/src/org/redkale/convert/Writer.java +++ b/src/org/redkale/convert/Writer.java @@ -65,6 +65,7 @@ public abstract class Writer { * * @param obj 写入的对象 */ + @SuppressWarnings("unchecked") public final void writeObjectField(final EnMember member, Object obj) { Object value = member.attribute.get(obj); if (value == null) return; diff --git a/src/org/redkale/convert/bson/BsonFactory.java b/src/org/redkale/convert/bson/BsonFactory.java index 5eb706f04..67c6a2af7 100644 --- a/src/org/redkale/convert/bson/BsonFactory.java +++ b/src/org/redkale/convert/bson/BsonFactory.java @@ -15,6 +15,7 @@ import org.redkale.convert.*; * * @author zhangjx */ +@SuppressWarnings("unchecked") public final class BsonFactory extends ConvertFactory { private static final BsonFactory instance = new BsonFactory(null, Boolean.getBoolean("convert.bson.tiny")); diff --git a/src/org/redkale/net/Server.java b/src/org/redkale/net/Server.java index 5fbd56461..8fc99cc38 100644 --- a/src/org/redkale/net/Server.java +++ b/src/org/redkale/net/Server.java @@ -116,6 +116,7 @@ public abstract class Server addrs = new HashSet(); + Set addrs = new HashSet<>(); transports.forEach(t -> addrs.addAll(Arrays.asList(t.getRemoteAddresses()))); updateRemoteAddresses(addrs); } diff --git a/src/org/redkale/net/sncp/ServiceWrapper.java b/src/org/redkale/net/sncp/ServiceWrapper.java index 4a50c4028..072666f84 100644 --- a/src/org/redkale/net/sncp/ServiceWrapper.java +++ b/src/org/redkale/net/sncp/ServiceWrapper.java @@ -40,6 +40,7 @@ public final class ServiceWrapper implements Comparable type, T service, String name, String sncpGroup, Set groups, AnyValue conf) { this.service = service; this.conf = conf; diff --git a/src/org/redkale/net/sncp/SncpServer.java b/src/org/redkale/net/sncp/SncpServer.java index f35862e85..b223d7ef0 100644 --- a/src/org/redkale/net/sncp/SncpServer.java +++ b/src/org/redkale/net/sncp/SncpServer.java @@ -21,6 +21,7 @@ import org.redkale.watch.*; * * @author zhangjx */ +@SuppressWarnings("unchecked") public final class SncpServer extends Server { public SncpServer() { diff --git a/src/org/redkale/source/EntityCache.java b/src/org/redkale/source/EntityCache.java index b1703c3fe..5d0c0a8c0 100644 --- a/src/org/redkale/source/EntityCache.java +++ b/src/org/redkale/source/EntityCache.java @@ -24,6 +24,7 @@ import org.redkale.util.*; * @author zhangjx * @param Entity类的泛型 */ +@SuppressWarnings("unchecked") public final class EntityCache { private static final Logger logger = Logger.getLogger(EntityCache.class.getName()); diff --git a/src/org/redkale/source/FilterNode.java b/src/org/redkale/source/FilterNode.java index 32f050d9b..86643f7a3 100644 --- a/src/org/redkale/source/FilterNode.java +++ b/src/org/redkale/source/FilterNode.java @@ -287,6 +287,7 @@ public class FilterNode { return createElementPredicate(cache, join, cache.getAttribute(column)); } + @SuppressWarnings("unchecked") protected final Predicate createElementPredicate(final EntityCache cache, final boolean join, final Attribute attr) { if (attr == null) return null; final String field = join ? (cache.getType().getSimpleName() + "." + attr.field()) : attr.field(); diff --git a/src/org/redkale/util/Attribute.java b/src/org/redkale/util/Attribute.java index 0372746d5..a47f89da9 100644 --- a/src/org/redkale/util/Attribute.java +++ b/src/org/redkale/util/Attribute.java @@ -119,6 +119,7 @@ public interface Attribute { * @param field 字段,如果该字段不存在则抛异常 * @return Attribute对象 */ + @SuppressWarnings("unchecked") public static Attribute create(final java.lang.reflect.Field field) { return create((Class) field.getDeclaringClass(), field.getName(), field, null, null); } @@ -132,6 +133,7 @@ public interface Attribute { * @param field 字段,如果该字段不存在则抛异常 * @return Attribute对象 */ + @SuppressWarnings("unchecked") public static Attribute create(String fieldalias, final java.lang.reflect.Field field) { return create((Class) field.getDeclaringClass(), fieldalias, field, null, null); } @@ -190,6 +192,7 @@ public interface Attribute { * @param setter setter方法 * @return Attribute对象 */ + @SuppressWarnings("unchecked") public static Attribute create(final java.lang.reflect.Method getter, final java.lang.reflect.Method setter) { return create((Class) (getter == null ? setter.getDeclaringClass() : getter.getDeclaringClass()), null, null, getter, setter); } diff --git a/src/org/redkale/util/ObjectPool.java b/src/org/redkale/util/ObjectPool.java index 2518e62ca..a7636a4ae 100644 --- a/src/org/redkale/util/ObjectPool.java +++ b/src/org/redkale/util/ObjectPool.java @@ -58,7 +58,7 @@ public final class ObjectPool implements Supplier { this.creator = creator; this.prepare = prepare; this.recycler = recycler; - this.queue = new LinkedBlockingQueue(Math.max(Runtime.getRuntime().availableProcessors() * 2, max)); + this.queue = new LinkedBlockingQueue<>(Math.max(Runtime.getRuntime().availableProcessors() * 2, max)); this.debug = logger.isLoggable(Level.FINER); }