Examples of org.milyn.javabean.context.BeanContext.addBean()

Class org.milyn.javabean.context.BeanContext

Examples of org.milyn.javabean.context.BeanContext.addBean()

org.milyn.javabean.context.BeanContext.addBean()
Add a bean instance under the specified {@link BeanId}. @param beanId The {@link org.milyn.javabean.repository.BeanId} under which the bean is to be stored. @param bean The bean instance to be stored.

                    FilterSource.setSource(executionContext, source);
                    FilterResult.setResults(executionContext, results);


                    // Add pre installed beans + global BeanContext lifecycle observers...
                    BeanContext beanContext = executionContext.getBeanContext();
                    beanContext.addBean(Time.BEAN_ID, new Time());
                    beanContext.addBean(UniqueID.BEAN_ID, new UniqueID());
                    for(BeanContextLifecycleObserver observer : context.getBeanContextLifecycleObservers()) {
                        beanContext.addObserver(observer);
                    }

View Full Code Here

                    FilterResult.setResults(executionContext, results);


                    // Add pre installed beans + global BeanContext lifecycle observers...
                    BeanContext beanContext = executionContext.getBeanContext();
                    beanContext.addBean(Time.BEAN_ID, new Time());
                    beanContext.addBean(UniqueID.BEAN_ID, new UniqueID());
                    for(BeanContextLifecycleObserver observer : context.getBeanContextLifecycleObservers()) {
                        beanContext.addObserver(observer);
                    }


                    try {

View Full Code Here

    long begin = System.currentTimeMillis();
    for(int l = 0; l < loops; l++) {


      for(BeanId id: beanIds) {
        BeanContext beanContext = executionContext.getBeanContext();
        beanContext.addBean(id, bean, null);
      }
      for(BeanId id: beanIds) {
        BeanContext beanContext = executionContext.getBeanContext();
        beanContext.getBean(id);
      }

View Full Code Here

        value = value + amount;
      } else {
        value = value - amount;
      }
    }
    beanContext.addBean(beanId, value, source);
  }




  private Long getStart(BeanContext beanContext) {

View Full Code Here

            BeanContext beanContext = execContext.getBeanContext();
            BeanIdStore beanIdStore =  execContext.getContext().getBeanIdStore();


            BeanId requiredOrderNumId = beanIdStore.register("requiredOrderNum");


            beanContext.addBean(requiredOrderNumId, 9999, null);
            try {
                smooks.filterSource(execContext, new StringSource("<doc/>"), null);
                fail("Expected DataSelectionException");
            } catch(SmooksException e) {
                assertEquals("Order with ORDERNUMBER=9999 not found in Database", e.getCause().getMessage());

View Full Code Here


        try {
            if(!statementExec.isJoin()) {
                if(statementExec.getStatementType() == StatementType.QUERY) {
                    if(resultSetScope == ResultSetScope.EXECUTION) {
                        beanContext.addBean(resultSetBeanId, statementExec.executeUnjoinedQuery(connection), source);
                    } else {
                        List<Map<String, Object>> resultMap;
                        // Cached in the application context...
                        ApplicationContext appContext = executionContext.getContext();
                        ResultSetContextObject rsContextObj = ResultSetContextObject.getInstance(rsAppContextKey, appContext);

View Full Code Here

                                    rsContextObj.expiresAt = System.currentTimeMillis() + resultSetTTL;
                                }
                            }
                        }
                        resultMap = rsContextObj.resultSet;
                        beanContext.addBean(resultSetBeanId, resultMap, source);
                    }
                } else {
                    statementExec.executeUnjoinedUpdate(connection);
                }
            } else {

View Full Code Here

                }
            } else {
                if(statementExec.getStatementType() == StatementType.QUERY) {
                    List<Map<String, Object>> resultMap = new ArrayList<Map<String, Object>>();
                    statementExec.executeJoinedQuery(connection, beanMap, resultMap);
                    beanContext.addBean(resultSetBeanId, resultMap, source);
                } else {
                    if(resultSetBeanId == null) {
                        statementExec.executeJoinedUpdate(connection, beanMap);
                    } else {
                        Object resultSetObj = beanContext.getBean(resultSetBeanId);

View Full Code Here

      BeanContext beanContext = executionContext.getBeanContext();


      if(result == null) {
        beanContext.removeBean(beanId, source);
      } else {
        beanContext.addBean(beanId, result, source);
      }
    } finally {
      if(dao != null) {
        emr.returnDao(dao);
      }

View Full Code Here


                  beanMapClone.put("row", row);


                    if(whereEvaluator.eval(beanMapClone)) {
                      selectedRow = row;
                      beanRepository.addBean(beanIdObj, selectedRow, source);
                    }
                }


                if(selectedRow == null && failedSelectError != null) {
                    throw new DataSelectionException(failedSelectError.apply(beanRepository.getBeanMap()));

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.