本文整理汇总了Java中com.google.common.eventbus.SubscriberExceptionContext类的典型用法代码示例。如果您正苦于以下问题：Java SubscriberExceptionContext类的具体用法？Java SubscriberExceptionContext怎么用？Java SubscriberExceptionContext使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SubscriberExceptionContext类属于com.google.common.eventbus包，在下文中一共展示了SubscriberExceptionContext类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: LoadController
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
public LoadController(Loader loader)
{
this.loader = loader;
this.masterChannel = new EventBus(new SubscriberExceptionHandler()
{
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context)
{
FMLLog.log("FMLMainChannel", Level.ERROR, exception, "Could not dispatch event: %s to %s", context.getEvent(), context.getSubscriberMethod());
}
});
this.masterChannel.register(this);
state = LoaderState.NOINIT;
packageOwners = ArrayListMultimap.create();
}
开发者ID:F1r3w477，项目名称:CustomWorldGen，代码行数:18，代码来源:LoadController.java
示例2: unhandledExceptionInEventThreadCallsSubscriberExceptionHandler
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Test
public void unhandledExceptionInEventThreadCallsSubscriberExceptionHandler() {
SubscriberExceptionHandler handler = mock(SubscriberExceptionHandler.class);
EventBus bus = new EventBus(handler);
final IllegalStateException exception = new IllegalStateException("Excepted Unhandled Exception");
bus.register(new Object() {
@Subscribe
public void throwUnhandledException(TriggerUnhandledException event) {
throw exception;
}
});
bus.post(new TriggerUnhandledException());
verify(handler).handleException(eq(exception), any(SubscriberExceptionContext.class));
}
开发者ID:DavidWhitlock，项目名称:PortlandStateJava，代码行数:18，代码来源:UnhandledExceptionEventTest.java
示例3: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context) {
loggers.get(context.getSubscriber().getClass()).log(
Level.SEVERE,
"Exception dispatching " + context.getEvent().getClass().getName() +
" to " + context.getSubscriber().getClass().getName() +
"#" + context.getSubscriberMethod().getName(),
exception
);
}
开发者ID:OvercastNetwork，项目名称:ProjectAres，代码行数:11，代码来源:EventExceptionHandler.java
示例4: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable throwable, SubscriberExceptionContext subscriberExceptionContext) {
String eventName = subscriberExceptionContext.getEvent().getClass().getSimpleName();
Class<?> subscriber = subscriberExceptionContext.getSubscriber().getClass();
LogManager.getLogger(subscriber).error("An error occurred on event " + eventName + " in " + subscriber.getName(), throwable);
}
开发者ID:Juraji，项目名称:Biliomi，代码行数:8，代码来源:EventSubscriberExceptionHandler.java
示例5: buildModList
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Subscribe
public void buildModList(FMLLoadEvent event)
{
Builder<String, EventBus> eventBus = ImmutableMap.builder();
for (final ModContainer mod : loader.getModList())
{
//Create mod logger, and make the EventBus logger a child of it.
EventBus bus = new EventBus(new SubscriberExceptionHandler()
{
@Override
public void handleException(final Throwable exception, final SubscriberExceptionContext context)
{
LoadController.this.errorOccurred(mod, exception);
}
});
boolean isActive = mod.registerBus(bus, this);
if (isActive)
{
activeModList.add(mod);
modStates.put(mod.getModId(), ModState.UNLOADED);
eventBus.put(mod.getModId(), bus);
FMLCommonHandler.instance().addModToResourcePack(mod);
}
else
{
FMLLog.log(mod.getModId(), Level.WARN, "Mod %s has been disabled through configuration", mod.getModId());
modStates.put(mod.getModId(), ModState.UNLOADED);
modStates.put(mod.getModId(), ModState.DISABLED);
}
modNames.put(mod.getModId(), mod.getName());
}
eventChannels = eventBus.build();
}
开发者ID:F1r3w477，项目名称:CustomWorldGen，代码行数:37，代码来源:LoadController.java
示例6: MentorEventBus
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
MentorEventBus() {
this(Executors.newWorkStealingPool(), new SubscriberExceptionHandler() {
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context) {
Log.error("Error in event handler ({})", context, exception);
}
});
}
开发者ID:vsite-hr，项目名称:mentor，代码行数:9，代码来源:MentorEventBus.java
示例7: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context)
{
String message = "Event: "
+ context.getEvent()
+ "\r\nSubscriber: "
+ context.getSubscriber()
+ "\r\nSubscriber method:"
+ context.getSubscriberMethod();
ErrorHandlerProvider.handle(context.getEventBus().toString(), message, exception);
}
开发者ID:overengineering，项目名称:space-travels-3，代码行数:12，代码来源:GuavaSubscriberExceptionHandler.java
示例8: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(final Throwable e, final SubscriberExceptionContext context) {
if ((e instanceof ClassCastException) && e.getMessage().contains(PoisonPill.class.getName())) {
LOG.debug("Poision Pill processed on: {}", context.getSubscriber().getClass().getSimpleName());
} else {
String msg = String.format("Could not call %s/%s on bus %s", context.getSubscriber().getClass().getSimpleName(),
context.getSubscriberMethod().getName(), name);
LOG.error(msg, e);
}
}
开发者ID:phenopolis，项目名称:pheno4j，代码行数:11，代码来源:ManagedEventBus.java
示例9: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(final Throwable exception, final SubscriberExceptionContext context)
{
String errmsg = "Could not dispatch event: " + context.getSubscriber() + " to " + context.getSubscriberMethod()
+ "\n Event: " + context.getEvent()
+ "\n Bus: " + context.getEventBus();
logger.error(errmsg, exception);
}
开发者ID:metasfresh，项目名称:metasfresh，代码行数:9，代码来源:EventBus.java
示例10: onSubscriberException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
protected void onSubscriberException(Throwable exception, @Nullable SubscriberExceptionContext
exceptionContext) {
if (exception instanceof InterruptedException) {
logger.log(Level.FINE, "EventBus Subscriber threw InterruptedException", exception);
Thread.currentThread().interrupt();
} else {
logger.log(Level.SEVERE, "An event subscriber threw an exception", exception);
eventBus.post(new UnexpectedThrowableEvent(exception, "An event subscriber threw an "
+ "exception on thread '" + Thread.currentThread().getName() + "'"));
}
}
开发者ID:WPIRoboticsProjects，项目名称:GRIP，代码行数:12，代码来源:GripCoreModule.java
示例11: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context) {
Class<?> listenerClass = context.getSubscriber().getClass();
String method = context.getSubscriberMethod().getName();
String event = context.getEvent().getClass().getSimpleName();
Logger logger = LoggerFactory.getLogger(listenerClass);
logger.error("Error dispatching event '" + event + "' to '"
+ listenerClass.getSimpleName() + "." + method + "'", exception);
}
开发者ID:sfera-labs，项目名称:sfera，代码行数:11，代码来源:Bus.java
示例12: EventBusThatPublishesUnhandledExceptionEvents
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
public EventBusThatPublishesUnhandledExceptionEvents() {
super(new SubscriberExceptionHandler() {
@Override
public void handleException(Throwable throwable, SubscriberExceptionContext subscriberExceptionContext) {
postUncaughtExceptionEvent(throwable);
}
});
errorMessageBus.register(this);
}
开发者ID:DavidWhitlock，项目名称:PortlandStateJava，代码行数:11，代码来源:EventBusThatPublishesUnhandledExceptionEvents.java
示例13: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Subscribe
public void handleException(ExceptionEvent e)
{
if (log.isErrorEnabled())
{
final String format = "当前事件为: %s\n当前订阅者为: %s\n订阅方法为: %s\nEventBus为: %s\n";
String msg = "\n";
log.error("检测到异常 :", e.getException());
msg += "===================================\n";
msg += "异常详细信息:\n";
SubscriberExceptionContext ctx = e.getContext();
if (ctx != null)
{
msg += String.format(format, ctx.getEvent(), ctx.getSubscriber(), ctx.getSubscriberMethod(), ctx
.getEventBus());
} else
msg += "无上下文信息.\n";
if (e.getExtra() != null)
{
msg += String.format("附加信息为: %s \n", e.getExtra());
} else
msg += "无附加信息.\n";
msg += "===================================";
log.error(msg);
}
}
开发者ID:wenerme，项目名称:tellets，代码行数:31，代码来源:AuxiliaryProcess.java
示例14: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context)
{
if (context.getEvent() instanceof ExceptionEvent)
{
log.error("处理错误过程中发生错误 上下文:" + context, exception);
return;
}
ExceptionEvent event = new ExceptionEvent(exception, context);
bus.post(event);
}
开发者ID:wenerme，项目名称:tellets，代码行数:12，代码来源:Events.java
示例15: AppEventBus
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
public AppEventBus() {
eventbus = new EventBus(new SubscriberExceptionHandler() {
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context) {
log.error("Could not dispatch event: " + context.getSubscriber() + " to " + context.getSubscriberMethod());
exception.printStackTrace();
}
});
}
开发者ID:rolandkrueger，项目名称:AppBaseForVaadin，代码行数:10，代码来源:AppEventBus.java
示例16: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable exception, SubscriberExceptionContext context) {
handleError("error in thread '" + Thread.currentThread().getName()
+ "' dispatching event to " + context.getSubscriber().getClass() + "." + context.getSubscriberMethod().getName(), exception);
}
开发者ID:MineboxOS，项目名称:minebox，代码行数:6，代码来源:GlobalErrorHandler.java
示例17: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable thrwbl, SubscriberExceptionContext sec) {
com.gmt2001.Console.err.println("Failed to dispatch event " + sec.getEvent().toString() + " to " + sec.getSubscriberMethod().toString());
com.gmt2001.Console.err.printStackTrace(thrwbl);
}
开发者ID:GloriousEggroll，项目名称:quorrabot，代码行数:6，代码来源:ExceptionHandler.java
示例18: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public void handleException(Throwable throwable, SubscriberExceptionContext subscriberExceptionContext) {
throwable.printStackTrace();
}
开发者ID:apache，项目名称:incubator-tamaya-sandbox，代码行数:5，代码来源:EventBus.java
示例19: handleException
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
@Override
public final void handleException(final Throwable exception,
final SubscriberExceptionContext context) {
exception.printStackTrace();
}
开发者ID:imotSpot，项目名称:imotSpot，代码行数:6，代码来源:DashboardEventBus.java
示例20: eventExceptionHandler
import com.google.common.eventbus.SubscriberExceptionContext; //导入依赖的package包/类
private static void eventExceptionHandler(Throwable exception, SubscriberExceptionContext context)
{
log.warn("uncaught exception in event subscriber", exception);
}
开发者ID:runelite，项目名称:runelite，代码行数:5，代码来源:RuneLiteModule.java
注：本文中的com.google.common.eventbus.SubscriberExceptionContext类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论