lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
wentch
2015-12-16 09:45:35 +08:00
parent 9952b97d0e
commit 8ccd5de549
1 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/org/redkale/net/sncp/Sncp.java
View File

@@ -132,7 +132,6 @@ public abstract class Sncp {
return rs; return rs;
} }
public static boolean isRemote(Service service) { public static boolean isRemote(Service service) {
return service.getClass().getName().startsWith(REMOTEPREFIX); return service.getClass().getName().startsWith(REMOTEPREFIX);
} }
@@ -687,12 +686,8 @@ public abstract class Sncp {
* @return * @return
*/ */
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public static <T extends Service> T createLocalService( public static <T extends Service> T createLocalService(final String name, final Consumer<Runnable> executor, final Class<T> serviceClass,
final String name, final InetSocketAddress clientAddress, HashSet<String> groups, Collection<Transport> sameGroupTransports, Collection<Transport> diffGroupTransports) {
final Consumer<Runnable> executor,
final Class<T> serviceClass,
final InetSocketAddress clientAddress, HashSet<String> groups, Collection<Transport> sameGroupTransports, Collection<Transport> diffGroupTransports
) {
try { try {
final Class newClazz = createLocalServiceClass(name, serviceClass); final Class newClazz = createLocalServiceClass(name, serviceClass);
T rs = (T) newClazz.newInstance(); T rs = (T) newClazz.newInstance();
@@ -848,12 +843,8 @@ public abstract class Sncp {
* @return * @return
*/ */
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public static <T extends Service> T createRemoteService( public static <T extends Service> T createRemoteService(final String name, final Consumer<Runnable> executor, final Class<T> serviceClass,
final String name, final InetSocketAddress clientAddress, HashSet<String> groups, final Transport transport) {
final Consumer<Runnable> executor,
final Class<T> serviceClass,
final InetSocketAddress clientAddress, HashSet<String> groups, final Transport transport
) {
if (serviceClass == null) return null; if (serviceClass == null) return null;
if (!Service.class.isAssignableFrom(serviceClass)) return null; if (!Service.class.isAssignableFrom(serviceClass)) return null;
int mod = serviceClass.getModifiers(); int mod = serviceClass.getModifiers();