2 Replies Latest reply: Jan 4, 2012 1:15 AM by 908647 RSS

    File Tranfer Issue Using JMS

    908647
      Hello everybody,

      I am new to JMS and trying to develop a chat application using Swing and JMS. TextMessaging is working fine but i am unable to configure FileTranfer.

      Configurations are stated below:
      Apache Geronimo 2.2 (as JMS provider server).
      ActiveMQ (for connecting to JMS server).
      Java Swing.

      Establishing Connection:

      Properties env = new Properties();
                env.put(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
                env.put(Context.PROVIDER_URL, "tcp://localhost:61616?jms.prefetchPolicy.all=100&jms.redeliveryPolicy.maximumRedeliveries=5");
                env.put(Context.SECURITY_PRINCIPAL, "system");
                env.put(Context.SECURITY_CREDENTIALS, "manager");
                env.put("topic.myTopic","org.apache.geronimo.configs/activemq-ra/JCAAdminObject/myTopic");
                // create publisher and subscriber
                InitialContext ctx = new InitialContext(env);
                ActiveMQConnectionFactory factory = (ActiveMQConnectionFactory) ctx.lookup("TopicConnectionFactory");
                final Topic topic = (Topic) ctx.lookup("myTopic");
                ActiveMQConnection conn = (ActiveMQConnection)factory.createTopicConnection();
                
      // Downloaded Apache FtpServer1.0.6 and started the server from bin folder ftpd.bat.
                conn.getBlobTransferPolicy().setUploadUrl("http://localhost:2121/fileserver/");

                final ActiveMQSession session = (ActiveMQSession)conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
                final TopicPublisher publisher = session.createPublisher(topic);
                subscriber = session.createSubscriber(topic);


      Sending BlobMessage

      String filePath = fileChooser.getSelectedFile().getAbsolutePath();
      File file = new File(filePath);
      BlobMessage msg = session.createBlobMessage(file);
      String sender = System.getProperty("user.name");
      msg.setStringProperty("sender", sender);
      msg.setStringProperty("filename", file.getName());
      publisher.publish(msg);


      Receiving BlobMessage

      public void onMessage(Message m) {
           try {
                String sender = m.getStringProperty("sender");
                if(m instanceof TextMessage){
                     TextMessage msg = (TextMessage) m;                              
                     incoming.append(sender + "> " + msg.getText() + "\n");
                } else if (m instanceof BlobMessage) {
                     String filename = m.getStringProperty("filename");
                     JOptionPane.showMessageDialog(null, "You have recieved a file "+filename+" from "+sender+" !!!");
                     BlobMessage blobMessage = (BlobMessage) m;
                     InputStream inputStream = blobMessage.getInputStream();
                     if (inputStream != null) {
                          try { 
                                    OutputStream os = new FileOutputStream(new File("C://"+filename));
                                    try { 
                                    byte[] buffer = new byte[4096];
                                    for (int n; (n = inputStream.read(buffer)) != -1; )
                                    os.write(buffer, 0, n);
                                    }catch(Exception e){
                                    e.printStackTrace();
                                    }
                                    finally { os.close(); }
                               }catch(Exception e){
                               e.printStackTrace();
                               }
                               finally { inputStream.close(); }

                     }
                }
           } catch (Exception ex) {
                ex.printStackTrace();
           }
      }


      I downloaded Apache FtpServer1.0.6 and started the server from bin folder ftpd.bat as I found this step after googling for sometime.
      I am getting the Recieved File alert in OnMessage method but the inputstream is null. No data is coming to the reciever. I am unable to figure out the actual issue.

      Please help me out.

      Many Thanks
      Rupal Chatterjee
        • 1. Re: File Tranfer Issue Using JMS
          jtahlborn
          i doubt your ftp server is going to service http requests, e.g.: "http://localhost:2121/fileserver/"
          • 2. Re: File Tranfer Issue Using JMS
            908647
            Hi jtahlborn,

            Thanks for ur time.

            I changed it to "conn.getBlobTransferPolicy().setUploadUrl("*ftp://localhost:2121/fileserver/*");" but still it is not working.

            InputStream at the reciever's end is null.

            I noticed one thing, when i comment out the entire above setUploadUrl statement ie "//conn.getBlobTransferPolicy().setUploadUrl("*ftp://localhost:2121/fileserver/*");", still there is no effect on the result. Means I am not getting any errors if i remove this statement. I am not sure whether this working.

            Please help.

            Thanks
            Rupal Chatterjee

            Edited by: Rupal on 03-Jan-2012 23:15