本文整理汇总了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;未经允许,请勿转载。 |
请发表评论