2 Commits

Author SHA1 Message Date
3fe08e92a8 修改:包结构名称 2024-04-23 19:20:16 +08:00
a0126582bd . 2024-04-22 00:21:54 +08:00
21 changed files with 46 additions and 40 deletions

11
pom.xml
View File

@@ -4,9 +4,9 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>net.tccn</groupId>
<groupId>dev.zhub</groupId>
<artifactId>zhub-client-spring</artifactId>
<version>17.0.0409.dev</version>
<version>17.0.0423.dev</version>
<parent>
<groupId>org.springframework.boot</groupId>
@@ -59,5 +59,12 @@
<url>https://nexus.1216.top/repository/maven-releases/</url>
</repository>
</distributionManagement>
<!--<distributionManagement>
<repository>
<id>mvn-recloud</id>
<name>mvn-release</name>
<url>http://nexus.recloud.cn/repository/maven-releases/</url>
</repository>
</distributionManagement>-->
</project>

View File

@@ -1,10 +1,9 @@
package tccn;
package dev.zhub;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import tccn.zhub.Rpc;
import dev.zhub.client.Rpc;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

View File

@@ -1,4 +1,4 @@
package tccn;
package dev.zhub;
/**
* 发布订阅 事件

View File

@@ -1,4 +1,4 @@
package tccn;
package dev.zhub;
import com.google.gson.reflect.TypeToken;

View File

@@ -1,4 +1,4 @@
package tccn;
package dev.zhub;
import com.google.gson.reflect.TypeToken;

View File

@@ -1,4 +1,4 @@
package tccn;
package dev.zhub;
import java.util.logging.Logger;

View File

@@ -1,4 +1,4 @@
package tccn;
package dev.zhub;
import com.google.gson.reflect.TypeToken;

View File

@@ -1,4 +1,4 @@
package tccn.zhub;
package dev.zhub.client;
// ================================================== lock ==================================================
public class Lock {

View File

@@ -1,4 +1,4 @@
package tccn.zhub;
package dev.zhub.client;
import com.google.gson.Gson;
import com.google.gson.annotations.Expose;

View File

@@ -1,4 +1,4 @@
package tccn.zhub;
package dev.zhub.client;
public class RpcResult<R> {
private String ruk;
@@ -34,7 +34,7 @@ public class RpcResult<R> {
return result;
}
public void setResult(Object result) {
this.result = (R) result;
public void setResult(R result) {
this.result = result;
}
}

View File

@@ -1,12 +1,12 @@
package tccn.zhub;
package dev.zhub.client;
import com.google.gson.reflect.TypeToken;
import dev.zhub.*;
import jakarta.annotation.PostConstruct;
import lombok.Setter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import tccn.*;
import tccn.timer.Timers;
import dev.zhub.timer.Timers;
import java.io.BufferedReader;
import java.io.IOException;
@@ -638,7 +638,7 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
TypeToken typeToken = rpc.getTypeToken();
if (typeToken.getType() != ((RpcResult<?>) value).getResult().getClass()) {
Object result = gson.fromJson(toStr(((RpcResult<?>) value).getResult()), typeToken.getType());
((RpcResult<?>) value).setResult(result);
((RpcResult<Object>) value).setResult(result);
}
rpc.setRpcResult((RpcResult) value);

View File

@@ -1,7 +1,7 @@
package tccn.timer;
package dev.zhub.timer;
import tccn.timer.queue.TimerQueue;
import tccn.timer.task.Task;
import dev.zhub.timer.queue.TimerQueue;
import dev.zhub.timer.task.Task;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

View File

@@ -1,8 +1,8 @@
package tccn.timer;
package dev.zhub.timer;
import tccn.timer.scheduled.Scheduled;
import tccn.timer.task.Job;
import tccn.timer.task.Task;
import dev.zhub.timer.scheduled.Scheduled;
import dev.zhub.timer.task.Job;
import dev.zhub.timer.task.Task;
import java.time.LocalDateTime;
import java.time.ZoneId;

View File

@@ -1,6 +1,6 @@
package tccn.timer;
package dev.zhub.timer;
import tccn.timer.scheduled.ScheduledCycle;
import dev.zhub.timer.scheduled.ScheduledCycle;
import java.util.UUID;
import java.util.function.Supplier;

View File

@@ -1,6 +1,6 @@
package tccn.timer.queue;
package dev.zhub.timer.queue;
import tccn.timer.task.Task;
import dev.zhub.timer.task.Task;
import java.util.LinkedList;
import java.util.concurrent.TimeUnit;

View File

@@ -1,4 +1,4 @@
package tccn.timer.scheduled;
package dev.zhub.timer.scheduled;
import java.time.LocalDateTime;

View File

@@ -1,4 +1,4 @@
package tccn.timer.scheduled;
package dev.zhub.timer.scheduled;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;

View File

@@ -1,4 +1,4 @@
package tccn.timer.scheduled;
package dev.zhub.timer.scheduled;
import java.time.LocalDate;
import java.time.LocalDateTime;

View File

@@ -1,4 +1,4 @@
package tccn.timer.task;
package dev.zhub.timer.task;
/**
* @author: liangxianyou at 2018/12/8 17:24.

View File

@@ -1,7 +1,7 @@
package tccn.timer.task;
package dev.zhub.timer.task;
import tccn.timer.TimerExecutor;
import tccn.timer.scheduled.Scheduled;
import dev.zhub.timer.TimerExecutor;
import dev.zhub.timer.scheduled.Scheduled;
/**
* @author: liangxianyou at 2018/8/5 19:32.

View File

@@ -1,8 +1,8 @@
import org.junit.Before;
import org.junit.Test;
import tccn.IType;
import tccn.zhub.Lock;
import tccn.zhub.ZHubClient;
import net.tccn.IType;
import net.tccn.zhub.Lock;
import net.tccn.zhub.ZHubClient;
// @RestService(automapping = true)
public class HelloService {