Spring Integration Outbound File Adapter -


i'm kind of having issues on implementing functionality , i'm noticing inconsistencies when drop files.

1) when drop multiple files, not files transferred correct directory.

2) service activator hits before file transfer happens outbound adapter.

3) stalls .moving.

a) looking @ code below, correctly setup?

b) how can make sure source files deleted before service activator hits.

c) transactional code necessary? 

<!-- adapter reading files in incoming directory --> <int-file:inbound-channel-adapter id="incomingfileadapter"                                   channel="fileinputchannel"                                   prevent-duplicates="false"                                   scanner="recursivedirectoryscanner"                                   filename-regex="^.*\.(?i)(avi|divx|xvid|flv|f4v|mkv|m1v|m2v|m4v|mpeg|mpg|mp4|mov|vob|wmv|asf|ts|mxf)$"                                   directory="${file.listener.path.incoming}">     <int:poller id="filepoller" default="true" max-messages-per-poll="5" fixed-rate="5000">         <int:transactional transaction-manager="pseudotransactionmanager" />     </int:poller> </int-file:inbound-channel-adapter>  <!-- adapter writing files processed directory --> <int-file:outbound-channel-adapter id="processedfileadapter"                                    mode="replace"                                    channel="fileinputchannel"                                    delete-source-files="true"                                    auto-create-directory="true"                                    order="1"                                    directory-expression="@dynamicdirectorygenerator.generatedirectory(payload)" />  <int:service-activator         input-channel="fileinputchannel"         output-channel="nullchannel"         order="2"         ref="fileinputactivator"         method="processmessage"/>  <bean id="fileinputactivator" class="com.nfl.dm.shield.ingestion.file.activator.fileinputactivator" /> <bean id="recursivedirectoryscanner" class="org.springframework.integration.file.recursiveleafonlydirectoryscanner" /> <bean id="dynamicdirectorygenerator" class="com.nfl.dm.shield.ingestion.file.dynamic.dynamicdirectorygenerator" /> <bean id="pseudotransactionmanager" class="org.springframework.integration.transaction.pseudotransactionmanager" />

a) since don't have declaration fileinputchannel, it's directchanel means messages alternately go outbound adapter , service activator.

declare <publish-subscribe-channel/> , each file go both subscribers (based on order).

b) it's not clear mean since want send file service, why want deleted before gets there? if mean can add <request-handler-advice-chain/> file adapter expressionevaluatingrequesthandleradvice. see retry-and-more sample example of how use advice.

c) no, pseudo transaction not necessary since not taking action on success or failure.


Comments

Post a Comment

Popular posts from this blog

toolbar - How to add link to user registration inside toobar in admin joomla 3 custom component -

im trying write component admin side , need add user creation. dont want duplicate existing codes add link. know how add task not simple link toolbar. thx help. if wanting button opens new user screen can try in component: $bar = jtoolbar::getinstance('toolbar'); $bar->appendbutton('link', 'users', 'new user','index.php?option=com_users&task=user.add'); you need add view.html.php file wherever you're creating toolbar. is need?
Read more

linux - disk space limitation when creating war file -

i have 1 gb disk space limitation hosting app , have used 700mb of it. however want create war file directory big (around 600mb) using command : jar -cvf root.war folderpath that's why encounter quota limitation , can't following. i'm looking way delete folder content when it's applying archive conserve disk space take note can't install zip tool in ssh shell ~ the code works on test directories, test first anyway, deletes files. it's not efficient. assumptions: 300mb free space, in destructively compress 600mb folderpath directory. none of files big -- if file in folderpath 300mb or larger, fail. notes: if ' $out ' file exists, nothing. first find pipes file list while , if ' $out ' doesn't exist in loop, create it, don't update -- if does exist, update it. each pass adds 1 more file, deletes unless file directory. after loop finishes delete empty directories too. unset u ; in=folderpath ; out=roo...
Read more