mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Reformat code.
This commit is contained in:
@@ -87,7 +87,8 @@ public class StoreCollector extends Collector implements InstanceRegistry {
|
|||||||
return mfs;
|
return mfs;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override public void register(CanalInstance instance) {
|
@Override
|
||||||
|
public void register(CanalInstance instance) {
|
||||||
final String destination = instance.getDestination();
|
final String destination = instance.getDestination();
|
||||||
StoreMetricsHolder holder = new StoreMetricsHolder();
|
StoreMetricsHolder holder = new StoreMetricsHolder();
|
||||||
CanalEventStore store = instance.getEventStore();
|
CanalEventStore store = instance.getEventStore();
|
||||||
@@ -115,7 +116,8 @@ public class StoreCollector extends Collector implements InstanceRegistry {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override public void unregister(CanalInstance instance) {
|
@Override
|
||||||
|
public void unregister(CanalInstance instance) {
|
||||||
final String destination = instance.getDestination();
|
final String destination = instance.getDestination();
|
||||||
instances.remove(destination);
|
instances.remove(destination);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user