overflow_cloud/central
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remodeling is in progress

Browse Source
This commit is contained in:
insanity 2018-04-24 20:41:46 +09:00
parent b69ba6c9d3
commit 0eda0683de
6 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/loafle/overflow/central/module/discovery/service/CentralDiscoveryService.java
View File

@ -2,9 +2,8 @@ package com.loafle.overflow.central.module.discovery.service;
import com.loafle.overflow.central.commons.model.SessionMetadata;
import com.loafle.overflow.central.commons.service.MessagePublisher; import com.loafle.overflow.central.commons.service.MessagePublisher;
import com.loafle.overflow.central.commons.utils.SessionMetadata;
import com.loafle.overflow.core.annotation.ProbeAPI; import com.loafle.overflow.core.annotation.ProbeAPI;
import com.loafle.overflow.core.annotation.WebappAPI; import com.loafle.overflow.core.annotation.WebappAPI;
import com.loafle.overflow.core.exception.OverflowException; import com.loafle.overflow.core.exception.OverflowException;

1
src/main/java/com/loafle/overflow/central/module/infra/service/CentralInfraService.java
View File

@ -1,5 +1,6 @@
package com.loafle.overflow.central.module.infra.service; package com.loafle.overflow.central.module.infra.service;
import com.loafle.overflow.central.commons.utils.PageUtil;
import com.loafle.overflow.central.module.infra.dao.InfraDAO; import com.loafle.overflow.central.module.infra.dao.InfraDAO;
import com.loafle.overflow.core.model.PageParams; import com.loafle.overflow.core.model.PageParams;
import com.loafle.overflow.model.domain.Domain; import com.loafle.overflow.model.domain.Domain;

3
src/main/java/com/loafle/overflow/central/proxy/ProxyServerInterceptor.java
View File

@ -1,6 +1,7 @@
package com.loafle.overflow.central.proxy; package com.loafle.overflow.central.proxy;
import com.loafle.overflow.central.commons.model.SessionMetadata; import com.loafle.overflow.central.commons.utils.SessionMetadata;
import io.grpc.*; import io.grpc.*;
public class ProxyServerInterceptor implements ServerInterceptor { public class ProxyServerInterceptor implements ServerInterceptor {

2
src/main/java/com/loafle/overflow/central/proxy/ServiceInvoker.java
View File

@ -2,8 +2,6 @@ package com.loafle.overflow.central.proxy;
import com.google.gson.internal.Primitives; import com.google.gson.internal.Primitives;
import com.google.protobuf.ByteString; import com.google.protobuf.ByteString;
import com.loafle.overflow.central.commons.exception.OverflowException;
import com.loafle.overflow.central.commons.exception.OverflowRuntimeException;
import com.loafle.overflow.central.proxy.exception.InvalidParameterException; import com.loafle.overflow.central.proxy.exception.InvalidParameterException;
import com.loafle.overflow.central.proxy.exception.InvalidRequestException; import com.loafle.overflow.central.proxy.exception.InvalidRequestException;
import com.loafle.overflow.central.proxy.exception.NoSuchMethodException; import com.loafle.overflow.central.proxy.exception.NoSuchMethodException;

2
src/main/java/com/loafle/overflow/central/proxy/ServiceProxy.java
View File

@ -3,8 +3,6 @@ package com.loafle.overflow.central.proxy;
import com.loafle.overflow.api.OverflowApiServerGrpc; import com.loafle.overflow.api.OverflowApiServerGrpc;
import com.loafle.overflow.api.ServerInput; import com.loafle.overflow.api.ServerInput;
import com.loafle.overflow.api.ServerOutput; import com.loafle.overflow.api.ServerOutput;
import com.loafle.overflow.central.commons.exception.OverflowException;
import com.loafle.overflow.central.commons.exception.OverflowRuntimeException;
import io.grpc.*; import io.grpc.*;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext; import org.springframework.context.annotation.AnnotationConfigApplicationContext;

12
src/main/java/com/loafle/overflow/central/redis/service/RedisMessagePublisher.java
View File

@ -1,9 +1,11 @@
package com.loafle.overflow.central.redis.service; package com.loafle.overflow.central.redis.service;
import com.loafle.overflow.central.commons.model.PublishMessage;
import com.loafle.overflow.central.commons.service.MessagePublisher; import com.loafle.overflow.central.commons.service.MessagePublisher;
import com.loafle.overflow.central.module.member.model.Member; import com.loafle.overflow.core.exception.OverflowException;
import com.loafle.overflow.central.module.member.service.MemberService; import com.loafle.overflow.core.model.PublishMessage;
import com.loafle.overflow.model.member.Member;
import com.loafle.overflow.service.central.member.MemberService;
import org.codehaus.jackson.map.ObjectMapper; import org.codehaus.jackson.map.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
@ -81,12 +83,12 @@ public class RedisMessagePublisher implements MessagePublisher {
@Cacheable("memberListByDomain") @Cacheable("memberListByDomain")
protected List<String> getMemberListByDomainID(final long domainID) { protected List<String> getMemberListByDomainID(final long domainID) throws OverflowException {
return this.getMemberList(memberService.readAllByDomainID(domainID)); return this.getMemberList(memberService.readAllByDomainID(domainID));
} }
@Cacheable("memberListByProbeKey") @Cacheable("memberListByProbeKey")
protected List<String> getMemberListByProbeKey(final String probeKey) { protected List<String> getMemberListByProbeKey(final String probeKey) throws OverflowException {
return this.getMemberList(memberService.readAllByProbeKey(probeKey)); return this.getMemberList(memberService.readAllByProbeKey(probeKey));
} }