Examples of PostOffice

de.micromata.opengis.kml.v_2_2_0.xal.PostOffice
hermes.postoffice.PostOffice
Listens for OSC, mouse, and keyboard messages; can also send OSC messages.
Objects can register "subscriptions" with the P.O. for a particular type of message. When that type of message is received, P.O. tells subscribers and passes along the information stored in the message.
net.myexperiments.gos.messaging.PostOffice
ninja.postoffice.Postoffice
Simply takes a Mail and sends it. Can be used for instance with the implementation that uses Apache CommonsMail. Or the Mockmailer. Or your own implementation. @author rbauer
org.hornetq.core.postoffice.PostOffice
A PostOffice instance maintains a mapping of a String address to a Queue. Multiple Queue instances can be bound with the same String address. Given a message and an address a PostOffice instance will route that message to all the Queue instances that are registered with that address. Addresses can be any String instance. A Queue instance can only be bound against a single address in the post office. @author Tim Fox
org.jboss.messaging.core.contract.PostOffice
A post office holds bindings of queues to conditions. When routing a reference, the post office routes the reference to any binding whose condition matches the condition specified in the call to route(...) A queue can only be bound with one condition in the post office Each queue must have a unique name and channel ID @author Tim Fox @author Clebert Suconic @author Ovidiu Feodorov @version $Revision: 3332 $ $Id: PostOffice.java 3332 2007-11-15 09:32:43Z timfox $
org.jboss.messaging.core.plugin.contract.PostOffice
A PostOffice A post office holds bindings of queues to conditions. When routing a reference, the post office routes the reference to any binding whose condition matches the condition specified in the call to route(...) Currently we only support conditions where the condition is an exact text match, and there is a single binding per queue. @author Tim Fox @author Clebert Suconic @author Ovidiu Feodorov @version $Revision: 2202 $ $Id: PostOffice.java 2202 2007-02-08 10:50:26Z timfox $

