Examples of MailboxRegistration

net.jini.event.MailboxRegistration
The MailboxRegistration defines the interface through which a client manages its registration and its notification processing. Event mailbox clients use this interface to:
- Manage the lease for this registration
- Obtain a RemoteEventListener reference that can be registered with event generators. This listener will then store any received events for this registration.
- Enable or disable the delivery of any stored events for this registration.
@author Sun Microsystems, Inc. @since 1.1

Examples of net.jini.event.MailboxRegistration


  logger.log(Level.INFO, "Getting ref to " + mbType);
  Lease mrl = null;
  if (mbType.equals(MAILBOX_IF_NAME)) {
      EventMailbox mb = getMailbox();
      MailboxRegistration mr = getRegistration(mb, DURATION);
      mrl = getMailboxLease(mr);
  } else if (mbType.equals(PULL_MAILBOX_IF_NAME)) {
            PullEventMailbox mb = getPullMailbox();
      MailboxPullRegistration mr = getPullRegistration(mb, DURATION);
      mrl = getPullMailboxLease(mr);

View Full Code Here

Examples of net.jini.event.MailboxRegistration

    public void run() throws Exception {
  EventMailbox mb = getConfiguredMailbox();        
  int i = 0;


  // Register and check lease
  MailboxRegistration mr = getRegistration(mb, DURATION1);
  Lease mrl = getMailboxLease(mr);
  checkLease(mrl, DURATION1); 


  // Get the mailbox service provided listener
  RemoteEventListener mbRel = getMailboxListener(mr);


  // Create an event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen = TestUtils.createGenerator(manager);
  EventRegistration evtReg = 
      myGen.register(EVENT_ID,  // Event ID to use
         null,    // handback
         mbRel,    // Notification target
         DURATION1);  // Lease duration
  Lease tgl = evtReg.getLease();
  checkLease(tgl, DURATION1); 


  // Create two listener objects
  TestListener bad = TestUtils.createNSOListener(manager);
  int badCount = 0;
  TestListener good = TestUtils.createListener(manager);
  int goodCount = 0;


  // Generate some events from first generator
  logger.log(Level.INFO, "Generating " + NUM_EVENTS + " events");
  RemoteEvent[] events = new RemoteEvent[NUM_EVENTS];
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }


  RemoteEvent[] bogus = {
      new RemoteEvent(myGen, 9999, 9999, null),
      new RemoteEvent(myGen, 5678, 1234, null),
  };


  // 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
  // the event mailbox to disableDelivery until
  // an another enableDelivery call occurs.
  logger.log(Level.INFO, "Wating for event delivery");
  badCount = 1;
        waitForEvents(bad, badCount, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(bad, badCount);
  logger.log(Level.INFO, "Verifying events ");
  assertEvent(bad, events[0]);
  if (bad.verifyEvents(events) ||
      bad.verifyEvents(bogus)    ) 
  {
      throw new TestException("Successfully verified bogus events");
  }


  // Send another event
  logger.log(Level.INFO, "Generating another event");
  RemoteEvent re = myGen.generateEvent(evtReg.getID(), 3);


  // Verify that the listener is not called.
  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

Examples of net.jini.event.MailboxRegistration

    public void run() throws Exception {
  EventMailbox mb = getConfiguredMailbox();        
  int i = 0;


  // Register and check lease
  MailboxRegistration mr = getRegistration(mb, DURATION1);
  Lease mrl = getMailboxLease(mr);
  checkLease(mrl, DURATION1); 


  // Get the mailbox service provided listener
  RemoteEventListener mbRel = getMailboxListener(mr);


  // Create an event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen = TestUtils.createGenerator(manager);
  EventRegistration evtReg = 
      myGen.register(EVENT_ID,       // Event ID to use
         null,      // handback
         mbRel,          // Notification target
         DURATION1);  // Lease duration
  Lease tgl = evtReg.getLease();
  checkLease(tgl, DURATION1); 


  // Create another event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen2 = TestUtils.createGenerator(manager);
  EventRegistration evtReg2 = 
      myGen2.register(EVENT_ID2,       // Event ID to use
          null,      // handback
          mbRel,          // Notification target
          DURATION1);  // Lease duration
  Lease tgl2 = evtReg2.getLease();
  checkLease(tgl2, DURATION1); 


  // Create two listener objects
  TestListener myRel = TestUtils.createListener(manager);
  TestListener myRel2 = TestUtils.createListener(manager);
  int myRelCount = 0, myRelCount2 = 0;


  // Generate some events from first generator
  RemoteEvent[] events = new RemoteEvent[NUM_EVENTS];
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }
  myRelCount += NUM_EVENTS;


  RemoteEvent[] bogus = {
      new RemoteEvent(myGen, 9999, 9999, null),
      new RemoteEvent(myGen2, 1234, 1, null),
  };


  // 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");
  assertCount(myRel, myRelCount);
  assertEvents(myRel, events);
  if (myRel.verifyEvents(bogus)) {
      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++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }
  myRelCount += NUM_EVENTS;
  waitForEvents(myRel, myRelCount, MAX_WAIT);
  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);
  }
  myRelCount2 += NUM_EVENTS;


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


  // Generate some more events from second generator
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen2.generateEvent(evtReg2.getID(), 3);
  }
  myRelCount2 += NUM_EVENTS;
  // Wait for events to arrive and verify
  logger.log(Level.INFO, "Wating for event delivery");
  waitForEvents(myRel2, myRelCount2, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(myRel2, myRelCount2);
  assertEvents(myRel2, events);
  // disable delivery
  mr.disableDelivery();
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);
  logger.log(Level.INFO, "Disabled delivery");


      // Generate some more events from each generator
  logger.log(Level.INFO, "Generating more events");
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }


  RemoteEvent[] events2 = new RemoteEvent[NUM_EVENTS];
  for (i = 0; i < NUM_EVENTS; i++) {
      events2[i] = myGen2.generateEvent(evtReg2.getID(), 3);
  }


  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);
  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(myRel, myRelCount);
  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 
  logger.log(Level.INFO, "Generating another event");
  RemoteEvent evt = myGen.generateEvent(evtReg.getID(), 3);


  logger.log(Level.INFO, "Asserting that event counts haven't changed");
  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);
  assertCount(myRel, myRelCount);


  logger.log(Level.INFO, "Disabling delivery");
  mr.disableDelivery();
  logger.log(Level.INFO, "Asserting event counts ");
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


      // Generate another event 
  logger.log(Level.INFO, "Generating another event");
  evt = myGen.generateEvent(evtReg.getID(), 3);


  logger.log(Level.INFO, "Disabling delivery again");
  mr.disableDelivery();
  logger.log(Level.INFO, "Asserting event counts ");
  assertCount(myRel, myRelCount);
  assertCount(myRel2, myRelCount2);


  // Generate another event 
  logger.log(Level.INFO, "Generating another event");
  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

