本文整理了Java中org.apache.felix.ipojo.annotations.Bind.<init>()
方法的一些代码示例,展示了Bind.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bind.<init>()
方法的具体详情如下:
包路径:org.apache.felix.ipojo.annotations.Bind
类名称:Bind
方法名:<init>
暂无
代码示例来源:origin: vert-x3/vertx-examples
@Bind(aggregate = true)
public void bindVerticle(Verticle verticle) {
LOGGER.info("Deploying verticle " + verticle);
TcclSwitch.executeWithTCCLSwitch(() -> {
vertx.deployVerticle(verticle, ar -> {
if (ar.succeeded()) {
deploymentIds.put(verticle, ar.result());
} else {
LOGGER.log(Level.SEVERE, "Cannot deploy " + verticle, ar.cause());
}
});
});
}
代码示例来源:origin: org.wisdom-framework/router
/**
* Binds a filter.
*
* @param filter the filter
*/
@Bind(aggregate = true, optional = true)
public void bindFilter(Filter filter) {
filters.add(filter);
}
代码示例来源:origin: info.kwarc.sally4.mhw/mhw-base
@Bind(aggregate=true, optional=true)
public void removeLMHStore(LMHMultiUserStore multiUserStore) {
lmhStores.remove(multiUserStore);
}
代码示例来源:origin: info.kwarc.sally4/sally4-docmanager
@Bind(aggregate=true)
public void bindService(HttpService httpSevlet, Dictionary<String, Object> properties) {
Object pid = properties.get("service.pid");
if (pid == null)
return;
if (!"org.ops4j.pax.web".equals(pid)) {
return;
}
port = properties.get(portProperty).toString();
this.httpSevlet = httpSevlet;
}
代码示例来源:origin: info.kwarc.sally4/sally4-docmanager
@Bind(aggregate=true)
void newSallyDoc(SallyClient newDoc) throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
addDoc(newDoc);
}
}
代码示例来源:origin: info.kwarc.sally4/mhw-base
@Bind(aggregate=true, optional=true)
public void bindMathHubWorker(IWorker worker) {
if (!started) {
bindRequests.add(worker);
return;
}
assignerModel.addWorker(worker);
}
代码示例来源:origin: org.ow2.kerneos.graniteds-osgi/granite-core
@Bind(aggregate = true, optional = true)
public final void bindSecurity(final GraniteSecurity security) {
synchronized (securityMap) {
securityMap.put(security.getService(), security);
}
}
代码示例来源:origin: org.wisdom-framework/wisdom-jdbc-datasources
@Bind(optional = true, aggregate = true)
public synchronized void bindFactory(DataSourceFactory factory, Map<String, String> properties) {
String driverClassName = properties.get(DataSourceFactory.OSGI_JDBC_DRIVER_CLASS);
drivers.put(driverClassName, factory);
checkPendingDatasource(driverClassName);
}
代码示例来源:origin: org.ow2.kerneos.graniteds-osgi/granite-core
@Bind(aggregate = true, optional = true)
public final void bindDestination(final GraniteDestination destination) {
synchronized (destinationServices) {
destinationServices.put(destination.getId(), destination);
}
}
代码示例来源:origin: org.ow2.kerneos.graniteds-osgi/granite-core
@Bind(aggregate = true, optional = true)
public final void bindFactory(final GraniteFactory factory) {
synchronized (factoryServices) {
factoryServices.put(factory.getId(), factory);
}
}
代码示例来源:origin: org.wisdom-framework/router
/**
* Registers the current router in the dispatcher.
*/
@Bind(aggregate = true)
public void bindDispatcher(WebSocketDispatcher dispatcher) {
dispatcher.register(this);
}
代码示例来源:origin: org.wisdom-framework/router
/**
* Binds a new controller.
*
* @param controller the new controller
*/
@Bind(aggregate = true)
public synchronized void bindController(Controller controller) {
analyze(controller);
}
代码示例来源:origin: info.kwarc.sally4.mhw/mhw-base
@Bind(aggregate=true, optional=true)
@Override
public void addBuildFactory(IBuildWorkflowFactory newFactory) {
buildFactories.put(newFactory.getId(), newFactory);
for (Entry<String, BuildWorkflowConfig> pairs : configuredWorkflows.entrySet()) {
String ext = pairs.getKey();
BuildWorkflowConfig conf = pairs.getValue();
if (!conf.getBuildWorkflowId().equals(newFactory.getId())) {
continue;
}
enableBuilders(ext);
}
}
代码示例来源:origin: org.ow2.kerneos/kerneos-core-server
@Bind(aggregate = true, optional = true)
private void bindKerneosApplication(KerneosApplication application) {
// Post an event
ApplicationEvent me = new ApplicationEvent(application.getConfiguration(), ApplicationEvent.LOAD);
Dictionary<String, Object> properties = new Hashtable<String, Object>();
properties.put(KerneosConstants.KERNEOS_TOPIC_DATA, me);
Event event = new Event(KerneosConstants.KERNEOS_APPLICATIONS_TOPIC, properties);
eventAdmin.sendEvent(event);
}
代码示例来源:origin: org.ow2.kerneos/kerneos-core-server
@Bind(aggregate = true, optional = true)
private void bindKerneosModule(KerneosModule module) {
// Post an event
ModuleEvent me = new ModuleEvent(module.getConfiguration(), ModuleEvent.LOAD);
Dictionary<String, Object> properties = new Hashtable<String, Object>();
properties.put(KerneosConstants.KERNEOS_TOPIC_DATA, me);
Event event = new Event(KerneosConstants.KERNEOS_MODULES_TOPIC, properties);
eventAdmin.sendEvent(event);
}
代码示例来源:origin: org.ow2.kerneos/kerneos-core-server
@Bind(aggregate = true, optional = true)
private void bindKerneosModuleFragment(KerneosModuleFragment moduleFragment) {
// Post an event
ModuleFragmentEvent mfe = new ModuleFragmentEvent(moduleFragment.getConfiguration(), ModuleEvent.LOAD);
Dictionary<String, Object> properties = new Hashtable<String, Object>();
properties.put(KerneosConstants.KERNEOS_TOPIC_DATA, mfe);
Event event = new Event(KerneosConstants.KERNEOS_MODULES_TOPIC + "/"
+ moduleFragment.getModuleId() + KerneosConstants.KERNEOS_MODULES_FRAGMENTS_TOPIC, properties);
eventAdmin.sendEvent(event);
}
代码示例来源:origin: info.kwarc.sally4.mhw/mhw-base
/**
* A new started workflow is created by a factory
* @param newWorkflow
*/
@Bind(aggregate=true, optional=true)
void addBuildWorkflow(final IBuildWorkflow newWorkflow) {
if (!newWorkflow.getRepositoryId().equals(repositoryid))
return;
activeWorkflowsInstances.put(newWorkflow.getExtension(), newWorkflow);
EventBusContext context = lmh.watchFiles(repoName, newWorkflow.getExtension());
FSEventHandlers.put(newWorkflow.getExtension(), new FSEventSubscriber(context, newWorkflow));
}
代码示例来源:origin: info.kwarc.sally4/text-base
@Bind(aggregate=true)
void newSallyClient(final SallyClient client) throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
if (client.supports("text")) {
InstanceCreator.init(factory)
.setInstanceName("Text Doc Instance "+client.getDocQueue())
.setDynamicRequirement(TextDocument.clientProperty, "("+SallyClient.clientQueue+"="+client.getDocQueue()+")")
.create();
}
}
代码示例来源:origin: info.kwarc.sally4/sally4-docmanager
@Bind(aggregate=true)
void addDoc(SallyClient doc) throws UnacceptableConfiguration, MissingHandlerException, ConfigurationException {
if (doc.supports("frames")) {
InstanceCreator.init(sallyFrameMenuFactory)
.setInstanceName("Sally Frame Menu for "+doc.getDocQueue())
.setDynamicRequirement("clientInstance", "(docQueue="+doc.getDocQueue()+")")
.setDynamicRequirement("theoInstance", "(environmentid="+doc.getEnvironmentID()+")")
.create();
}
}
代码示例来源:origin: info.kwarc.sally4/mhw-base
@Bind(aggregate=true, optional=true)
public void addPlanetaryClient(PlanetaryDoc planetaryClients) {
NewService serv = new NewService();
String host = servlet.getURL();
serv.setIcon(host+"/mhw/libs/mhwsettings.png");
serv.setId("mhwsettings");
serv.setName("Math Hub Worker Settings");
serv.setType("toolbar");
serv.setUrl(host+"/mhw/mhwsettings?uid="+planetaryClients.getUserID());
planetaryClients.newService(serv);
}
内容来源于网络,如有侵权,请联系作者删除!