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

Broker介绍

[英]The broker is the primary interface into the OpenJPA runtime. Each broker maintains an independent object cache and an independent transactional context.
[中]代理是OpenJPA运行时的主要接口。每个代理都维护一个独立的对象缓存和一个独立的事务上下文。

代码示例

代码示例来源：origin: stackoverflow.com

final PersistenceCapable pc = ((PersistenceCapable) detachedEntity);
 final Object[] state = (Object[]) pc.pcGetDetachedState();
 final BitSet loadedFieldsOnDetach = (BitSet) state[1];
 final OpenJPAEntityManager oem = getEntityManager();
 final Broker _broker = ((EntityManagerImpl) oem).getBroker();
 final ClassMetaData meta = _broker.getConfiguration().getMetaDataRepositoryInstance()
     .getMetaData(ImplHelper.getManagedInstance(detachedEntity).getClass(), _broker.getClassLoader(), true);
 for (final FieldMetaData fmd : meta.getDefinedFields()) {
   if (loadedFieldsOnDetach.get(fmd.getIndex())) {
     System.out.println(fmd.getName() + " was loaded on detach.");
   }
 }

代码示例来源：origin: org.apache.openejb.patch/openjpa-kernel

public DelegatingStoreManager getStoreManager() {
  try {
    return _broker.getStoreManager();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

/**
 * Return a persistence manager facade to the given broker retaining
 * previously associated persistence context type.
 */
public static OpenJPAEntityManager toEntityManager(Broker broker) {
  if (broker == null)
    return null;
  broker.lock();
  try {
    OpenJPAEntityManager em = (OpenJPAEntityManager)
      broker.getUserObject(EM_KEY);
    if (em == null) {
      EntityManagerFactoryImpl emf = (EntityManagerFactoryImpl)
        toEntityManagerFactory(broker.getBrokerFactory());
      em = emf.newEntityManagerImpl(broker);
      broker.putUserObject(EM_KEY, em);
    }
    return em;
  } catch (Exception e) {
    throw PersistenceExceptions.toPersistenceException(e);
  } finally {
    broker.unlock();
  }
}

代码示例来源：origin: org.compass-project/compass

private void commit(TransactionEvent trEvent) {
  Broker broker = (Broker) trEvent.getSource();
  CompassTransaction tr = (CompassTransaction) broker.getUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY);
  CompassSession session = (CompassSession) broker.getUserObject(COMPASS_SESSION_USER_OBJECT_KEY);
  try {
    if (openJpaControlledTransaction) {
      try {
        tr.commit();
      } finally {
        session.close();
      }
    }
  } finally {
    broker.putUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY, null);
    broker.putUserObject(COMPASS_SESSION_USER_OBJECT_KEY, null);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-jdbc

if (sm == null) {
  tmpBroker = ctx.getBroker();
  tmpBroker.transactional(candidate, false, null);
  sm = tmpBroker.getStateManager(candidate);
    tmpBroker.nontransactional(sm.getManagedInstance(), null);

代码示例来源：origin: org.apache.openjpa/openjpa-slice

public DistributedQueryImpl(Broker broker, String language, StoreQuery storeQuery) {
  super(broker, language, storeQuery);
  _lock = new ReentrantSliceLock();
  _conf = (DistributedConfiguration)broker.getConfiguration();
}

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

public boolean getMultithreaded() {
  try {
    return _broker.getMultithreaded();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-kernel

public BrokerFactory getBrokerFactory() {
  try {
    return _broker.getBrokerFactory();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openejb.patch/openjpa

public ClassLoader getClassLoader() {
  try {
    return _broker.getClassLoader();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-kernel

public LifecycleEventManager getLifecycleEventManager() {
  try {
    return _broker.getLifecycleEventManager();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-jdbc

public OpenJPASavepoint newSavepoint(String name, Broker broker) {
  // flush after creating savepoint b/c flush may add/change states
  OpenJPASavepoint save = new ConnectionSavepoint(broker, name, _restore);
  broker.flush();
  return save;
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

public Object putUserObject(Object key, Object val) {
  try {
    return _broker.putUserObject(key, val);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

public Object getUserObject(Object key) {
  try {
    return _broker.getUserObject(key);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-kernel

public OpenJPAStateManager getStateManager(Object obj) {
  try {
    return _broker.getStateManager(obj);
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

if (sm == null) {
  tmpBroker = ctx.getBroker();
  tmpBroker.transactional(candidate, false, null);
  sm = tmpBroker.getStateManager(candidate);
    tmpBroker.nontransactional(sm.getManagedInstance(), null);

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

public OpenJPAConfiguration getConfiguration() {
  try {
    return _broker.getConfiguration();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/openjpa-all

public boolean getMultithreaded() {
  try {
    return _broker.getMultithreaded();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.apache.openjpa/com.springsource.org.apache.openjpa

public BrokerFactory getBrokerFactory() {
  try {
    return _broker.getBrokerFactory();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}

代码示例来源：origin: org.compass-project/compass

private void rollback(TransactionEvent trEvent) {
    Broker broker = (Broker) trEvent.getSource();
    CompassTransaction tr = (CompassTransaction) broker.getUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY);
    CompassSession session = (CompassSession) broker.getUserObject(COMPASS_SESSION_USER_OBJECT_KEY);
    try {
      if (openJpaControlledTransaction) {
        try {
          tr.rollback();
        } finally {
          session.close();
        }
      }
    } finally {
      broker.putUserObject(COMPASS_TRANSACTION_USER_OBJECT_KEY, null);
      broker.putUserObject(COMPASS_SESSION_USER_OBJECT_KEY, null);
    }
  }
});

代码示例来源：origin: org.apache.openjpa/openjpa-all

public ClassLoader getClassLoader() {
  try {
    return _broker.getClassLoader();
  } catch (RuntimeException re) {
    throw translate(re);
  }
}