Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
D
discovery
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
谢捷峰
discovery
Commits
37b0c156
Commit
37b0c156
authored
May 20, 2019
by
Nepxion
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修正异常打印
parent
c0145d28
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
23 additions
and
33 deletions
+23
-33
discovery-plugin-framework-consul/src/main/java/com/nepxion/discovery/plugin/framework/decorator/ConsulServiceRegistryDecorator.java
+5
-7
discovery-plugin-framework-eureka/src/main/java/com/nepxion/discovery/plugin/framework/decorator/EurekaServiceRegistryDecorator.java
+5
-7
discovery-plugin-framework-nacos/src/main/java/com/nepxion/discovery/plugin/framework/decorator/NacosServiceRegistryDecorator.java
+5
-7
discovery-plugin-framework-zookeeper/src/main/java/com/nepxion/discovery/plugin/framework/decorator/ZookeeperServiceRegistryDecorator.java
+5
-7
discovery-plugin-framework/src/main/java/com/nepxion/discovery/plugin/framework/decorator/DiscoveryClientDecorator.java
+3
-5
No files found.
discovery-plugin-framework-consul/src/main/java/com/nepxion/discovery/plugin/framework/decorator/ConsulServiceRegistryDecorator.java
View file @
37b0c156
...
...
@@ -9,8 +9,6 @@ package com.nepxion.discovery.plugin.framework.decorator;
* @version 1.0
*/
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.BeansException
;
import
org.springframework.cloud.consul.serviceregistry.ConsulRegistration
;
import
org.springframework.cloud.consul.serviceregistry.ConsulServiceRegistry
;
...
...
@@ -21,7 +19,7 @@ import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
import
com.nepxion.discovery.plugin.framework.listener.register.RegisterListenerExecutor
;
public
class
ConsulServiceRegistryDecorator
extends
ConsulServiceRegistry
{
private
static
final
Logger
LOG
=
LoggerFactory
.
getLogger
(
ConsulServiceRegistryDecorator
.
class
);
//
private static final Logger LOG = LoggerFactory.getLogger(ConsulServiceRegistryDecorator.class);
private
ConsulServiceRegistry
serviceRegistry
;
private
ConfigurableApplicationContext
applicationContext
;
...
...
@@ -43,7 +41,7 @@ public class ConsulServiceRegistryDecorator extends ConsulServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onRegister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -58,7 +56,7 @@ public class ConsulServiceRegistryDecorator extends ConsulServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onDeregister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -73,7 +71,7 @@ public class ConsulServiceRegistryDecorator extends ConsulServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onSetStatus
(
registration
,
status
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -93,7 +91,7 @@ public class ConsulServiceRegistryDecorator extends ConsulServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onClose
();
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
discovery-plugin-framework-eureka/src/main/java/com/nepxion/discovery/plugin/framework/decorator/EurekaServiceRegistryDecorator.java
View file @
37b0c156
...
...
@@ -9,8 +9,6 @@ package com.nepxion.discovery.plugin.framework.decorator;
* @version 1.0
*/
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.BeansException
;
import
org.springframework.cloud.netflix.eureka.serviceregistry.EurekaRegistration
;
import
org.springframework.cloud.netflix.eureka.serviceregistry.EurekaServiceRegistry
;
...
...
@@ -21,7 +19,7 @@ import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
import
com.nepxion.discovery.plugin.framework.listener.register.RegisterListenerExecutor
;
public
class
EurekaServiceRegistryDecorator
extends
EurekaServiceRegistry
{
private
static
final
Logger
LOG
=
LoggerFactory
.
getLogger
(
EurekaServiceRegistryDecorator
.
class
);
//
private static final Logger LOG = LoggerFactory.getLogger(EurekaServiceRegistryDecorator.class);
private
EurekaServiceRegistry
serviceRegistry
;
private
ConfigurableApplicationContext
applicationContext
;
...
...
@@ -41,7 +39,7 @@ public class EurekaServiceRegistryDecorator extends EurekaServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onRegister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -56,7 +54,7 @@ public class EurekaServiceRegistryDecorator extends EurekaServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onDeregister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -71,7 +69,7 @@ public class EurekaServiceRegistryDecorator extends EurekaServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onSetStatus
(
registration
,
status
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -91,7 +89,7 @@ public class EurekaServiceRegistryDecorator extends EurekaServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onClose
();
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
discovery-plugin-framework-nacos/src/main/java/com/nepxion/discovery/plugin/framework/decorator/NacosServiceRegistryDecorator.java
View file @
37b0c156
...
...
@@ -9,8 +9,6 @@ package com.nepxion.discovery.plugin.framework.decorator;
* @version 1.0
*/
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.BeansException
;
import
org.springframework.cloud.alibaba.nacos.NacosDiscoveryProperties
;
import
org.springframework.cloud.alibaba.nacos.registry.NacosServiceRegistry
;
...
...
@@ -22,7 +20,7 @@ import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
import
com.nepxion.discovery.plugin.framework.listener.register.RegisterListenerExecutor
;
public
class
NacosServiceRegistryDecorator
extends
NacosServiceRegistry
{
private
static
final
Logger
LOG
=
LoggerFactory
.
getLogger
(
NacosServiceRegistryDecorator
.
class
);
//
private static final Logger LOG = LoggerFactory.getLogger(NacosServiceRegistryDecorator.class);
private
NacosServiceRegistry
serviceRegistry
;
private
ConfigurableApplicationContext
applicationContext
;
...
...
@@ -44,7 +42,7 @@ public class NacosServiceRegistryDecorator extends NacosServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onRegister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -59,7 +57,7 @@ public class NacosServiceRegistryDecorator extends NacosServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onDeregister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -74,7 +72,7 @@ public class NacosServiceRegistryDecorator extends NacosServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onSetStatus
(
registration
,
status
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -94,7 +92,7 @@ public class NacosServiceRegistryDecorator extends NacosServiceRegistry {
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onClose
();
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
discovery-plugin-framework-zookeeper/src/main/java/com/nepxion/discovery/plugin/framework/decorator/ZookeeperServiceRegistryDecorator.java
View file @
37b0c156
...
...
@@ -9,8 +9,6 @@ package com.nepxion.discovery.plugin.framework.decorator;
* @version 1.0
*/
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.BeansException
;
import
org.springframework.cloud.zookeeper.serviceregistry.ZookeeperRegistration
;
import
org.springframework.cloud.zookeeper.serviceregistry.ZookeeperServiceRegistry
;
...
...
@@ -21,7 +19,7 @@ import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
import
com.nepxion.discovery.plugin.framework.listener.register.RegisterListenerExecutor
;
public
class
ZookeeperServiceRegistryDecorator
extends
ZookeeperServiceRegistry
{
private
static
final
Logger
LOG
=
LoggerFactory
.
getLogger
(
ZookeeperServiceRegistryDecorator
.
class
);
//
private static final Logger LOG = LoggerFactory.getLogger(ZookeeperServiceRegistryDecorator.class);
private
ZookeeperServiceRegistry
serviceRegistry
;
private
ConfigurableApplicationContext
applicationContext
;
...
...
@@ -43,7 +41,7 @@ public class ZookeeperServiceRegistryDecorator extends ZookeeperServiceRegistry
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onRegister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -58,7 +56,7 @@ public class ZookeeperServiceRegistryDecorator extends ZookeeperServiceRegistry
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onDeregister
(
registration
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -73,7 +71,7 @@ public class ZookeeperServiceRegistryDecorator extends ZookeeperServiceRegistry
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onSetStatus
(
registration
,
status
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -93,7 +91,7 @@ public class ZookeeperServiceRegistryDecorator extends ZookeeperServiceRegistry
RegisterListenerExecutor
registerListenerExecutor
=
applicationContext
.
getBean
(
RegisterListenerExecutor
.
class
);
registerListenerExecutor
.
onClose
();
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for RegisterListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for RegisterListenerExecutor failed, ignore to executor listener");
}
}
...
...
discovery-plugin-framework/src/main/java/com/nepxion/discovery/plugin/framework/decorator/DiscoveryClientDecorator.java
View file @
37b0c156
...
...
@@ -11,8 +11,6 @@ package com.nepxion.discovery.plugin.framework.decorator;
import
java.util.List
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
org.springframework.beans.BeansException
;
import
org.springframework.cloud.client.ServiceInstance
;
import
org.springframework.cloud.client.discovery.DiscoveryClient
;
...
...
@@ -23,7 +21,7 @@ import com.nepxion.discovery.plugin.framework.context.PluginContextAware;
import
com.nepxion.discovery.plugin.framework.listener.discovery.DiscoveryListenerExecutor
;
public
class
DiscoveryClientDecorator
implements
DiscoveryClient
{
private
static
final
Logger
LOG
=
LoggerFactory
.
getLogger
(
DiscoveryClientDecorator
.
class
);
//
private static final Logger LOG = LoggerFactory.getLogger(DiscoveryClientDecorator.class);
private
DiscoveryClient
discoveryClient
;
private
ConfigurableApplicationContext
applicationContext
;
...
...
@@ -45,7 +43,7 @@ public class DiscoveryClientDecorator implements DiscoveryClient {
DiscoveryListenerExecutor
discoveryListenerExecutor
=
applicationContext
.
getBean
(
DiscoveryListenerExecutor
.
class
);
discoveryListenerExecutor
.
onGetInstances
(
serviceId
,
instances
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for DiscoveryListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for DiscoveryListenerExecutor failed, ignore to executor listener");
}
}
...
...
@@ -66,7 +64,7 @@ public class DiscoveryClientDecorator implements DiscoveryClient {
DiscoveryListenerExecutor
discoveryListenerExecutor
=
applicationContext
.
getBean
(
DiscoveryListenerExecutor
.
class
);
discoveryListenerExecutor
.
onGetServices
(
services
);
}
catch
(
BeansException
e
)
{
LOG
.
warn
(
"Get bean for DiscoveryListenerExecutor failed, ignore to executor listener"
);
//
LOG.warn("Get bean for DiscoveryListenerExecutor failed, ignore to executor listener");
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment