• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java BlueprintEvent类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.osgi.service.blueprint.container.BlueprintEvent类的典型用法代码示例。如果您正苦于以下问题：Java BlueprintEvent类的具体用法？Java BlueprintEvent怎么用？Java BlueprintEvent使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



BlueprintEvent类属于org.osgi.service.blueprint.container包，在下文中一共展示了BlueprintEvent类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: beforeClose

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void beforeClose(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.beforeClose(event);
						return null;
					}
				});
			} else {
				dispatcher.beforeClose(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例2: beforeRefresh

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void beforeRefresh(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.beforeRefresh(event);
						return null;
					}
				});
			} else {
				dispatcher.beforeRefresh(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例3: afterClose

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void afterClose(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.afterClose(event);
						return null;
					}
				});
			} else {
				dispatcher.afterClose(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例4: afterRefresh

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void afterRefresh(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.afterRefresh(event);
						return null;
					}
				});
			} else {
				dispatcher.afterRefresh(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例5: refreshFailure

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void refreshFailure(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.refreshFailure(event);
						return null;
					}
				});
			} else {
				dispatcher.refreshFailure(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例6: grace

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void grace(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.grace(event);
						return null;
					}
				});
			} else {
				dispatcher.grace(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例7: waiting

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void waiting(final BlueprintEvent event) {
	if (dispatcher != null) {
		try {
			if (System.getSecurityManager() != null) {
				AccessController.doPrivileged(new PrivilegedAction<Object>() {
					public Object run() {
						dispatcher.waiting(event);
						return null;
					}
				});
			} else {
				dispatcher.waiting(event);
			}
		} catch (Throwable th) {
			log.warn("Cannot dispatch event " + event, th);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:19，代码来源:EventAdminDispatcher.java


示例8: addEvent

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
void addEvent(BlueprintEvent event) {
	// copy event
	BlueprintEvent replay = new BlueprintEvent(event, true);
	Bundle bnd = replay.getBundle();
	if (bnd.getState() == Bundle.ACTIVE || bnd.getState() == Bundle.STARTING || bnd.getState() == Bundle.STOPPING) {
		events.put(bnd, replay);
		if (log.isTraceEnabled())
			log.trace("Adding replay event  " + replay.getType() + " for bundle " + replay.getBundle());
	} else {
		if (log.isTraceEnabled()) {
			log.trace("Replay event " + replay.getType() + " ignored; " + "owning bundle has been uninstalled "
					+ bnd);
			events.remove(bnd);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:17，代码来源:ReplayEventManager.java


示例9: onApplicationEvent

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void onApplicationEvent(ApplicationEvent event) {
	if (event instanceof ContextClosedEvent) {
		enabled = false;
		return;
	}

	if (event instanceof ContextRefreshedEvent) {
		initialized = true;
		return;
	}

	if (event instanceof OsgiServiceDependencyWaitStartingEvent) {
		if (enabled) {
			OsgiServiceDependencyWaitStartingEvent evt = (OsgiServiceDependencyWaitStartingEvent) event;
			String[] filter = new String[] { evt.getServiceDependency().getServiceFilter().toString() };
			BlueprintEvent waitingEvent =
					new BlueprintEvent(BlueprintEvent.WAITING, bundleContext.getBundle(), extenderBundle,
							filter);

			listenerManager.blueprintEvent(waitingEvent);
			dispatcher.waiting(waitingEvent);
		}
		return;
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:26，代码来源:BlueprintContainerProcessor.java


示例10: doStart

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
@Override
protected void doStart() throws Exception {
    super.doStart();
    if (bundleContext == null) {
        String descriptors = getDescriptors();
        if (descriptors == null) {
            throw new IllegalArgumentException("Descriptors must be provided, with the name of the blueprint XML file");
        }
        LOG.debug("Starting Blueprint XML file: " + descriptors);
        if (configAdminPid != null && configAdminFileName != null) {
            // pid/file is used to set INITIAL content of ConfigAdmin to be used when blueprint container is started
            bundleContext = createBundleContext(bundleName, new String[] {configAdminFileName, configAdminPid});
        } else {
            bundleContext = createBundleContext(bundleName);
        }
        Set<Long> eventHistory = new HashSet<>();

        CamelBlueprintHelper.waitForBlueprintContainer(eventHistory, bundleContext, bundleName, BlueprintEvent.CREATED, null);

        camelContext = CamelBlueprintHelper.getOsgiService(bundleContext, CamelContext.class);
        if (camelContext == null) {
            throw new IllegalArgumentException("Cannot find CamelContext in blueprint XML file: " + descriptors);
        }
    }
}
开发者ID:HydAu，项目名称:Camel，代码行数:26，代码来源:Main.java


示例11: testProperties

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
@Test
public void testProperties() throws Exception {
    Bundle camelCore = getBundleBySymbolicName("org.apache.camel.camel-core");
    Bundle test = getBundleBySymbolicName(getClass().getSimpleName());

    camelCore.stop();
    test.stop();

    Thread.sleep(500);

    test.start();
    try {
        getOsgiService(BlueprintContainer.class, "(osgi.blueprint.container.symbolicname=" + getClass().getSimpleName() + ")", 500);
        fail("Expected a timeout");
    } catch (RuntimeException e) {
        // Expected timeout
    }

    camelCore.start();
    CamelBlueprintHelper.waitForBlueprintContainer(null, test.getBundleContext(), getClass().getSimpleName(), BlueprintEvent.CREATED, null);
    getOsgiService(BlueprintContainer.class, "(osgi.blueprint.container.symbolicname=" + getClass().getSimpleName() + ")", 500);
}
开发者ID:HydAu，项目名称:Camel，代码行数:23，代码来源:BlueprintPropertiesTest.java


示例12: getFormattedEvent

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
private String getFormattedEvent(final BlueprintEvent event, final String trClass, final String approot) {
    String eventType = getEventTypeString(event.getType());
    String timeStamp = getTimeStamp(event.getTimestamp());
    Bundle bundle = event.getBundle();
    String stackTrace = "";
    if (event.getCause() != null) {
        StringWriter stringWriter = new StringWriter();
        PrintWriter pw = new PrintWriter(stringWriter);
        event.getCause().printStackTrace(pw);
        stackTrace = "<pre>" + stringWriter.toString() + "</pre>";
    }
    String dependencies = getDependencies(event.getDependencies());
    return "<tr class=\"ui-state-default " + trClass + "\" >"
            + "<td>" + timeStamp + "</td>"
            + "<td><a href=\"" + approot + "/bundles/" + bundle.getBundleId() + "\">"
            + bundle.getSymbolicName() + ":" + bundle.getVersion() + " (" + bundle.getBundleId() + ")</a></td>"
            + "<td>" + eventType + "</td>"
            + "<td>" + stackTrace + "</td>"
            + "<td>" + dependencies + "</td>"
            + "</tr>";
}
开发者ID:everit-org-archive，项目名称:osgi-webconsole-blueprint，代码行数:22，代码来源:BlueprintServlet.java


示例13: getBundleState

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
@Override public BundleState getBundleState( long bundleId ) {
  BlueprintEvent blueprintEvent = states.get( bundleId );

  if ( blueprintEvent == null ) {
    return BundleState.Unknown;
  }
  switch ( blueprintEvent.getType() ) {
    case BlueprintEvent.CREATING:
      return BundleState.Starting;
    case BlueprintEvent.CREATED:
      return BundleState.Active;
    case BlueprintEvent.DESTROYING:
      return BundleState.Stopping;
    case BlueprintEvent.DESTROYED:
      return BundleState.Resolved;
    case BlueprintEvent.FAILURE:
      return BundleState.Failure;
    case BlueprintEvent.GRACE_PERIOD:
      return BundleState.GracePeriod;
    case BlueprintEvent.WAITING:
      return BundleState.Waiting;
    default:
      return BundleState.Unknown;
  }
}
开发者ID:pentaho，项目名称:pentaho-osgi-bundles，代码行数:26，代码来源:BlueprintStateServiceImpl.java


示例14: refreshFailure

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void refreshFailure(BlueprintEvent event) {
	Dictionary<String, Object> props = init(event);

	Throwable th = event.getCause();
	props.put(EXCEPTION, th);
	props.put(CAUSE, th);
	props.put(EXCEPTION_CLASS, th.getClass().getName());
	String msg = th.getMessage();
	props.put(EXCEPTION_MESSAGE, (msg != null ? msg : ""));
	initDependencies(props, event);
	sendEvent(new Event(TOPIC_FAILURE, props));
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:13，代码来源:OsgiEventDispatcher.java


示例15: initDependencies

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
private void initDependencies(Dictionary<String, Object> props, BlueprintEvent event) {
	String[] deps = event.getDependencies();
	if (!ObjectUtils.isEmpty(deps)) {
		props.put(DEPENDENCIES, deps);
		// props.put(SERVICE_FILTER, deps[0]);
		// props.put(SERVICE_FILTER_2, deps[0]);
		// props.put(SERVICE_OBJECTCLASS, extractObjectClassFromFilter(deps[0]));
		props.put(ALL_DEPENDENCIES, deps);
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:11，代码来源:OsgiEventDispatcher.java


示例16: init

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
private Dictionary<String, Object> init(BlueprintEvent event) {
	Dictionary<String, Object> props = new Hashtable<String, Object>();

	Bundle bundle = event.getBundle();

	// common properties
	props.put(TIMESTAMP, System.currentTimeMillis());
	props.put(EVENT, event);
	props.put(TYPE, Integer.valueOf(event.getType()));

	props.put(BUNDLE, event.getBundle());
	props.put(BUNDLE_ID, bundle.getBundleId());

	// name (under two keys)
	String name = OsgiStringUtils.nullSafeName(bundle);
	props.put(BUNDLE_NAME, name);
	props.put(Constants.BUNDLE_NAME, name);

	// sym name (under two keys)
	String symName = OsgiStringUtils.nullSafeSymbolicName(bundle);
	props.put(BUNDLE_SYM_NAME, symName);
	props.put(Constants.BUNDLE_SYMBOLICNAME, symName);

	// version (as well under two keys)
	Version version = OsgiBundleUtils.getBundleVersion(bundle);
	props.put(BUNDLE_VERSION, version);
	props.put(Constants.BUNDLE_VERSION, version);

	// extender bundle info
	Bundle extenderBundle = event.getExtenderBundle();

	props.put(EXTENDER_BUNDLE, extenderBundle);
	props.put(EXTENDER_BUNDLE_ID, extenderBundle.getBundleId());
	props.put(EXTENDER_BUNDLE_SYM_NAME, extenderBundle.getSymbolicName());
	Version extenderVersion = OsgiBundleUtils.getBundleVersion(extenderBundle);
	props.put(EXTENDER_BUNDLE_VERSION, extenderVersion);

	return props;
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:40，代码来源:OsgiEventDispatcher.java


示例17: bundleChanged

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void bundleChanged(BundleEvent event) {
	if (BundleEvent.STOPPED == event.getType() || BundleEvent.UNINSTALLED == event.getType()
			|| BundleEvent.UNRESOLVED == event.getType()) {
		BlueprintEvent removed = events.remove(event.getBundle());
		if (log.isTraceEnabled())
			log.trace("Removed  bundle " + event.getBundle() + " for sending replayes events; last one was "
					+ removed);
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:10，代码来源:ReplayEventManager.java


示例18: dispatchReplayEvents

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
void dispatchReplayEvents(BlueprintListener listener) {
	synchronized (events) {
		for (BlueprintEvent event : events.values()) {
			listener.blueprintEvent(event);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:8，代码来源:ReplayEventManager.java


示例19: blueprintEvent

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void blueprintEvent(BlueprintEvent event) {
	replayManager.addEvent(event);

	for (BlueprintListener listener : listeners) {
		try {
			listener.blueprintEvent(event);
		} catch (Exception ex) {
			log.warn("exception encountered when calling listener " + System.identityHashCode(listener), ex);
		}
	}
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:12，代码来源:BlueprintListenerManager.java


示例20: postProcessClose

import org.osgi.service.blueprint.container.BlueprintEvent; //导入依赖的package包/类
public void postProcessClose(ConfigurableOsgiBundleApplicationContext context) {
	BlueprintEvent destroyedEvent =
			new BlueprintEvent(BlueprintEvent.DESTROYED, context.getBundle(), extenderBundle);

	listenerManager.blueprintEvent(destroyedEvent);
	dispatcher.afterClose(destroyedEvent);
}
开发者ID:eclipse，项目名称:gemini.blueprint，代码行数:8，代码来源:BlueprintContainerProcessor.java



注：本文中的org.osgi.service.blueprint.container.BlueprintEvent类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java LoaderContext类代码示例发布时间：2022-05-22
下一篇：
Java ResourceHandlerRegistration类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap