I am getting error as Stream Closed, Here is the Details

, ,
1

I am getting error as Stream Closed, Here is the Details
I am using Filepolling port, and i have input ffdata(object) of the flowservice then i am trying to converting it into values using ConverToValues service, here i am getting error as Stream Closed.

com.wm.app.b2b.server.ServiceException: java.io.IOException: Stream closed
at pub.flatFileImpl.convertToValues(flatFileImpl.java:460)
at sun.reflect.GeneratedMethodAccessor112.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at com.wm.app.b2b.server.JavaService.baseInvoke(JavaService.java:322)
at com.wm.app.b2b.server.invoke.InvokeManager.process(InvokeManager.java:612)
at com.wm.app.b2b.server.invoke.StatisticsProcessor.process(StatisticsProcessor.java:44)
at com.wm.app.b2b.server.invoke.ServiceCompletionImpl.process(ServiceCompletionImpl.java:226)
at com.wm.app.b2b.server.invoke.ValidateProcessor.process(ValidateProcessor.java:49)
at com.wm.app.b2b.server.ACLManager.process(ACLManager.java:198)
at com.wm.app.b2b.server.invoke.DispatchProcessor.process(DispatchProcessor.java:39)
at com.wm.app.b2b.server.AuditLogManager.process(AuditLogManager.java:411)
at com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:521)
at com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:369)
at com.wm.app.b2b.server.ServiceManager.invoke(ServiceManager.java:246)
at com.wm.app.b2b.server.BaseService.invoke(BaseService.java:168)
at com.wm.lang.flow.FlowInvoke.invoke(FlowInvoke.java:324)
at com.wm.lang.flow.FlowState.invokeNode(FlowState.java:581)
at com.wm.lang.flow.FlowState.step(FlowState.java:438)
at com.wm.lang.flow.FlowState.invoke(FlowState.java:403)
at com.wm.app.b2b.server.FlowSvcImpl.baseInvoke(FlowSvcImpl.java:982)
at com.wm.app.b2b.server.invoke.InvokeManager.process(InvokeManager.java:612)
at com.wm.app.b2b.server.invoke.StatisticsProcessor.process(StatisticsProcessor.java:44)
at com.wm.app.b2b.server.invoke.ServiceCompletionImpl.process(ServiceCompletionImpl.java:226)
at com.wm.app.b2b.server.invoke.ValidateProcessor.process(ValidateProcessor.java:49)
at com.wm.app.b2b.server.ACLManager.process(ACLManager.java:198)
at com.wm.app.b2b.server.invoke.DispatchProcessor.process(DispatchProcessor.java:39)
at com.wm.app.b2b.server.AuditLogManager.process(AuditLogManager.java:411)
at com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:521)
at com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:369)
at com.wm.app.b2b.server.ServiceManager.invoke(ServiceManager.java:246)
at com.wm.app.b2b.server.ServiceManager.invoke(ServiceManager.java:128)
at com.wm.ff.net.FilePollingTransaction$RunService.write(FilePollingTransaction.java:433)
at com.wm.ff.net.FilePollingTransaction$RunService.run(FilePollingTransaction.java:284)
at com.wm.util.pool.PooledThread.run(PooledThread.java:105)
at java.lang.Thread.run(Thread.java:534)

I followed another way like
taking ffdata then used StreamToBytes,BytesToString when i looked at the string it is inserting new line between each record.

Can anybody throw some ideas.

Thanks
Ram

2

Can you list out the steps you have in your service, in the way you want them to be working (e.g. without debugging steps or workarounds)?

3
  1. File Polling Port is configured like this.

Package Name TestPack1

Polling Information

Monitoring Directory \Test\Filelist
Working Directory (optional) unspecified
Completion Directory \Test\completionDir
Error Directory (optional)\Test\Err
File Name Filter (optional) *.TXT
File Age (optional) (seconds) unspecified
Content Type (optional) application/x-wmflatfile
Allow Recursive Polling No

Security

Run services as user Administrator
Message ProcessingProcessing TestPack1:FilePolingTestFlow
File Polling Interval 5
Log only when directory availability changes No
Directories are NFS mounted file system No
Cleanup Service (optional) unspecified
Cleanup At Startup Yes
Cleanup File Age (optional) (days) 7
Cleanup Interval (optional) (hours)24
Maximum number of Invocation Threads 1

2)input of the Flowservice declared as ffdata(i.e Object datatype)

3)Now I have SEQUENCE steps(For Try/Catch)
4)I have MAP step for App Info
5)Now I have ConvertToValues step , here i am mapping ffdata to ffData
…
…
in the convertToValues step it fails with message StreamClosed.

Actually i even tried Using the steps StreamToByes, BytesToString steps
Before CovertingToValues , here Whatever the String i get from BytesToString is having Extra newline between each record, if i map this String to ConvertToValues step It fails because of Record structure is not compliance with the schema.

Note:If I debug the flow by passing string as input istead of ffdata Object, ConvertToValues works fine without any errors.

I hope this gives you Clear Picture.

Thanks
Ram

4

Can anybody throw some ideas on this.

Thanks
Ram