Commit 8bb02389 by Nepxion

修正不支持服务名大写的Bug

parent fa5479b4
...@@ -54,7 +54,7 @@ public abstract class AbstractPluginAdapter implements PluginAdapter { ...@@ -54,7 +54,7 @@ public abstract class AbstractPluginAdapter implements PluginAdapter {
@Override @Override
public String getServiceId() { public String getServiceId() {
return registration.getServiceId(); return registration.getServiceId().toLowerCase();
} }
@Override @Override
......
...@@ -28,7 +28,7 @@ public class CountFilterRegisterListener extends AbstractRegisterListener { ...@@ -28,7 +28,7 @@ public class CountFilterRegisterListener extends AbstractRegisterListener {
@Override @Override
public void onRegister(Registration registration) { public void onRegister(Registration registration) {
String serviceId = registration.getServiceId(); String serviceId = registration.getServiceId().toLowerCase();
String host = registration.getHost(); String host = registration.getHost();
int port = registration.getPort(); int port = registration.getPort();
......
...@@ -26,7 +26,7 @@ import com.nepxion.discovery.plugin.framework.event.RegisterFailureEvent; ...@@ -26,7 +26,7 @@ import com.nepxion.discovery.plugin.framework.event.RegisterFailureEvent;
public class HostFilterRegisterListener extends AbstractRegisterListener { public class HostFilterRegisterListener extends AbstractRegisterListener {
@Override @Override
public void onRegister(Registration registration) { public void onRegister(Registration registration) {
String serviceId = registration.getServiceId(); String serviceId = registration.getServiceId().toLowerCase();
String host = registration.getHost(); String host = registration.getHost();
int port = registration.getPort(); int port = registration.getPort();
......
...@@ -16,17 +16,17 @@ import com.nepxion.discovery.plugin.framework.listener.register.AbstractRegister ...@@ -16,17 +16,17 @@ import com.nepxion.discovery.plugin.framework.listener.register.AbstractRegister
public class MyRegisterListener extends AbstractRegisterListener { public class MyRegisterListener extends AbstractRegisterListener {
@Override @Override
public void onRegister(Registration registration) { public void onRegister(Registration registration) {
// System.out.println("========== Register Listener :: register()被触发, serviceId=" + registration.getServiceId()); // System.out.println("========== Register Listener :: register()被触发, serviceId=" + registration.getServiceId().toLowerCase());
} }
@Override @Override
public void onDeregister(Registration registration) { public void onDeregister(Registration registration) {
// System.out.println("========== Register Listener :: deregister()被触发, serviceId=" + registration.getServiceId()); // System.out.println("========== Register Listener :: deregister()被触发, serviceId=" + registration.getServiceId().toLowerCase());
} }
@Override @Override
public void onSetStatus(Registration registration, String status) { public void onSetStatus(Registration registration, String status) {
// System.out.println("========== Register Listener :: setStatus()被触发, serviceId=" + registration.getServiceId() + ", status=" + status); // System.out.println("========== Register Listener :: setStatus()被触发, serviceId=" + registration.getServiceId().toLowerCase() + ", status=" + status);
} }
@Override @Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment