private void getAvailableChanges ( final Map < String , String > changes ) { WorkflowSystem . OperationCompleted < DAT > task = stateChangeQueue . poll ( ) ; while ( task != null && task . getNewState ( ) != null ) { changes . putAll ( task . getNewState ( ) . getState ( ) ) ; DAT result = task . getResult ( ) ; if ( null != sharedData && null != result ) { sharedData . addData ( result ) ; } task = stateChangeQueue . poll ( ) ; } }
Poll for changes from the queue and process all changes that are immediately available without waiting