List of addPreProcessingAction() Examples

Examples of addPreProcessingAction()

org.mokai.ConnectorService.addPreProcessingAction()
Adds an {@link Action} to the collection of pre-processing actions if itdoesn't exists. Existence is determined by the {@link Action#equals(Object)}method. @param action the {@link Action} to be added. @return the {@link ConnectorService} instance (fluent API). @throws IllegalArgumentException if the action is null. @throws ObjectAlreadyExistsException if the action already exists in thecollection of pre-processing actions.
org.mokai.impl.camel.AbstractCamelConnectorService.addPreProcessingAction()

Examples of org.mokai.ConnectorService.addPreProcessingAction()

      processorService.addAcceptor(acceptor);
    }


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


    // add post-processing-actions to the processor
    for (Action action : postProcessingActions) {
      processorService.addPostProcessingAction(action);

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

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


    Action configurableAction = Mockito.mock(Action.class,
        Mockito.withSettings().extraInterfaces(Configurable.class));


    processorService.addPreProcessingAction(configurableAction);
    processorService.removePreProcessingAction(configurableAction);


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

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()


    MockProcessor processor = new MockProcessor();
    ConnectorService processorService = new MockConnectorService("test", processor, resourceRegistry);


    Action action = new StopAction();
    processorService.addPreProcessingAction(action);


    processorService.start();


    simulateMessage(new Message(), "activemq:mokai-test");

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

    Action action3 = Mockito.mock(Action.class);
    // duplicates the messages that arrive and generates 5 more as it wont stop the ones that arrived
    Action action4 = new SplitterAction(2, false);
    Action action5 = Mockito.mock(Action.class);


    processorService
      .addPreProcessingAction(action1)
      .addPreProcessingAction(action2)
      .addPreProcessingAction(action3)
      .addPreProcessingAction(action4)
      .addPreProcessingAction(action5);

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

    ConnectorService processorService = new MockConnectorService("test", processor, resourceRegistry);


    Action action = Mockito.mock(Action.class);
    Mockito.doThrow(new NullPointerException()).when(action).execute(Mockito.any(Message.class));


    processorService.addPreProcessingAction(action);


    processorService.start();


    simulateMessage(new Message(), "activemq:mokai-test");

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

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


    // test inject resource to pre-processing action
    MockAction action = new MockAction();
    processorService.addPreProcessingAction(action);
    Assert.assertNotNull(action.getMessageStore());


    // test inject resource to post-processing action
    action = new MockAction();
    processorService.addPostProcessingAction(action);

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

    MockProcessor processor = new MockProcessor();
    ConnectorService processorService = new MockConnectorService("test", processor, resourceRegistry);


    // add a pre-processing action
    MockAction preProcessingAction = new MockAction();
    processorService.addPreProcessingAction(preProcessingAction);


    // add another pre-processing action that changes the message
    processorService.addPreProcessingAction(new Action() {


      @Override

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

    // add a pre-processing action
    MockAction preProcessingAction = new MockAction();
    processorService.addPreProcessingAction(preProcessingAction);


    // add another pre-processing action that changes the message
    processorService.addPreProcessingAction(new Action() {


      @Override
      public void execute(Message message) throws Exception {
        Message smsMessage = (Message) message;
        smsMessage.setProperty("from", "1234");

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()


    Action action1 = new MockAction();
    Action action2 = new MockAction();


    // add first action
    processorService.addPreProcessingAction(action1);
    Assert.assertEquals(1, processorService.getPreProcessingActions().size());


    // add second action
    processorService.addPreProcessingAction(action2);
    Assert.assertEquals(2, processorService.getPreProcessingActions().size());

View Full Code Here

Examples of org.mokai.ConnectorService.addPreProcessingAction()

    // add first action
    processorService.addPreProcessingAction(action1);
    Assert.assertEquals(1, processorService.getPreProcessingActions().size());


    // add second action
    processorService.addPreProcessingAction(action2);
    Assert.assertEquals(2, processorService.getPreProcessingActions().size());


    List<Action> preProcessingActions  = processorService.getPreProcessingActions();
    Assert.assertEquals(preProcessingActions.get(0), action1);
    Assert.assertEquals(preProcessingActions.get(1), action2);

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.