Examples of net.jini.event.MailboxRegistration.enableDelivery()

Class net.jini.event.MailboxRegistration

Examples of net.jini.event.MailboxRegistration.enableDelivery()

net.jini.event.MailboxRegistration.enableDelivery()
Initiates delivery of stored notifications to the supplied target listener, if any. If a target listener already exists, then it will be replaced with the specified target listener. Passing null as the target parameter has the same effect as calling the disableDelivery method. @param target The listener to be notified of stored events, if any. @throws IllegalArgumentException if the supplied target parameter is a listener object that was generated by the mailbox service itself. @throws java.rmi.RemoteException if there isa communication failure between the client and the service.

  };


  // Enable the first of our listener objects
  assertCount(bad, 0);
  logger.log(Level.INFO, "Enabling delivery to our REL" + bad);
  mr.enableDelivery(bad);


        // Wait for events to arrive and verify.
  // Note that the listener object throws a 
  // NoSuchObjectException and should only
  // receive the first event.  This should cause

View Full Code Here

  logger.log(Level.INFO, "Asserting that event count hasn't changed");
  assertCount(bad, badCount);


  assertCount(good, goodCount);
  logger.log(Level.INFO, "Enabling delivery to our REL" + good);
  mr.enableDelivery(good);


  // Verify that the listener gets the proper events
  logger.log(Level.INFO, "Waiting for event delivery"); 
        goodCount = NUM_EVENTS+1;
        waitForEvents(good, goodCount, MAX_WAIT);

View Full Code Here

  };


  // Enable the first of our listener objects
  assertCount(myRel, 0);
  logger.log(Level.INFO, "Enabling delivery to our REL" + myRel);
  mr.enableDelivery(myRel);


      // Wait for events to arrive and verify
  logger.log(Level.INFO, "Wating for event delivery");
  waitForEvents(myRel, myRelCount, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery");

View Full Code Here

      throw new TestException("Successfully verified bogus events");
  }


  // Re-submit listener again
  logger.log(Level.INFO, "Re-enabling delivery to our REL");
  mr.enableDelivery(myRel);
  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(myRel, myRelCount);


      // Generate some more events
  for (i = 0; i < NUM_EVENTS; i++) {

View Full Code Here

  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(myRel, myRelCount);
  assertEvents(myRel, events);
  // enable second listener object
  logger.log(Level.INFO, "Enabling delivery to our REL2" + myRel2);
  mr.enableDelivery(myRel2);
  assertCount(myRel2, myRelCount2);


  // Generate some more events 
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);

View Full Code Here

  logger.log(Level.INFO, "Verifying that event counts haven't changed");
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


  logger.log(Level.INFO, "enabling delivery to REL");
  mr.enableDelivery(myRel);
  myRelCount += NUM_EVENTS*2;


  // Wait for events to arrive and verify
  logger.log(Level.INFO, "Wating for event delivery");
  waitForEvents(myRel, myRelCount, MAX_WAIT);

View Full Code Here

  assertEvents(myRel, events);
  assertEvents(myRel, events2);


  // Submit the null listener
  logger.log(Level.INFO, "Calling enableDelivery(null)");
  mr.enableDelivery(null);
  logger.log(Level.INFO, "Asserting that event counts haven't changed");
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


  // Generate another event

View Full Code Here

  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


  logger.log(Level.INFO, "Enabling REL2");
  myRelCount2 += 1;
  mr.enableDelivery(myRel2);
  logger.log(Level.INFO, "Wating for event delivery");
  waitForEvents(myRel2, myRelCount2, MAX_WAIT);
  logger.log(Level.INFO, "Asserting event counts ");
  assertCount(myRel2, myRelCount2);
  assertEvent(myRel2, evt);

View Full Code Here

  RemoteEvent evt2 = myGen2.generateEvent(evtReg2.getID(), 3);
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


  logger.log(Level.INFO, "Enabling REL2 ");
  mr.enableDelivery(myRel2);
  myRelCount2 += 2;


  logger.log(Level.INFO, "Waiting for event delivery");
  waitForEvents(myRel2, myRelCount2, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery");

View Full Code Here

  };


  // Enable the first of our listener objects
  assertCount(badListener, badCount);
  logger.log(Level.INFO, "Enabling delivery to our bad REL" + badListener);
  mr.enableDelivery(badListener);


        // Wait for events to arrive and verify.
  // Note that the listener object throws a 
  // RemoteException and can receive multiple
  // events (duplicate) events from redelivery

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.