java.lang.IllegalStateException.fillInStackTrace()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(123)

本文整理了Java中java.lang.IllegalStateException.fillInStackTrace()方法的一些代码示例,展示了IllegalStateException.fillInStackTrace()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IllegalStateException.fillInStackTrace()方法的具体详情如下:
包路径:java.lang.IllegalStateException
类名称:IllegalStateException
方法名:fillInStackTrace

IllegalStateException.fillInStackTrace介绍

暂无

代码示例

代码示例来源:origin: fusesource/mqtt-client

private static IllegalStateException createListenerNotSetError() {
  return (IllegalStateException) new IllegalStateException("No connection listener set to handle message received from the server.").fillInStackTrace();
}

代码示例来源:origin: fusesource/mqtt-client

private static IllegalStateException createDisconnectedError() {
  return (IllegalStateException) new IllegalStateException("Disconnected").fillInStackTrace();
}

代码示例来源:origin: org.fusesource.mqtt-client/mqtt-client

private static IllegalStateException createDisconnectedError() {
  return (IllegalStateException) new IllegalStateException("Disconnected").fillInStackTrace();
}

代码示例来源:origin: org.apache.qpid/proton-hawtdispatch

public static IllegalStateException illegalState(String msg) {
  return (IllegalStateException) new IllegalStateException(msg).fillInStackTrace();
}

代码示例来源:origin: org.fusesource.mqtt-client/mqtt-client

private static IllegalStateException createListenerNotSetError() {
  return (IllegalStateException) new IllegalStateException("No connection listener set to handle message received from the server.").fillInStackTrace();
}

代码示例来源:origin: com.caucho/resin

private static RuntimeException invalid(BlockStore store, String msg)
{
 IllegalStateException e = new IllegalStateException(msg);
 e.fillInStackTrace();
 log.log(Level.WARNING, e.toString(), e);
 
 throw e;
}

代码示例来源:origin: com.caucho/resin

private static IllegalStateException stateError(String msg)
 {
  IllegalStateException e = new IllegalStateException(msg);
  e.fillInStackTrace();
  log.log(Level.WARNING, e.toString(), e);
  return e;
 }
}

代码示例来源:origin: com.caucho/resin

private static RuntimeException corrupted(BlockStore store, String msg)
{
 IllegalStateException e = new IllegalStateException(msg);
 e.fillInStackTrace();
 log.log(Level.WARNING, e.toString(), e);
 
 e.printStackTrace();
 
 store.fatalCorrupted(msg);
 
 throw e;
}

代码示例来源:origin: co.cask.tigon/tigon-flow

@Override
public final ListenableFuture<ProgramController> stop() {
 if (!state.compareAndSet(State.STARTING, State.STOPPING)
     && !state.compareAndSet(State.ALIVE, State.STOPPING)
     && !state.compareAndSet(State.SUSPENDED, State.STOPPING)) {
  return Futures.immediateFailedFuture(new IllegalStateException("Resumption not allowed").fillInStackTrace());
 }
 final SettableFuture<ProgramController> result = SettableFuture.create();
 executor(State.STOPPING).execute(new Runnable() {
  @Override
  public void run() {
   try {
    caller.stopping();
    doStop();
    state.set(State.STOPPED);
    result.set(AbstractProgramController.this);
    caller.stopped();
   } catch (Throwable t) {
    error(t, result);
   }
  }
 });
 return result;
}

代码示例来源:origin: co.cask.tigon/tigon-flow

@Override
public final ListenableFuture<ProgramController> suspend() {
 if (!state.compareAndSet(State.ALIVE, State.SUSPENDING)) {
  return Futures.immediateFailedFuture(new IllegalStateException("Suspension not allowed").fillInStackTrace());
 }
 final SettableFuture<ProgramController> result = SettableFuture.create();
 executor(State.SUSPENDING).execute(new Runnable() {
  @Override
  public void run() {
   try {
    caller.suspending();
    doSuspend();
    state.set(State.SUSPENDED);
    result.set(AbstractProgramController.this);
    caller.suspended();
   } catch (Throwable t) {
    error(t, result);
   }
  }
 });
 return result;
}

代码示例来源:origin: co.cask.tigon/tigon-flow

@Override
public final ListenableFuture<ProgramController> resume() {
 if (!state.compareAndSet(State.SUSPENDED, State.RESUMING)) {
  return Futures.immediateFailedFuture(new IllegalStateException("Resumption not allowed").fillInStackTrace());
 }
 final SettableFuture<ProgramController> result = SettableFuture.create();
 executor(State.RESUMING).execute(new Runnable() {
  @Override
  public void run() {
   try {
    caller.resuming();
    doResume();
    state.set(State.ALIVE);
    result.set(AbstractProgramController.this);
    caller.alive();
   } catch (Throwable t) {
    error(t, result);
   }
  }
 });
 return result;
}

代码示例来源:origin: com.strapdata.cassandra/cassandra-all

notPresentFail.fillInStackTrace();

代码示例来源:origin: com.netflix.sstableadaptor/sstable-adaptor-cassandra

