java - Spring - Rerun batch job after final step complete -

-

i've written batch job processing on message pulls queue. reads in message, processes, removes queue. want job go first step (seeing if message exists) after removes previous message queue. if message exists, go through of steps again. if no message exists, job complete.

i'm trying implement job decider this.

right xml configuration is:

    <j:decision decider="jobstarter" id="startjob">         <j:next on="start_step" to="producecloseoutmessage" />         <j:end on="completed" />         <j:fail on="failed" />     </j:decision>

but i'm not sure how implement decider itself. have queue reader class i've implemented actual check of queue see if message exists or not. should calling method in decider?

i know current implementation of decider wrong i've included below anyway: 

protected static final flowexecutionstatus start_step = new flowexecutionstatus("start_step"); protected static final flowexecutionstatus end_job = flowexecutionstatus.completed; protected static final flowexecutionstatus failed = flowexecutionstatus.failed;  private queuereader queuereader;  public jobdecider(queuereader queuereader){     this.queuereader = queuereader; }  @override public flowexecutionstatus decide(jobexecution jobexecution,         stepexecution stepexecution) {      flowexecutionstatus flowexecutionstatus;     flowexecutionstatus = jobdecider.start_step;      try {         if(!queuereader.receivemessage().isempty()){             flowexecutionstatus = wmflgintjobdecider.start_step;         } else{             flowexecutionstatus = wmflgintjobdecider.end_job;         }      } catch (jmsexception e) {         flowexecutionstatus = wmflgintjobdecider.failed;         e.printstacktrace();     }     return flowexecutionstatus; }

edit: think might have solution. i've updated code above in decider.


Comments

Post a Comment

Popular posts from this blog

javascript - React Maximum Callstack when adding component -

-
i have list component getting information local json file if following works expected. import react 'react'; import casestudies './case-studies.json'; import casestudyitem './case-study-list'; const casestudylist = () => { const casestudyitems = casestudies.map( casestudy => { console.log(casestudy); return ( <div key={casestudy.name}>{casestudy.name}</div> ); }); return ( <ul> {casestudyitems} </ul> ); } export default casestudylist; the expected number of case studies printed out no problem. if replace div inside of casestudies.map statement following <casestudyitem key={casestudy.id} casestudy={casestudy} /> i "maximum callstack size exceed error" if add log statement in there shows spitting out hundred , hundreds of items. cause this? in case needed here casestudyitem component, blank testing purposes. import
Read more

javascript - Uncaught FirebaseError: Messaging: This method is available in a Window context -

-
i'm using firebase service worker web push notification. currently, facing error: uncaught firebaseerror: messaging: method available in window context. (messaging/only-available-in-window). i using website on desktop register sw. how resolve issue? error stack i'm getting in console. browsererrormessage: "failed register serviceworker: serviceworker script evaluation failed" code :"messaging/failed-serviceworker-registration" message :"messaging: unable register default service worker. failed register serviceworker: serviceworker script evaluation failed (messaging/failed-serviceworker-registration)." stack: "firebaseerror: messaging: unable register default service worker. failed register serviceworker: serviceworker script evaluation failed (messaging/failed-serviceworker-registration).↵ @ https://www.gstatic.com/firebasejs/3.7.0/firebase.js:555:225" __proto__: error thank you this method should there in main
Read more

correlation - Autocorrelation in Matlab WITHOUT xcorr -

-
so i'm expected make autocorrelation of multiple signals (in order see difference of power spectrum it's irrelevant) note: don't want other way resolve exercise explanation problem :) the signals periodic , data length multiple of period. the problem don't same answer xcorr function of matlab. i'm using classic (i think) r_x(lag) = sum(k=-inf +inf) of x(k)*x(k-lag). when searching answer found other method 1 used using basically: ifft(fft().*conj(fft())) if understood correctly taking inverse fourier transform of periodigram equivalent power spectrum, fourier transform of autocorrelation. don't know why "classic" way doesn't work.. can please explain why/if code wrong? if don't want run code can go directly % ! autocorrelation! code: % making prbs y, of period 2^size(a,1) -1 , span [-lambda,lambda] = [ 1 0 0 0 0 1;... 1 0 0 0 0 0;... 0 1 0 0 0 0;... 0 0 1 0 0 0;... 0 0 0 1 0 0;... 0 0 0 0 1 0]; c = [
Read more