(Spring batch) Pollable channel with replies contains ChunkResponses even if JOB is succefully completed -

-

i have following chunk writer configuration getting replies spring batch remote chunking:

    <bean id="chunkwriter" class="org.springframework.batch.integration.chunk.chunkmessagechannelitemwriter" scope="step">     <property name="messagingoperations" ref="messaginggateway" />     <property name="replychannel" ref="masterchunkreplies" />     <property name="throttlelimit" value="5" />     <property name="maxwaittimeouts" value="30000" /> </bean>   <bean id="messaginggateway" class="org.springframework.integration.core.messagingtemplate">     <property name="defaultchannel" ref="masterchunkrequests" />     <property name="receivetimeout" value="2000" /> </bean>  <!-- remote chunking replies slave --> <jms:inbound-channel-adapter id="masterjmsreplies"                              destination="remotechunkingrepliesqueue"                              connection-factory="remotechunkingconnectionfactory"                              channel="masterchunkreplies">     <int:poller fixed-delay="10" /> </jms:inbound-channel-adapter>  <int:channel id="masterchunkreplies">     <int:queue />     <int:interceptors>         <int:wire-tap channel="loggingchannel"/>     </int:interceptors> </int:channel>

my remotely chunked step running perfectly, data processed performance, steps ends in completed state. problem masterchunkreplies queue channel contains chunkresponses after end of job. documentation doesn't it, normal state?

problem can't run new job then, because crashes at:

message contained wrong job instance id ["                 + jobinstanceid + "] should have been [" + localstate.getjobid() + "]."

there simple workaround, cleaning masterchunkreplies queue channel @ start of job, i'm not sure if correct...

can please clarify this?

gary, found root cause.

at slaves, if change following chunk consumer jms adapter:

<jms:message-driven-channel-adapter id="slaverequests"                                     connection-factory="remotechunkingconnectionfactory"                                     destination="remotechunkingrequestsqueue"                                     channel="chunkrequests"                                     concurrent-consumers="10"                                     max-concurrent-consumers="50"                                     acknowledge="transacted"                                     receive-timeout="5000"                                     idle-task-execution-limit="10"                                     idle-consumer-limit="5"          />

for 

<jms:inbound-channel-adapter id="jmsrequests" connection-factory="remotechunkingconnectionfactory"                              destination="remotechunkingrequestsqueue"                              channel="chunkrequests"                              acknowledge="transacted"                              receive-timeout="5000"         >     <int:poller fixed-delay="100"/> </jms:inbound-channel-adapter>

then works, masterchunkreplies queue consumed @ end of job. anyway, attempts of consuming chunkrequests @ slaves in parallalel doesn't work. masterchunkreplies queue contains not consumed chunkresponses. starting new jobs ends in 

message contained wrong job instance id ["             + jobinstanceid + "] should have been [" + localstate.getjobid() + "]."

gary, mean slaves cannot consume chunkrequests in parallel?


Comments

Post a Comment

Popular posts from this blog

how to insert data php javascript mysql with multiple array session 2 -

-
i have method method discussed , successful data entered 1 when more 1 can not database this programs my php form : <form class="form-horizontal" id="form-produk"> <div class="control-group" > <label class="control-label" for="kelas">kategori</label> <div class="controls"> <select class='form-control' name='id_kategori'> <?php $tampil=mysql_query("select * kategori order nama_kategori"); if ($id_kat==0){ echo "<option value=0 selected>- pilih kategori -</option>"; } while($w=mysql_fetch_array($tampil)){ if ($id_kat==$w[id_kategori]){ echo "<option value=$w[id_kategori] selected>$w[nama_kategori]</option>"; } else{ echo "<option value=$w[id_kategori]>$...
Read more

multithreading - Exception in Application constructor -

-
i wanna write snake game javafx , there exception don't know , want know how fix it. ( know it's not complete yet ) and want know , class extends application ( start override ) main in other programs? see , here not static void main bc didn't need, if want add main shoud do? it's exeption... exception in application constructor exception in thread "main" java.lang.nosuchmethodexception: main_snake.main([ljava.lang.string;) @ java.lang.class.getmethod(class.java:1819) @ com.intellij.rt.execution.application.appmain.main(appmain.java:125) and code : import javafx.animation.animationtimer; import javafx.application.application; import javafx.event.eventhandler; import javafx.scene.scene; import javafx.scene.canvas.canvas; import javafx.scene.canvas.graphicscontext; import javafx.scene.input.keyevent; import javafx.scene.layout.borderpane; import javafx.scene.paint.color; import javafx.stage.stage; import java.util.arraylist; /** * creat...
Read more

windows - CertCreateCertificateContext returns CRYPT_E_ASN1_BADTAG / 8009310b -

-
i realize similar post others (e.g. this one ), there details missing posts might significant case. to start with, here's simplified program: #include "stdafx.h" #include <windows.h> #include <wincrypt.h> int _tmain(int argc, _tchar* argv[]) { // usage: certextract certpath char keyfile[] = "c:\\certificates\\public.crt"; byte lp[65536]; security_attributes sa; handle hkeyfile; dword bytes; pccert_context certcontext; sa.nlength = sizeof(sa); sa.lpsecuritydescriptor = null; sa.binherithandle = false; hkeyfile = createfile(keyfile, generic_read, file_share_read, &sa, open_existing, file_attribute_normal, null); if (hkeyfile) { if (readfile(hkeyfile, lp, getfilesize(hkeyfile, null), &bytes, null) && bytes > 0) { certcontext = certcreatecertificatecontext(x509_asn_encoding, lp, bytes); if (certcontext) { printf("yay...
Read more