Examples of net.jini.event.MailboxRegistration

    public void run() throws Exception {
  EventMailbox mb = getConfiguredMailbox();        
  int i = 0;


  // Register and check lease
  MailboxRegistration mr = getRegistration(mb, DURATION1);
  Lease mrl = getMailboxLease(mr);
  checkLease(mrl, DURATION1); 


  // Get the mailbox service provided listener
  RemoteEventListener mbRel = getMailboxListener(mr);


  // Create an event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen = TestUtils.createGenerator(manager);
  EventRegistration evtReg = 
      myGen.register(EVENT_ID,  // Event ID to use
         null,    // handback
         mbRel,    // Notification target
         DURATION1);  // Lease duration
  Lease tgl = evtReg.getLease();
  checkLease(tgl, DURATION1); 


  // Create two listener objects
  TestListener badListener = TestUtils.createREListener(manager);
  TestListener goodListener = TestUtils.createListener(manager);
  int badCount = 0;
  int goodCount = 0;


  // Generate some events 
  logger.log(Level.INFO, "Generating " + NUM_EVENTS + " events");
  RemoteEvent[] events = new RemoteEvent[NUM_EVENTS];
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }


  RemoteEvent[] bogus = {
      new RemoteEvent(myGen, 9999, 9999, null),
      new RemoteEvent(myGen, 5678, 1234, null),
  };


  // 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
  // attempts.
  logger.log(Level.INFO, "Wating for event delivery");
  badCount = 1;
        waitForEvents(badListener, badCount, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery count of " 
      + badCount);
  assertCount(badListener, badCount);
  logger.log(Level.INFO, "Verifying events ");
  assertEvent(badListener, events[0]);
  if (badListener.verifyEvents(events) ||
      badListener.verifyEvents(bogus)    ) 
  {
      throw new TestException("Successfully verified bogus events");
  }


        // Delay to (hopefully) ensure that 
        // some retries are attempted. This test
        // is timing dependent since after MAX_RETRIES 
        // the mailbox will discard the
        // remote event and move onto the next one, if any. 
        // If this delay is long enough to exceed the
        // MAX_RETRIES then the count will get bumped and
        // the test will fail.
        long delay = 7000;
  logger.log(Level.INFO, "Sleeping for " + delay);
  try {
            Thread.sleep(delay);
  } catch (InterruptedException ie) {
      logger.log(Level.INFO, "Sleep interrupted");
  } 


        // Note that the count should still be 1 since
        // retries will try to deliver the same event.
        // Listener counts distinct events. See note above.
  logger.log(Level.INFO, "Verifying event delivery count of " 
      + badCount);
  assertCount(badListener, badCount);
  // No need to assertEvents since it be the same one
  // as before.


  // Enable good listener
  assertCount(goodListener, goodCount);
  logger.log(Level.INFO, "Enabling good listener");
  mr.enableDelivery(goodListener);


  goodCount = 5;
  logger.log(Level.INFO, "Wating for event delivery of " + goodCount);
        waitForEvents(goodListener, goodCount, MAX_WAIT);
  logger.log(Level.INFO, "Asserting event count");

