Hi Together, First of all I was not sure where to put this ? in the beginners section (cause I am using Jboss since 2,5 months), or in the ejb3 section according to the error message. So hopefully I am right here. What I want to do: I want to upload a file from a java client to JBoss: I read in several forums that ejb actually does not support file upload (apart from uploading files via servlets, jsf and HTTP, etc.). Later I found a workaround (putting my files as portions of bytes to server). So I programmed the class (client) and a session bean below and everything works fine, except: When I declare the session bean as @Stateful I get for every time the write()-method is called the message: DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor My file is 252kb and I get the message 252 times in my server log plus one time when I call open() and one time when calling close(): | 2006-11-09 17:03:22,249 DEBUG [org.jboss.remoting.transport.socket.ServerThread] WAKEUP in SERVER THREAD | 2006-11-09 17:03:22,249 DEBUG [org.jboss.remoting.transport.socket.ServerThread] beginning dorun | 2006-11-09 17:03:22,327 DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor | 2006-11-09 17:03:22,327 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] Open remote stream: successful. | 2006-11-09 17:03:22,343 DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor | 2006-11-09 17:03:22,343 DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor | ...... | .... | .. | total 252 | .. | .... | ...... | 2006-11-09 17:03:22,905 DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor | 2006-11-09 17:03:22,905 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] Closing remote stream: successful | 2006-11-09 17:03:22,921 DEBUG [org.jboss.ejb3.entity.ExtendedPersistenceContextPropagationInterceptor] ++++ LongLivedSessionPropagationInterceptor | 2006-11-09 17:03:22,921 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] SourceFileChecksum vs. RemoteFileChecksum: 748869239 / 748869239 | 2006-11-09 17:03:22,921 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] File is OK | 2006-11-09 17:03:22,952 DEBUG [org.jboss.remoting.transport.socket.ServerThread] begin thread wait | What I am doing wrong rather what do I have to do to do it right? When declaring the session bean as @Stateless everything is fine: | 2006-11-09 17:01:01,499 DEBUG [org.jboss.remoting.transport.socket.ServerThread] WAKEUP in SERVER THREAD | 2006-11-09 17:01:01,499 DEBUG [org.jboss.remoting.transport.socket.ServerThread] beginning dorun | 2006-11-09 17:01:01,515 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] Open remote stream: successful. | 2006-11-09 17:01:02,062 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] Closing remote stream: successful | 2006-11-09 17:01:02,062 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] SourceFileChecksum vs. RemoteFileChecksum: 748869239 / 748869239 | 2006-11-09 17:01:02,062 INFO [test.ejb.appclientsync.sessionbeans.RemoteStreamBean] File is OK | 2006-11-09 17:01:02,109 DEBUG [org.jboss.remoting.transport.socket.ServerThread] begin thread wait | This is my session bean: | package test.ejb.appclientsync.sessionbeans; | | import java.io.FileOutputStream; | import java.io.IOException; | import java.util.zip.Adler32; | import java.util.zip.CheckedOutputStream; | | import javax.ejb.Stateful; | | import org.apache.log4j.Logger; | | @Stateful | public class RemoteStreamBean implements RemoteStreamBeanRemote { | | public static Logger logger = Logger.getLogger(RemoteStreamBean.class); | | public static final String RemoteJNDIName = | RemoteStreamBean.class.getSimpleName() + "/remote"; | public static final String LocalJNDIName = | RemoteStreamBean.class.getSimpleName() + "/local"; | | private static CheckedOutputStream cos; | private static FileOutputStream fos; | | private static long checksum; | | public RemoteStreamBean() { | super(); | } | | public void open() { | try { | fos = new FileOutputStream("C:/test/remote/testfile.txt"); | cos = new CheckedOutputStream(fos, new Adler32()); | logger.info("Open remote stream: successful."); | } catch (IOException ioe) { | logger.info("Failure during open()"); | } | | } | | public boolean write(byte[] data, int off, int len) { | try { | cos.write(data, off, len); | cos.flush(); | return true; | } catch (Exception IOException) { | logger.info("Failure during write()..."); | //cleanReset(true); | return false; | } | } | | public boolean close() { | try { | checksum = cos.getChecksum().getValue(); | cos.close(); | logger.info("Closing remote stream: successful"); | return true; | } catch (IOException ioe) { | logger.info("Failure during close()"); | return false; | } | } | | public boolean success(long sourceFileChecksum) { | | logger.info("SourceFileChecksum vs. RemoteFileChecksum: " + | sourceFileChecksum + " / " + checksum); | | if(sourceFileChecksum != checksum) { | logger.info("Transmitted file is courrupt"); | return false; | } else { | logger.info("File is OK"); | return true; | | } | } | | }//end class | My Interface: | package test.ejb.appclientsync.sessionbeans; | | import javax.ejb.Remote; | | @Remote | public interface RemoteStreamBeanRemote { | | public void open(); | | public boolean write(byte[] data, int off, int len); | | public boolean close(); | | public boolean success(long sourceFileChecksum); | | } Client (started via a simple class containing main()-method only): | package test.syncbaker.appclient.syncmode; | | import java.io.FileInputStream; | import java.io.FileNotFoundException; | import java.io.IOException; | import java.util.zip.Adler32; | import java.util.zip.CheckedInputStream; | | import javax.naming.Context; | import javax.naming.InitialContext; | import javax.naming.NamingException; | | import org.apache.log4j.Logger; | | import test.ejb.appclientsync.sessionbeans.RemoteStreamBean; | import test.appclientsync.sessionbeans.RemoteStreamBeanRemote; | | public class FileUpload { | | public Logger logger = Logger.getLogger(FileUpload.class); | | private Context context; | private static RemoteStreamBeanRemote rfos; | | private FileInputStream fis; | private CheckedInputStream cis; | | public FileUpload() { | super(); | loadRemoteFileOutputStream(); | } | | private void loadRemoteFileOutputStream() { | try { | context = new InitialContext(); | rfos = (RemoteStreamBeanRemote) | context.lookup(RemoteStreamBean.RemoteJNDIName); | } | catch (NamingException ne) { | logger.error("Unable to load (connect) remote service."); | logger.error(ne); | System.exit(-1); | } | } | | public void uploadFile() { | | /* | * Checksum | */ | long checksum = 0; | | /* | * Open RemoteFileOutputStream | */ | rfos.open(); | | try { | | /* | * Open local InputStreams | */ | fis = new FileInputStream("c:/test/source/testfile.txt"); | cis = new CheckedInputStream(fis, new Adler32()); | | /* | * Transfer file | */ | byte[] buf = new byte[1024]; | int len; | while ((len = cis.read(buf)) > 0) { | | /* | * Transmit file | */ | boolean transmitState = rfos.write(buf, 0, len); | | /* | * success? | */ | if(!transmitState) { | logger.warn("Warning: Failure during uploading"); | | throw new IOException(); | | } | | }// end while transmit | | /* | * Get checksum of stream | */ | checksum = cis.getChecksum().getValue(); | | /* | * Close InputStream | */ | cis.close(); | | /* | * Close RemoteFileOutputStream. | */ | boolean closingState = rfos.close(); | if(!closingState) { | logger.warn("Failure during closing remote stream."); | throw new IOException(); | } | logger.info("Closing remote stream: successful"); | | /* | * Finally check success of transmission. | */ | boolean success = rfos.success(checksum); | if(!success) { | logger.warn("File uploaded is corrupt"); | throw new IOException(); | } else { | logger.debug("File upload complete."); | } | | /* | * Handel Exceptions | */ | } catch (FileNotFoundException fnfe) { | fnfe.printStackTrace(); | } catch (IOException ioe) { | ioe.printStackTrace(); | } | | } | | } | Thanks in advance. Regards Rene View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3984597#... Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...