List of addAcceptor() Examples

Examples of addAcceptor()

org.mokai.ConnectorService.addAcceptor()
Adds an {@link Acceptor} to the collection of acceptors if it doesn'texists. Existence of an acceptor is determined by the {@link Acceptor#equals(Object)} method. @param acceptor the {@link Acceptor} instance to be added. @return the {@link ConnectorService} instance (fluent API). @throws IllegalArgumentException if the acceptor is null. @throws ObjectAlreadyExistsException if the acceptor already exists.
org.mokai.acceptor.AndAcceptor.addAcceptor()
org.mokai.acceptor.OrAcceptor.addAcceptor()

Examples of org.mokai.ConnectorService.addAcceptor()

    int maxConcurrentMsgs = getMaxConcurrentMsgs(connectorElement);
    processorService.setMaxConcurrentMsgs(maxConcurrentMsgs);


    // add acceptors to the processor
    for (Acceptor acceptor : acceptors) {
      processorService.addAcceptor(acceptor);
    }


    // add pre-processing-actions to the processor
    for (Action action : preProcessingActions) {
      processorService.addPreProcessingAction(action);

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

    ConnectorService processorService = new MockConnectorService("test", Mockito.mock(Processor.class), resourceRegistry);


    Acceptor configurableAcceptor = Mockito.mock(Acceptor.class,
        Mockito.withSettings().extraInterfaces(Configurable.class));


    processorService.addAcceptor(configurableAcceptor);
    processorService.removeAcceptor(configurableAcceptor);


    Mockito.verify((Configurable) configurableAcceptor).configure();
    Mockito.verify((Configurable) configurableAcceptor).destroy();
  }

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()


    Processor processor = Mockito.mock(Processor.class);
    ConnectorService processorService = new MockConnectorService("test", processor, resourceRegistry);


    MockAcceptor acceptor = new MockAcceptor();
    processorService.addAcceptor(acceptor);


    Assert.assertNotNull(acceptor.getMessageStore());
  }


  @Test

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

  }


  @Test(expectedExceptions=IllegalArgumentException.class)
  public void shouldFailWithNullAcceptor() throws Exception {
    ConnectorService processorService = new MockConnectorService("test", new MockProcessor(), resourceRegistry);
    processorService.addAcceptor(null);
  }


  @Test(expectedExceptions=IllegalArgumentException.class)
  public void shouldFailWithEmptyId() throws Exception {
    new MockConnectorService("", new MockProcessor(), resourceRegistry);

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()


    Acceptor acceptor1 = Mockito.mock(Acceptor.class);
    Acceptor acceptor2 = Mockito.mock(Acceptor.class);


    // add first acceptor
    processorService.addAcceptor(acceptor1);
    Assert.assertEquals(1, processorService.getAcceptors().size());


    // add second acceptor
    processorService.addAcceptor(acceptor2);
    Assert.assertEquals(2, processorService.getAcceptors().size());

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

    // add first acceptor
    processorService.addAcceptor(acceptor1);
    Assert.assertEquals(1, processorService.getAcceptors().size());


    // add second acceptor
    processorService.addAcceptor(acceptor2);
    Assert.assertEquals(2, processorService.getAcceptors().size());


    List<Acceptor> acceptors = processorService.getAcceptors();
    Assert.assertEquals(acceptors.get(0), acceptor1);
    Assert.assertEquals(acceptors.get(1), acceptor2);

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

      routingEngine.start();


      // create the connection
      MockProcessor processor = new MockProcessor();
      ConnectorService connection = routingEngine.addConnection("1", processor);
      connection.addAcceptor(new MockAcceptor());
      connection.start();


      // create the application
      MockConnector receiver = new MockConnector();
      ConnectorService application = routingEngine.addApplication("1", receiver);

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

      routingEngine.start();


      // create the application
      MockProcessor processor = new MockProcessor();
      ConnectorService application = routingEngine.addApplication("1", processor);
      application.addAcceptor(new MockAcceptor());
      application.start();


      // create the connection
      MockConnector receiver = new MockConnector();
      ConnectorService connection = routingEngine.addConnection("1", receiver);

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

      routingEngine.start();


      // create the processor
      MockProcessor processor = new MockProcessor();
      ConnectorService processorService = routingEngine.addConnection("1", processor);
      processorService.addAcceptor(new Acceptor() {


        @Override
        public boolean accepts(Message message) {
          return false;
        }

View Full Code Here

Examples of org.mokai.ConnectorService.addAcceptor()

      routingEngine.start();


      // create the processor
      MockProcessor processor = new MockProcessor();
      ConnectorService processorService = routingEngine.addConnection("1", processor);
      processorService.addAcceptor(new Acceptor() {


        @Override
        public boolean accepts(Message message) {
          return false;
        }

View Full Code Here

0 1

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.