diff --git a/src/main/java/com/ifish/socketNew/MinaServerHandler.java b/src/main/java/com/ifish/socketNew/MinaServerHandler.java index c200fda..a3f4dbb 100644 --- a/src/main/java/com/ifish/socketNew/MinaServerHandler.java +++ b/src/main/java/com/ifish/socketNew/MinaServerHandler.java @@ -90,8 +90,8 @@ public class MinaServerHandler extends IoHandlerAdapter { //离线时间 jobGroup.setTimestamp(IfishUtil.format(new Date())); //10分钟后推送 update 30分钟 -// jobGroup.setStartTime(new Date(System.currentTimeMillis() + 600000L * 3)); - jobGroup.setStartTime(new Date(System.currentTimeMillis() + 60000L)); + jobGroup.setStartTime(new Date(System.currentTimeMillis() + 600000L * 3)); +// jobGroup.setStartTime(new Date(System.currentTimeMillis() + 60000L)); scheduleJob.addJob(jobGroup); } diff --git a/src/main/java/com/ifish/socketNew/SomeServer.java b/src/main/java/com/ifish/socketNew/SomeServer.java index ca38df1..6fdf1ea 100644 --- a/src/main/java/com/ifish/socketNew/SomeServer.java +++ b/src/main/java/com/ifish/socketNew/SomeServer.java @@ -26,11 +26,9 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsTemplate; -import org.springframework.jms.core.MessageCreator; import javax.jms.Destination; import javax.jms.JMSException; -import javax.jms.Message; import javax.jms.Session; import java.util.Calendar; import java.util.Date; diff --git a/src/main/resources/mq.properties b/src/main/resources/mq.properties index a5dcb67..77df9ed 100644 --- a/src/main/resources/mq.properties +++ b/src/main/resources/mq.properties @@ -1,5 +1,4 @@ -#broker_url=tcp://test.ifish7.com:61616 -broker_url=tcp://www.ifish7.com:61616 +broker_url=tcp://localhost:61616 username=admin #password=admin password=adminifish7