Package org.springframework.batch.item

Examples of org.springframework.batch.item.ExecutionContext

88
89
90
91
92
93
94
95
96
97
98
99
100
  private void start(String foo) {

    JobSynchronizationManager.close();
    jobExecution = new JobExecution(123L);

    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("foo", foo);
    executionContext.put("parent", bar);

    jobExecution.setExecutionContext(executionContext);
    JobSynchronizationManager.register(jobExecution);

    beanCount = beanFactory.getBeanDefinitionCount();
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
139
    assertEquals("bar-bar", compound.getName());

    JobSynchronizationManager.close();
    jobExecution = new JobExecution(123L);

    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("foo", "spam");

    jobExecution.setExecutionContext(executionContext);
    JobSynchronizationManager.register(jobExecution);

    assertEquals("spam-bar", compound.getName());
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
111
  }

  @Test
  public void testExecutionContext() throws Exception {
    StepExecution stepExecution = new StepExecution("foo", new JobExecution(11L), 1L);
    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("name", "spam");
    stepExecution.setExecutionContext(executionContext);
    proxied.execute(stepExecution);
    assertTrue(TestStep.getContext().attributeNames().length > 0);
    String collaborator = (String) TestStep.getContext().getAttribute("collaborator");
    assertNotNull(collaborator);
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
100
101
  private void start(String foo) {

    StepSynchronizationManager.close();
    stepExecution = new StepExecution("foo", new JobExecution(11L), 123L);

    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("foo", foo);
    executionContext.put("parent", bar);

    stepExecution.setExecutionContext(executionContext);
    StepSynchronizationManager.register(stepExecution);

    beanCount = beanFactory.getBeanDefinitionCount();
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
140
    assertEquals("bar-bar", compound.getName());

    StepSynchronizationManager.close();
    stepExecution = new StepExecution("foo", new JobExecution(11L), 123L);

    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("foo", "spam");

    stepExecution.setExecutionContext(executionContext);
    StepSynchronizationManager.register(stepExecution);

    assertEquals("spam-bar", compound.getName());
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
110
  }

  @Test
  public void testExecutionContext() throws Exception {
    JobExecution stepExecution = new JobExecution(11L);
    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("name", "spam");
    stepExecution.setExecutionContext(executionContext);
    proxied.execute(stepExecution);
    assertTrue(TestJob.getContext().attributeNames().length > 0);
    String collaborator = (String) TestJob.getContext().getAttribute("collaborator");
    assertNotNull(collaborator);
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
  @Override
  public void writeCredit(CustomerCredit customerCredit) throws Exception {

    if (!opened) {
      open(new ExecutionContext());
    }

    String line = "" + customerCredit.getName() + separator
        + customerCredit.getCredit();
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
97
    StepSynchronizationManager.close();
    TestStep.reset();
    stepExecution = new StepExecution("foo", new JobExecution(11L), 123L);

    ExecutionContext executionContext = new ExecutionContext();
    executionContext.put("foo", "bar");

    stepExecution.setExecutionContext(executionContext);
    StepSynchronizationManager.register(stepExecution);

    beanCount = beanFactory.getBeanDefinitionCount();
View Full Code Here
180
181
182
183
184
185
186
187
188
189
  }

  @Test
  public void testExecutionContext() throws Exception {
    assertNotNull(execution.getExecutionContext());
    ExecutionContext context = new ExecutionContext();
    context.putString("foo", "bar");
    execution.setExecutionContext(context);
    assertEquals("bar", execution.getExecutionContext().getString("foo"));
  }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
  }

  private int doTest(String name, String test) throws Exception {
    @SuppressWarnings("unchecked")
    ItemStreamReader<String> reader = (ItemStreamReader<String>) applicationContext.getBean(name);
    reader.open(new ExecutionContext());
    StopWatch stopWatch = new StopWatch(test);
    stopWatch.start();
    int count = 0;
    while (reader.read() != null) {
      // do nothing
View Full Code Here
TOP

Related Classes of org.springframework.batch.item.ExecutionContext

  • com.vmware.bdd.service.job.SimpleStepExecutionListener
  • com.vmware.bdd.service.job.SubJobStep
  • org.springframework.batch.admin.sample.LeadRandomizer
  • org.springframework.batch.admin.service.SimpleJobServiceTests
  • org.springframework.batch.core.job.SimpleStepHandler
  • org.springframework.batch.core.partition.ExampleItemReaderTests
  • org.springframework.batch.core.partition.support.SimpleStepExecutionSplitterTests
  • org.springframework.batch.core.repository.dao.AbstractExecutionContextDaoTests
  • org.springframework.batch.core.repository.dao.JdbcExecutionContextDao
  • org.springframework.batch.core.repository.dao.MapExecutionContextDao
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.