public EntityManagerImpl(SessionFactory sessionFactory,
    PersistenceContextType pcType,
    PersistenceUnitTransactionType transactionType,
    boolean discardOnClose,
    Map properties) 
{
	 
		super( pcType, transactionType, properties );
		this.sessionFactory = sessionFactory;
		this.open = true;
		this.discardOnClose = discardOnClose;
		postInit();
}

 public  void close() 
{
		if ( !open ) throw new IllegalStateException( "EntityManager is closed" );
		if ( !discardOnClose && isTransactionInProgress() ) {
			//delay the closing till the end of the enlisted transaction
			getSession().getTransaction().registerSynchronization(
					new Synchronization() {
						public void beforeCompletion() {
							//nothing to do
						}
						public void afterCompletion(int i) {
							if ( session != null ) {
								if ( session.isOpen() ) {
									log.debug( "Closing entity manager after transaction completion" );
									session.close();
								}
								else {
									log.warn( "Entity Manager closed by someone else ("
											+ Environment.AUTO_CLOSE_SESSION
											+ " must not be used)");
								}
							}
							//TODO session == null should not happen
						}
					}
			);
		}
		else {
			//close right now
			if ( session != null ) session.close();
		}
		open = false;
}

 protected Session getRawSession() 
{
		if ( session == null ) {
			session = sessionFactory.openSession();
			if ( persistenceContextType == PersistenceContextType.TRANSACTION ) {
				( (SessionImplementor) session ).setAutoClear( true );
			}
		}
		return session;
}

 public Session getSession() 
{
		if ( !open ) throw new IllegalStateException( "EntityManager is closed" );
		return getRawSession();
}

 public boolean isOpen() 
{
		//adjustFlushMode(); //don't adjust, can't be done on closed EM
		try {
			if ( open ) getSession().isOpen(); //to force enlistment in tx
			return open;
		}
		catch (HibernateException he) {
			throwPersistenceException( he );
			return false;
		}
}