SimpleExecutionRunnable implements Runnable { public ExecutionMessage getExecutionMessage() { return executionMessage; } SimpleExecutionRunnable(ExecutionService executionService,
                                   OutboundBuffer outBuffer,
                                   InBuffer inBuffer,
                                   ExecutionMessageConverter converter,
                                   EndExecutionCallback endExecutionCallback,
                                   QueueStateIdGeneratorService queueStateIdGeneratorService,
                                   String workerUUID,
                                   WorkerConfigurationService workerConfigurationService,
                                   WorkerManager workerManager); ExecutionMessage getExecutionMessage(); void setExecutionMessage(ExecutionMessage executionMessage); @Override void run();  }
@Test public void testGetExecutionMessage() throws Exception { SimpleExecutionRunnable simpleExecutionRunnable = new SimpleExecutionRunnable(executionService, outBuffer, inBuffer, converter, endExecutionCallback, queueStateIdGenerator, "stam", workerConfigurationService, workerManager); ExecutionMessage executionMessage = simpleExecutionRunnable.getExecutionMessage(); Assert.assertNull(executionMessage); simpleExecutionRunnable.setExecutionMessage(new ExecutionMessage()); executionMessage = simpleExecutionRunnable.getExecutionMessage(); Assert.assertNotNull(executionMessage); }