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

How to provide Authorization & Authentication using Asp.net, C#? -

Image
i have asp.net application in c#. i have provide page authorization specific user/usergroup. i have created 2 tables in database: 1) pagename 2)permissions[insert, update, view, delete] but i'm unable match tables , permissions assigning... can 1 please me, how created tables in database , how coding. please me. you can below explanation. configure access specific file , folder, set forms-based authentication. request page in application redirected logon.aspx automatically. in web.config file, type or paste following code. this code grants users access default1.aspx page , subdir1 folder . <configuration> <system.web> <authentication mode="forms" > <forms loginurl="login.aspx" name=".aspnetauth" protection="none" path="/" timeout="20" > </forms> </authentication> <!-- section denies access files in...
Read more

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

android - Pass an Serializable object in AIDL -

i have defined aidl file interface imyfeature { void dotask(class clazz); } but need pass class object process. possible in android? if so, how? i tried: interface imyfeature { serializable class; void dotask(class clazz); } but doesn’t work. aidl in android supports custom class implement parcelable interface. in case want send class object not possible. can send class canonical name , retrieve in service. for example have aidl file interface imyfeature { void dotask(string classname); } then call : binder.dotask(myclass.class.getcanonicalname()); and in service binder stub implementation : private final imyfeature mbinder = new imyfeature.stub() { public void dotask(string classname) { try { class<?> clazz = class.forname(classname); constructor<?> ctor = clazz.getconstructor((class[]) null); object object = ctor.newinstance(); ...
Read more