import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Cleanup
 *
 * @throws ResourceException Thrown if an error occurs
 */
@Override
public void cleanup() throws ResourceException {
   if (logger.isTraceEnabled()) {
      ActiveMQRALogger.LOGGER.trace("cleanup()");
   }

   if (isDestroyed.get()) {
      throw new IllegalStateException("ManagedConnection already destroyed");
   }

   destroyHandles();

   inManagedTx = false;

   inManagedTx = false;

   // I'm recreating the lock object when we return to the pool
   // because it looks too nasty to expect the connection handle
   // to unlock properly in certain race conditions
   // where the dissociation of the managed connection is "random".
   lock = new ReentrantLock();
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
public void checkTransactionActive() throws JMSException {
   // don't bother looking at the transaction if there's an active XID
   if (!inManagedTx && tm != null) {
      try {
         Transaction tx = tm.getTransaction();
         if (tx != null) {
            int status = tx.getStatus();
            // Only allow states that will actually succeed
            if (status != Status.STATUS_ACTIVE && status != Status.STATUS_PREPARING && status != Status.STATUS_PREPARED && status != Status.STATUS_COMMITTING) {
               throw new javax.jms.IllegalStateException("Transaction " + tx + " not active");
            }
         }
      } catch (SystemException e) {
         JMSException jmsE = new javax.jms.IllegalStateException("Unexpected exception on the Transaction ManagerTransaction");
         jmsE.initCause(e);
         throw jmsE;
      }
   }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
@Override
public void configure() throws Exception {

    final CountDownLatch startLatch = new CountDownLatch(1);

    // verify that a component can be added manually
    getContext().addComponent("quartz2", new QuartzComponent() {
        @Override
        public void onCamelContextStarted(CamelContext context, boolean alreadyStarted) throws Exception {
            super.onCamelContextStarted(context, alreadyStarted);
            startLatch.countDown();
        }
    });

    from("quartz2://mytimer?trigger.repeatCount=3&trigger.repeatInterval=100")
    .process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            if (startLatch.getCount() > 0)
                throw new IllegalStateException("onCamelContextStarted not called");
        }
    })
    .to(MOCK_RESULT_URI);
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Get the physical connection handler.
 * This bummer will be called in two situations:
 * <ol>
 * <li>When a new mc has bean created and a connection is needed
 * <li>When an mc has been fetched from the pool (returned in match*)
 * </ol>
 * It may also be called multiple time without a cleanup, to support connection sharing.
 *
 * @param subject
 * @param info
 * @return A new connection object.
 * @throws ResourceException
 */
public Object getConnection(final Subject subject, final ConnectionRequestInfo info) throws ResourceException {
    // Check user first
    JmsCred cred = JmsCred.getJmsCred(mcf, subject, info);

    // Null users are allowed!
    if (user != null && !user.equals(cred.name)) {
        throw new SecurityException
                ("Password credentials not the same, reauthentication not allowed");
    }
    if (cred.name != null && user == null) {
        throw new SecurityException
                ("Password credentials not the same, reauthentication not allowed");
    }

    user = cred.name; // Basically meaningless

    if (isDestroyed) {
        throw new IllegalStateException("ManagedConnection already destroyd");
    }

    // Create a handle
    JmsSession handle = new JmsSession(this, (JmsConnectionRequestInfo) info);
    handles.add(handle);
    return handle;
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Get a connection
 *
 * @param subject       The security subject
 * @param cxRequestInfo The request info
 * @return The connection
 * @throws ResourceException Thrown if an error occurs
 */
@Override
public synchronized Object getConnection(final Subject subject,
                                         final ConnectionRequestInfo cxRequestInfo) throws ResourceException {
   if (logger.isTraceEnabled()) {
      ActiveMQRALogger.LOGGER.trace("getConnection(" + subject + ", " + cxRequestInfo + ")");
   }

   // Check user first
   ActiveMQRACredential credential = ActiveMQRACredential.getCredential(mcf, subject, cxRequestInfo);

   // Null users are allowed!
   if (userName != null && !userName.equals(credential.getUserName())) {
      throw new SecurityException("Password credentials not the same, reauthentication not allowed");
   }

   if (userName == null && credential.getUserName() != null) {
      throw new SecurityException("Password credentials not the same, reauthentication not allowed");
   }

   if (isDestroyed.get()) {
      throw new IllegalStateException("The managed connection is already destroyed");
   }

   ActiveMQRASession session = new ActiveMQRASession(this, (ActiveMQRAConnectionRequestInfo) cxRequestInfo);
   handles.add(session);
   return session;
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Move a handler from one mc to this one.
 *
 * @param obj An object of type ActiveMQSession.
 * @throws ResourceException     Failed to associate connection.
 * @throws IllegalStateException ManagedConnection in an illegal state.
 */
@Override
public void associateConnection(final Object obj) throws ResourceException {
   if (logger.isTraceEnabled()) {
      ActiveMQRALogger.LOGGER.trace("associateConnection(" + obj + ")");
   }

   if (!isDestroyed.get() && obj instanceof ActiveMQRASession) {
      ActiveMQRASession h = (ActiveMQRASession) obj;
      h.setManagedConnection(this);
      handles.add(h);
   } else {
      throw new IllegalStateException("ManagedConnection in an illegal state");
   }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Get the meta data for the connection.
 *
 * @return The meta data for the connection.
 * @throws ResourceException     Thrown if the operation fails.
 * @throws IllegalStateException Thrown if the managed connection already is destroyed.
 */
@Override
public ManagedConnectionMetaData getMetaData() throws ResourceException {
   if (logger.isTraceEnabled()) {
      ActiveMQRALogger.LOGGER.trace("getMetaData()");
   }

   if (isDestroyed.get()) {
      throw new IllegalStateException("The managed connection is already destroyed");
   }

   return new ActiveMQRAMetaData(this);
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Move a handler from one mc to this one.
 *
 * @param obj An object of type JmsSession.
 * @throws ResourceException     Failed to associate connection.
 * @throws IllegalStateException ManagedConnection in an illegal state.
 */
public void associateConnection(final Object obj) throws ResourceException {
    //
    // Should we check auth, ie user and pwd? FIXME
    //

    if (!isDestroyed && obj instanceof JmsSession) {
        JmsSession h = (JmsSession) obj;
        h.setManagedConnection(this);
        handles.add(h);
    } else {
        throw new IllegalStateException
                ("ManagedConnection in an illegal state");
    }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
/**
 * Get the meta data for the connection.
 *
 * @return The meta data for the connection.
 * @throws ResourceException
 * @throws IllegalStateException ManagedConnection already destroyed.
 */
public ManagedConnectionMetaData getMetaData() throws ResourceException {
    if (isDestroyed) {
        throw new IllegalStateException("ManagedConnection already destroyd");
    }

    return new JmsMetaData(this);
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
private void checkSize(int val, String name) throws IllegalStateException {
  if (val <= 0) throw new IllegalStateException(name + " must be > 0");
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
private void unencrypted(Session ctx, byte[] msg) throws Exception {
  Response r = getResponse(msg);
  lastResponse = r;

  log.info("Unencrypted: on session {}\n{}", ctx.getId(), mapper.writeValueAsString(r));

  if (!ok(r.getResponseCode())) return;

  if (ResponseCode.INFO == r.getResponseCode()) {
    Object[] payload = r.getPayload();
    if (payload == null || payload.length == 0 || !(payload[0] instanceof Map<?, ?>)) {
      throw new IllegalStateException("Expecting map of systemId:[value]");
    }

    systemId = (Long) ((Map<?, ?>) payload[0]).get("systemId");

    log.info("Setting system id {}", systemId);
    this.session = ctx;
    return;
  }

  JsonNode node = mapper.readTree(msg);
  JsonNode response = node.get("payload");

  boolean hasKey = response != null && response.isArray() && response.size() == 1;

  if (hasKey) {
    log.info("Setting key");
    otpKey = response.get(0).binaryValue();
    return;
  }

  switch (r.getType()) {
  case OtpKeyRequest.TYPE:
    log.info("Deleting key");
    otpKey = null;
    break;
  default:
    break;
  }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
private void unencrypted(ChannelHandlerContext ctx, byte[] msg) throws Exception {
  Response r = getResponse(msg);
  lastResponse = r;

  boolean c = ctx.pipeline().get(SslHandler.class) != null;

  log.info("Unencrypted: on {} channel\n{}", (c ? "secured" : "unsecured"), mapper.writeValueAsString(r));

  if (!ok(r.getResponseCode())) return;

  if (ResponseCode.INFO == r.getResponseCode()) {
    Object[] payload = r.getPayload();
    if (payload == null || payload.length == 0 || !(payload[0] instanceof Map<?, ?>)) {
      throw new IllegalStateException("Expecting map of systemId:[value]");
    }

    systemId = (Long) ((Map<?, ?>) payload[0]).get("systemId");

    log.info("Setting system id {}", systemId);
    clearChannel = ctx.channel();
    return;
  }

  JsonNode node = mapper.readTree(msg);
  JsonNode response = node.get("payload");

  boolean hasKey = response != null && response.isArray() && response.size() == 1;

  if (hasKey) {
    log.info("Setting key");
    otpKey = response.get(0).binaryValue();
    return;
  }

  switch (r.getType()) {
  case OtpKeyRequest.TYPE:
    log.info("Deleting key");
    otpKey = null;
    break;
  default:
    break;
  }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
@AroundInvoke
public Object aroundInvoke(final InvocationContext invocationContext) throws Exception {
    Principal desiredUser = null;
    RealmUser connectionUser = null;

    Map<String, Object> contextData = invocationContext.getContextData();
    if (contextData.containsKey(DELEGATED_USER_KEY)) {
        desiredUser = new SimplePrincipal((String) contextData.get(DELEGATED_USER_KEY));

        Connection con = SecurityActions.remotingContextGetConnection();

        if (con != null) {
            UserInfo userInfo = con.getUserInfo();
            if (userInfo instanceof SubjectUserInfo) {
                SubjectUserInfo sinfo = (SubjectUserInfo) userInfo;
                for (Principal current : sinfo.getPrincipals()) {
                    if (current instanceof RealmUser) {
                        connectionUser = (RealmUser) current;
                        break;
                    }
                }
            }

        } else {
            throw new IllegalStateException("Delegation user requested but no user on connection found.");
        }
    }

    SecurityContext cachedSecurityContext = null;
    boolean contextSet = false;
    try {
        if (desiredUser != null && connectionUser != null
                && (desiredUser.getName().equals(connectionUser.getName()) == false)) {
            // The final part of this check is to verify that the change does actually indicate a change in user.
            try {
                // We have been requested to switch user and have successfully identified the user from the connection
                // so now we attempt the switch.
                cachedSecurityContext = SecurityActions.securityContextSetPrincipalInfo(desiredUser,
                        new OuterUserCredential(connectionUser));
                // keep track that we switched the security context
                contextSet = true;
                SecurityActions.remotingContextClear();
            } catch (Exception e) {
                logger.error("Failed to switch security context for user", e);
                // Don't propagate the exception stacktrace back to the client for security reasons
                throw new EJBAccessException("Unable to attempt switching of user.");
            }
        }

        return invocationContext.proceed();
    } finally {
        // switch back to original security context
        if (contextSet) {
            SecurityActions.securityContextSet(cachedSecurityContext);
        }
    }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
@AroundInvoke
public Object aroundInvoke(final InvocationContext invocationContext) throws Exception {
    Principal desiredUser = null;
    RealmUser connectionUser = null;

    Map<String, Object> contextData = invocationContext.getContextData();
    if (contextData.containsKey(DELEGATED_USER_KEY)) {
        desiredUser = new SimplePrincipal((String) contextData.get(DELEGATED_USER_KEY));

        Connection con = SecurityActions.remotingContextGetConnection();

        if (con != null) {
            UserInfo userInfo = con.getUserInfo();
            if (userInfo instanceof SubjectUserInfo) {
                SubjectUserInfo sinfo = (SubjectUserInfo) userInfo;
                for (Principal current : sinfo.getPrincipals()) {
                    if (current instanceof RealmUser) {
                        connectionUser = (RealmUser) current;
                        break;
                    }
                }
            }

        } else {
            throw new IllegalStateException("Delegation user requested but no user on connection found.");
        }
    }

    SecurityContext cachedSecurityContext = null;
    boolean contextSet = false;
    try {
        if (desiredUser != null && connectionUser != null
            && (desiredUser.getName().equals(connectionUser.getName()) == false)) {
            // The final part of this check is to verify that the change does actually indicate a change in user.
            try {
                // We have been requested to switch user and have successfully identified the user from the connection
                // so now we attempt the switch.
                cachedSecurityContext = SecurityActions.securityContextSetPrincipalInfo(desiredUser,
                    new OuterUserCredential(connectionUser));
                // keep track that we switched the security context
                contextSet = true;
                SecurityActions.remotingContextClear();
            } catch (Exception e) {
                logger.error("Failed to switch security context for user", e);
                // Don't propagate the exception stacktrace back to the client for security reasons
                throw new EJBAccessException("Unable to attempt switching of user.");
            }
        }

        return invocationContext.proceed();
    } finally {
        // switch back to original security context
        if (contextSet) {
            SecurityActions.securityContextSet(cachedSecurityContext);
        }
    }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
@AroundInvoke
public Object aroundInvoke(final InvocationContext invocationContext) throws Exception {
    Principal desiredUser = null;
    RealmUser connectionUser = null;

    Map<String, Object> contextData = invocationContext.getContextData();
    logger.info(">>>>>>>>>> contextData " + contextData);
    if (contextData.containsKey(DELEGATED_USER_KEY)) {
        desiredUser = new SimplePrincipal((String) contextData.get(DELEGATED_USER_KEY));
        logger.info("desiredUser " + desiredUser);

        Connection con = SecurityActions.remotingContextGetConnection();

        if (con != null) {
            UserInfo userInfo = con.getUserInfo();
            if (userInfo instanceof SubjectUserInfo) {
                SubjectUserInfo sinfo = (SubjectUserInfo) userInfo;
                for (Principal current : sinfo.getPrincipals()) {
                    if (current instanceof RealmUser) {
                        connectionUser = (RealmUser) current;
                        break;
                    }
                }
            }

        } else {
            throw new IllegalStateException("Delegation user requested but no user on connection found.");
        }
    }

    SecurityContext cachedSecurityContext = null;
    boolean contextSet = false;
    try {
        if (desiredUser != null && connectionUser != null
                && (desiredUser.getName().equals(connectionUser.getName()) == false)) {
            // The final part of this check is to verify that the change does actually indicate a change in user.
            try {
                // We have been requested to switch user and have successfully identified the user from the connection
                // so now we attempt the switch.
                cachedSecurityContext = SecurityActions.securityContextSetPrincipalInfo(desiredUser,
                        new OuterUserCredential(connectionUser));
                logger.info(">>>>>>>>>>>>> Switch users ");
                // keep track that we switched the security context
                contextSet = true;
                SecurityActions.remotingContextClear();
            } catch (Exception e) {
                logger.error("Failed to switch security context for user", e);
                // Don't propagate the exception stacktrace back to the client for security reasons
                throw new EJBAccessException("Unable to attempt switching of user.");
            }
        }

        return invocationContext.proceed();
    } finally {
        // switch back to original security context
        if (contextSet) {
            SecurityActions.securityContextSet(cachedSecurityContext);
        }
    }
}
 

import javax.resource.spi.IllegalStateException; //导入依赖的package包/类
@AroundInvoke
public Object aroundInvoke(final InvocationContext invocationContext) throws Exception {
    Principal userPrincipal = null;
    RealmUser connectionUser = null;
    String authToken = null;

    Map<String, Object> contextData = invocationContext.getContextData();
    if (contextData.containsKey(SECURITY_TOKEN_KEY)) {
        authToken = (String) contextData.get(SECURITY_TOKEN_KEY);

        Connection con = SecurityActions.remotingContextGetConnection();

        if (con != null) {
            UserInfo userInfo = con.getUserInfo();
            if (userInfo instanceof SubjectUserInfo) {
                SubjectUserInfo sinfo = (SubjectUserInfo) userInfo;
                for (Principal current : sinfo.getPrincipals()) {
                    if (current instanceof RealmUser) {
                        connectionUser = (RealmUser) current;
                        break;
                    }
                }
            }
            userPrincipal = new SimplePrincipal(connectionUser.getName());

        } else {
            throw new IllegalStateException("Token authentication requested but no user on connection found.");
        }
    }

    SecurityContext cachedSecurityContext = null;
    boolean contextSet = false;
    try {
        if (userPrincipal != null && connectionUser != null && authToken != null) {
            try {
                // We have been requested to use an authentication token
                // so now we attempt the switch.
                cachedSecurityContext = SecurityActions.securityContextSetPrincipalCredential(userPrincipal,
                        new OuterUserPlusCredential(connectionUser, authToken));
                // keep track that we switched the security context
                contextSet = true;
                SecurityActions.remotingContextClear();
            } catch (Exception e) {
                logger.error("Failed to switch security context for user", e);
                // Don't propagate the exception stacktrace back to the client for security reasons
                throw new EJBAccessException("Unable to attempt switching of user.");
            }
        }

        return invocationContext.proceed();
    } finally {
        // switch back to original security context
        if (contextSet) {
            SecurityActions.securityContextSet(cachedSecurityContext);
        }
    }
}