183184185186187188189190191192193
return result2; } try { holder.wait(timeout); } catch (InterruptedException x) { Thread.currentThread().interrupt(); }
309310311312313314315316317318319
handler.addNotificationListener(id, new NotificationTuple(name, listener, null, null)); synchronized (holder) { while (lost.get() == 0) holder.wait(10); assertEquals(lost.get(), losts); } handler.removeNotificationListeners(new Integer[]{id}); }
8687888990919293949596
ObjectName remoteMLetName = ObjectName.getInstance(":type=mlet"); remoteServer.registerMBean(remoteMLet, remoteMLetName); synchronized (holder) { while (holder.get() == null) holder.wait(10); assertNotNull(holder.get()); holder.set(null); } // Remove the listener