private synchronized void bindRegistry(Registry registry,String[] intents,String[] configs) {
RegistryWatcher watcher = new RegistryWatcher(ctx,registry);
watchers.put(registry,watcher);
ServiceRegistration[] regs = new ServiceRegistration[2];
ExportedServiceTracker export = new ExportedServiceTracker(ctx,registry,intents,configs);
export.open();
trackers.put(registry,export);
ImportedServiceFindHook find = new ImportedServiceFindHook(watcher);
regs[0] = ctx.registerService(FindHook.class.getName(),find,null);
ImportedServiceListenerHook listener = new ImportedServiceListenerHook(
watcher);
regs[1] = ctx.registerService(ListenerHook.class.getName(),listener,null);
serviceRegs.put(registry,regs);
}
private synchronized void bindRegistry(Registry registry,regs);
}
项目:aries-rsa
文件:TopologyManagerImport.java
public void start() {
bctx.registerService(RemoteServiceAdminListener.class,this,null);
bctx.registerService(ListenerHook.class,listenerHook,null);
bctx.registerService(FindHook.class,findHook,null);
endpointListenerManager.start();
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。