Examples of hermes.postoffice.PostOffice

    assertEquals(beings[5].getInteractionsWith(beings[1]), 3);
  }
  
  @Test
  public void test_LockUpdateRate() {
    World w = new World(new PostOffice(), new HCamera());
    w.lockUpdateRate(5);
    long time = System.currentTimeMillis();
    w.update();
    long elapsed = System.currentTimeMillis() - time;
    assertEquals(elapsed,200,5);

View Full Code Here

Examples of hermes.postoffice.PostOffice

  class TestWorld1 extends World {


    int nUpdates;
    
    public TestWorld1(int nUpdates) {
      super(new PostOffice(5000,5001), new HCamera());
      this.nUpdates = nUpdates;
    }

View Full Code Here

Examples of hermes.postoffice.PostOffice

    boolean postUpdated = false;
    boolean setupCalled = false;
    boolean shutdownCalled = false;
    
    public TestWorld2() {
      super(new PostOffice(), new HCamera());
    }

View Full Code Here

Examples of net.myexperiments.gos.messaging.PostOffice

     * Setup System
     * 
     */
//    layout = new CreateWorld(this);
    scheduler = new EventQueue(this);
    GOSPS = new PostOffice();
    /**
     * 
     * Create console
     * 
     */

View Full Code Here

Examples of ninja.postoffice.Postoffice

    public void testSending() throws Exception {


        // ////////////////////////////////////////////////////////////////////
        // Setup the mockpostoffice
        // ////////////////////////////////////////////////////////////////////
        Postoffice postoffice = new PostofficeMockImpl();


        // /////////////////////////////////////////////////////////////////////
        // Sending of first mail.
        // /////////////////////////////////////////////////////////////////////
        Mail firstMail = new MailImpl();


        firstMail.setSubject("first mail");
        firstMail.addTo("to@localhost");
        firstMail.setFrom("from@localhost");
        firstMail.setBodyText("simple body text");


        // make sure that mocked mailer did not send email previously
        assertEquals(null, ((PostofficeMockImpl) postoffice).getLastSentMail());


        postoffice.send(firstMail);


        // and test that mail has been sent.
        assertEquals("first mail", ((PostofficeMockImpl) postoffice).getLastSentMail().getSubject());
        assertTrue(((PostofficeMockImpl) postoffice).getLastSentMail().getTos()
                .contains("to@localhost"));
        assertTrue(((PostofficeMockImpl) postoffice).getLastSentMail().getFrom().equals(
                "from@localhost"));
        assertTrue(((PostofficeMockImpl) postoffice).getLastSentMail().getBodyText().equals(
                "simple body text"));


        // /////////////////////////////////////////////////////////////////////
        // Sending of another mail. Check that mock mailer handles repeated
        // sending correctly.
        // /////////////////////////////////////////////////////////////////////
        Mail secondMail = new MailImpl();


        secondMail.setSubject("second mail");
        secondMail.addTo("to@localhost");
        secondMail.setFrom("from@localhost");
        secondMail.setBodyText("simple body text");


        // send simple mail via mocked postoffice
        postoffice.send(secondMail);


        // and test that mail has been sent.
        assertEquals("second mail", ((PostofficeMockImpl) postoffice).getLastSentMail().getSubject());
        assertTrue(((PostofficeMockImpl) postoffice).getLastSentMail().getTos()
                .contains("to@localhost"));

View Full Code Here

Examples of org.hornetq.core.postoffice.PostOffice

      if (server == null)
      {
         throw new IllegalArgumentException("No server at " + node);
      }


      PostOffice po = server.getPostOffice();


      long start = System.currentTimeMillis();


      int messageCount = 0;

View Full Code Here

Examples of org.hornetq.core.postoffice.PostOffice

      if (server == null)
      {
         throw new IllegalArgumentException("No server at " + node);
      }


      PostOffice po = server.getPostOffice();


      long start = System.currentTimeMillis();


      int bindingCount = 0;


      int totConsumers = 0;


      do
      {
         bindingCount = 0;


         totConsumers = 0;


         Bindings bindings = po.getBindingsForAddress(new SimpleString(address));


         for (Binding binding : bindings.getBindings())
         {
            if (binding instanceof LocalQueueBinding && local || binding instanceof RemoteQueueBinding && !local)
            {
               QueueBinding qBinding = (QueueBinding)binding;


               bindingCount++;


               totConsumers += qBinding.consumerCount();
            }
         }


         if (bindingCount == count && totConsumers == consumerCount)
         {
            return;
         }


         Thread.sleep(10);
      }
      while (System.currentTimeMillis() - start < ClusterTestBase.WAIT_TIMEOUT);


      // System.out.println(threadDump(" - fired by ClusterTestBase::waitForBindings"));


      String msg = "Timed out waiting for bindings (bindingCount = " + bindingCount +
                   ", totConsumers = " +
                   totConsumers +
                   ")";


      ClusterTestBase.log.error(msg);


      // Sending thread dump into junit report.. trying to get some information about the server case the binding didn't
      // arrive
      System.out.println(UnitTestCase.threadDump(msg));


      Bindings bindings = po.getBindingsForAddress(new SimpleString(address));


      System.out.println("=======================================================================");
      System.out.println("Binding information for address = " + address + " on node " + node);


      for (Binding binding : bindings.getBindings())

View Full Code Here

Examples of org.hornetq.core.postoffice.PostOffice

      File testdir = new File(getTestDir());
      deleteDirectory(testdir);


      Configuration configuration = createDefaultConfig();


      PostOffice postOffice = new FakePostOffice();


      final JournalStorageManager journal = new JournalStorageManager(configuration, execFactory);


      try
      {

View Full Code Here

Examples of org.hornetq.core.postoffice.PostOffice

      if (server == null)
      {
         throw new IllegalArgumentException("No server at " + node);
      }


      PostOffice po = server.getPostOffice();


      long start = System.currentTimeMillis();


      int messageCount = 0;

View Full Code Here

Examples of org.hornetq.core.postoffice.PostOffice

      if (server == null)
      {
         throw new IllegalArgumentException("No server at " + node);
      }


      PostOffice po = server.getPostOffice();


      long start = System.currentTimeMillis();


      int bindingCount = 0;


      int totConsumers = 0;


      do
      {
         bindingCount = 0;


         totConsumers = 0;


         Bindings bindings = po.getBindingsForAddress(new SimpleString(address));


         for (Binding binding : bindings.getBindings())
         {
            if (binding instanceof LocalQueueBinding && local || binding instanceof RemoteQueueBinding && !local)
            {
               QueueBinding qBinding = (QueueBinding)binding;


               bindingCount++;


               totConsumers += qBinding.consumerCount();
            }
         }


         if (bindingCount == count && totConsumers == consumerCount)
         {
            return;
         }


         Thread.sleep(10);
      }
      while (System.currentTimeMillis() - start < ClusterTestBase.WAIT_TIMEOUT);


      // System.out.println(threadDump(" - fired by ClusterTestBase::waitForBindings"));


      String msg = "Timed out waiting for bindings (bindingCount = " + bindingCount +
                   ", totConsumers = " +
                   totConsumers +
                   ")";


      ClusterTestBase.log.error(msg);


      // Sending thread dump into junit report.. trying to get some information about the server case the binding didn't
      // arrive
      System.out.println(UnitTestCase.threadDump(msg));


      Bindings bindings = po.getBindingsForAddress(new SimpleString(address));


      System.out.println("=======================================================================");
      System.out.println("Binding information for address = " + address + " on node " + node);


      for (Binding binding : bindings.getBindings())

View Full Code Here

0 1 2 3 4 5

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.