Unstable work event listener monitor changes with user transactions

@Test public void listenerAdapterExceptionTest() throws RepositoryException, NotSupportedException, SystemException, SecurityException, IllegalStateException, RollbackException, HeuristicMixedException, HeuristicRollbackException, InterruptedException { // initialize workspace Session session = getSession(); session.getRootNode().addNode( "folder1" ); session.save(); // register listener for PropertyEvent with nodeType restriction Session listenerSession = repository().login(); EventListener listener = new EventListener() { public void onEvent(EventIterator events) { while (events.hasNext()) { Event event = events.nextEvent(); System .out.println(event.toString()); } } }; TransactionManager txman = repository().transactionManager(); listenerSession .getWorkspace() .getObservationManager() .addEventListener(listener, Event.PROPERTY_ADDED | Event.PROPERTY_REMOVED | Event.PROPERTY_CHANGED, "/folder1" , true , null , new String [] { "nt:unstructured" }, false ); // try to add nodes within transactions for ( int i = 0; i < 1000; i++) { txman.begin(); Session session1 = repository().login(); session1.getNode( "/folder1" ).addNode( "node" + i); session1.save(); session1.logout(); txman.commit(); } // wait for listener thread Thread .sleep(1000); // clean listenerSession.getWorkspace().getObservationManager().removeEventListener(listener); listenerSession.logout(); // check system out } @Test public void catchExceptionTest() throws RepositoryException, NotSupportedException, SystemException, SecurityException, IllegalStateException, RollbackException, HeuristicMixedException, HeuristicRollbackException, InterruptedException { // initialize workspace Session session = getSession(); session.getRootNode().addNode( "folder2" ); session.save(); // register NODE_ADDED listener final Session listenerSession = repository().login(); final ArrayList<Event> failedEvents = new ArrayList<Event>(); EventListener listener = new EventListener() { public void onEvent(EventIterator events) { while (events.hasNext()) { Event event = events.nextEvent(); try { // try to find created node listenerSession.getNode(event.getPath()); } catch (RepositoryException e) { // register fails failedEvents.add(event); e.printStackTrace(); } System .out.println(event.toString()); } } }; listenerSession.getWorkspace().getObservationManager() .addEventListener(listener, Event.NODE_ADDED, "/folder2" , true , null , null , false ); TransactionManager txman = repository().transactionManager(); // try to add nodes within transactions int transactions = 1000; for ( int i = 0; i < transactions; i++) { txman.begin(); Session session1 = repository().login(); session1.getNode( "/folder2" ).addNode( "node" + i); session1.save(); session1.logout(); txman.commit(); } // wait for listener thread Thread .sleep(1000); // clean listenerSession.getWorkspace().getObservationManager().removeEventListener(listener); listenerSession.logout(); // assert result Assert.assertEquals( "Failed events" , 0 + " / " + transactions, failedEvents.size() + " / " + transactions); }