View Full Code Here

Examples of net.jini.event.MailboxRegistration

  logger.log(Level.INFO, "Getting ref to " + mbType); 
  Lease lease = null;
        if (mbType.equals(MAILBOX_IF_NAME)) {
      EventMailbox mb = getMailbox(); 
      logger.log(Level.INFO, "Generating a registration");
      MailboxRegistration mbr = getRegistration(mb, DURATION);
      logger.log(Level.INFO, "Getting registration lease");
      lease = getMailboxLease(mbr);
  } else if (mbType.equals(PULL_MAILBOX_IF_NAME)) {
      PullEventMailbox mb = getPullMailbox(); 
      logger.log(Level.INFO, "Generating a pull registration");

View Full Code Here

Examples of net.jini.event.MailboxRegistration

  Object admin1 = getMailboxAdmin(mb1);
  Object admin2 = getMailboxAdmin(mb2);
  Object admin1_dup = null;


        // Get Mailbox registration references
  MailboxRegistration mr1 = getRegistration(mb1, DURATION);
  MailboxRegistration mr2 = getRegistration(mb2, DURATION);
  MailboxRegistration mr1_dup = null;


        // Get Mailbox lease references
  Lease mrl1 = getMailboxLease(mr1);
  Lease mrl2 = getMailboxLease(mr2);
  Lease mrl1_dup = null;

View Full Code Here

Examples of net.jini.event.MailboxRegistration

            getConfig().getStringConfigVal(
    MAILBOX_PROPERTY_NAME,
    MAILBOX_IF_NAME);


  logger.log(Level.INFO, "Getting ref to " + mbType);
        MailboxRegistration mr = null;
  Lease mrl = null;
  if (mbType.equals(MAILBOX_IF_NAME)) {
      EventMailbox mb = getMailbox();
      mr = getRegistration(mb, DURATION);
      mrl = getMailboxLease(mr);
  } else if (mbType.equals(PULL_MAILBOX_IF_NAME)) {
            PullEventMailbox pmb = getPullMailbox();
      MailboxPullRegistration mpr = getPullRegistration(pmb, DURATION);
      mrl = getPullMailboxLease(mpr);
            mr = mpr;
   } else {
            throw new TestException(
    "Unsupported mailbox type requested" + mbType);
  }
        
  checkLease(mrl, DURATION); 


  // Get the mailbox service provided listener
  RemoteEventListener mbRel = getMailboxListener(mr);


  // Create an event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen = TestUtils.createGenerator(manager);
  EventRegistration evtReg = 
      myGen.register(EVENT_ID,  // Event ID to use
         null,    // handback
         mbRel,    // Notification target
         DURATION);  // Lease duration
  Lease tgl = evtReg.getLease();
  checkLease(tgl, DURATION); 


  // Create our target listener
  TestListener listener = TestUtils.createListener(manager);
  int evtCnt = 0;


  logger.log(Level.INFO, "Generating an event" + listener);
  myGen.generateEvent(evtReg.getID(), 3);


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


  logger.log(Level.INFO, "Wating for event delivery");
        evtCnt++;
        waitForEvents(listener, evtCnt, MAX_WAIT);
  logger.log(Level.INFO, "Verifying event delivery");
  assertCount(listener, evtCnt);


  logger.log(Level.INFO, "Disabling delivery to our REL");
  mr.enableDelivery(null);


  shutdown(0);


  logger.log(Level.INFO, "Generating an event" + listener);
  myGen.generateEvent(evtReg.getID(), 3);

View Full Code Here

Examples of net.jini.event.MailboxRegistration

    private final long VALID_DURATION_ANY = Lease.ANY;


    public void run() throws Exception {
  EventMailbox mb = getConfiguredMailbox();        


  MailboxRegistration mr1 = getRegistration(mb, DURATION1);
  checkLease(getMailboxLease(mr1), DURATION1); 


  MailboxRegistration mr2 = getRegistration(mb, Lease.FOREVER);
  checkLease(getMailboxLease(mr2), Lease.FOREVER); 


  MailboxRegistration mr3 = getRegistration(mb, Lease.ANY);
  checkLease(getMailboxLease(mr3), Lease.ANY); 


  MailboxRegistration mr4 = null;
  try {
      mr4 =  getRegistration(mb, INVALID_DURATION_NEG);
      throw new TestException("Illegal negative duration value "
          + "was accepted");
  } catch (IllegalArgumentException iae) {

View Full Code Here

Examples of net.jini.event.MailboxRegistration

    public void run() throws Exception {
  EventMailbox mb = getConfiguredMailbox();        
  int i = 0;


  // Register and check lease
  MailboxRegistration mr = getRegistration(mb, DURATION1);
  logger.log(Level.INFO, "Got registration ref {0}", mr);
        Lease mrl = getMailboxLease(mr);
  logger.log(Level.INFO, "Got lease ref {0}", mrl);
        checkLease(mrl, DURATION1); 
  logger.log(Level.INFO, "Mailbox lease good until " 
        + new Date(mrl.getExpiration()));


  // Get the mailbox service provided listener
  RemoteEventListener mbRel = getMailboxListener(mr);
  logger.log(Level.INFO, "Got RemoteEventListener ref {0}", mbRel);
        
  // Create an event generator and pass it the
  // mailbox's remote event listener.
  TestGenerator myGen = TestUtils.createGenerator(manager);
  logger.log(Level.INFO, "Got TestGenerator ref {0}", myGen);
  EventRegistration evtReg = 
      myGen.register(EVENT_ID,       // Event ID to use
         null,      // handback
         mbRel,          // Notification target
         DURATION1);  // Lease duration
  logger.log(Level.INFO, "Got EventRegistration ref {0}", evtReg);
  Lease tgl = evtReg.getLease();
  checkLease(tgl, DURATION1); 
  logger.log(Level.INFO, "EventRegistration lease good until " 
        + new Date(tgl.getExpiration()));


  // Create two listener objects
  TestListener myListener = 
      TestUtils.createDisableNSOListener(manager, mr);
  logger.log(Level.INFO, "Got TestListener ref {0}", myListener);
  int eventCount = 0;


  // Generate some events 
  logger.log(Level.INFO, "Generating " + NUM_EVENTS + " events");
  RemoteEvent[] events = new RemoteEvent[NUM_EVENTS];
  for (i = 0; i < NUM_EVENTS; i++) {
      events[i] = myGen.generateEvent(evtReg.getID(), 3);
  }


  RemoteEvent[] bogus = {
      new RemoteEvent(myGen, 9999, 9999, null),
      new RemoteEvent(myGen, 5678, 1234, null),
  };


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


        // Add an extra delay here since we'll only block
  // on the receipt of one event, but we really want 
  // to see if a second event is sent as well.
  logger.log(Level.INFO, "sleeping for 5 sec");

View Full Code Here

Examples of net.jini.event.MailboxRegistration


  logger.log(Level.INFO, "Getting ref to " + mbType);
  Lease mrl = null;
  if (mbType.equals(MAILBOX_IF_NAME)) {
      EventMailbox mb = getMailbox();
      MailboxRegistration mr = getRegistration(mb, DURATION);
      mrl = getMailboxLease(mr);
  } else if (mbType.equals(PULL_MAILBOX_IF_NAME)) {
            PullEventMailbox mb = getPullMailbox();
      MailboxPullRegistration mr = getPullRegistration(mb, DURATION);
      mrl = getPullMailboxLease(mr);

View Full Code Here

0 1 2

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.