@Stateful
public class MySessionBean implements MySession {

    private static final Log log = LogFactory.getLog(MySessionBean.class);

    @PersistenceContext(type=PersistenceContextType.EXTENDED, properties=@PersistenceProperty(name="org.hibernate.flushMode", value="MANUAL"))
    private EntityManager entityManager;
   
    @EJB
    private CounterDAO counterDAO;
   
    public void test() {
        org.jboss.ejb3.entity.HibernateSession hs = (org.jboss.ejb3.entity.HibernateSession) entityManager;
        org.hibernate.Session session = hs.getHibernateSession();
        org.hibernate.FlushMode flushMode = session.getFlushMode();
        log.info(flushMode);
       
        for (int i = 0; i < 100; i++) {
            Integer value = counterDAO.increment(threadName);
        }
    }

    public void flush() {
        entityManager.flush();
    }

    @Remove
    public void destroy() {
        log.info("FtpSessionBean.destroy()");
    }
}