notPresentFail.fillInStackTrace();

代码示例来源:origin: com.caucho/resin

public UserPoolItem(ConnectionPool cm)
{
 _cm = cm;
 _id = _cm.generateId();
 _transaction = _cm.getTransaction();
 if (cm.getSaveAllocationStackTrace()) {
  _allocationStackTrace = new IllegalStateException(L.l("unclosed connection: " + this + " was allocated at"));
  _allocationStackTrace.fillInStackTrace();
 }
}

代码示例来源:origin: org.kaazing/netx.http

public final Socket createSocket(URL url) throws IOException {
  try {
    return createSocket0(url);
  }
  catch (SecurityException e) {
    try {
      URL bridge = new URL(url, BRIDGE_RESOURCE_PATH);
      ClassLoader parent = HttpOriginSecuritySpi.class.getClassLoader();
      URLClassLoader loader = URLClassLoader.newInstance(new URL[] { bridge }, parent);
      for (HttpOriginSecuritySpi security : load(HttpOriginSecuritySpi.class, loader)) {
        return security.createSocket(url);
      }
      String message = format("%s not found: %s", BRIDGE_RESOURCE_NAME, bridge);
      e.initCause(new IllegalStateException(message).fillInStackTrace());
      throw e;
    }
    catch (Exception e0) {
      e.initCause(e0);
      throw e;
    }
  }
}

代码示例来源:origin: de.dentrassi.eclipse.neoscada.core/org.eclipse.scada.da.server.common

protected WriteResult processWriteValue ( final Variant value, final OperationParameters operationParameters )
{
  final AttributeWriteHandler handler = this.writeHandler;
  if ( handler == null )
  {
    return new WriteResult ( new IllegalStateException ( "No write handler set" ).fillInStackTrace () );
  }
  try
  {
    handler.handleWrite ( value );
  }
  catch ( final Exception e )
  {
    return new WriteResult ( e );
  }
  return new WriteResult ();
}

代码示例来源:origin: org.kaazing/netx.http

@IgnoreJRERequirement
public final HttpURLConnection openConnection(URL url) throws IOException {
  try {
    return openConnection0(url);
  }
  catch (SecurityException e) {
    try {
      URL bridge = new URL(url, BRIDGE_RESOURCE_PATH);
      ClassLoader parent = getClass().getClassLoader();
      URLClassLoader loader = URLClassLoader.newInstance(new URL[] { bridge }, parent);
      for (HttpOriginSecuritySpi security : load(HttpOriginSecuritySpi.class, loader)) {
        return security.openConnection(url);
      }
      String message = format("%s not found: %s", BRIDGE_RESOURCE_NAME, bridge);
      e.addSuppressed(new IllegalStateException(message).fillInStackTrace());
      throw e;
    }
    catch (Exception e0) {
      if (e0 != e) {
        e.addSuppressed(e0);
      }
      throw e;
    }
  }
}

代码示例来源:origin: de.dentrassi.eclipse.neoscada.core/org.eclipse.scada.core.client.ngp

@Override
protected synchronized void handleMessage ( final Object message )
{
  logger.trace ( "handleMessage: {}", message );
  if ( message instanceof SessionAccepted )
  {
    handleSessionAccepted ( (SessionAccepted)message );
  }
  else if ( message instanceof SessionRejected )
  {
    // failure
    performDisconnected ( new IllegalStateException ( String.format ( "Failed to create session. Reply: %s", ( (SessionRejected)message ).getErrorReason () ) ).fillInStackTrace () );
  }
  else if ( message instanceof SessionPrivilegesChanged )
  {
    handlePrivilegeChange ( (SessionPrivilegesChanged)message );
  }
  else if ( message instanceof RequestCallbacks )
  {
    handleRequestCallbacks ( (RequestCallbacks)message );
  }
  else if ( message instanceof ResponseMessage )
  {
    handleResponse ( (ResponseMessage)message );
  }
}

代码示例来源:origin: org.eclipse.neoscada.core/org.eclipse.scada.core.client.ngp

@Override
protected synchronized void handleMessage ( final Object message )
{
  logger.trace ( "handleMessage: {}", message );
  if ( message instanceof SessionAccepted )
  {
    handleSessionAccepted ( (SessionAccepted)message );
  }
  else if ( message instanceof SessionRejected )
  {
    // failure
    performDisconnected ( new IllegalStateException ( String.format ( "Failed to create session. Reply: %s", ( (SessionRejected)message ).getErrorReason () ) ).fillInStackTrace () );
  }
  else if ( message instanceof SessionPrivilegesChanged )
  {
    handlePrivilegeChange ( (SessionPrivilegesChanged)message );
  }
  else if ( message instanceof RequestCallbacks )
  {
    handleRequestCallbacks ( (RequestCallbacks)message );
  }
  else if ( message instanceof ResponseMessage )
  {
    handleResponse ( (ResponseMessage)message );
  }
}

代码示例来源:origin: com.caucho/resin

exn.fillInStackTrace();

相关文章