KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > scalagent > joram > mom > dest > ftp > TransferImplRef


1 /*
2  * JORAM: Java(TM) Open Reliable Asynchronous Messaging
3  * Copyright (C) 2001 - 2007 ScalAgent Distributed Technologies
4  *
5  * This library is free software; you can redistribute it and/or
6  * modify it under the terms of the GNU Lesser General Public
7  * License as published by the Free Software Foundation; either
8  * version 2.1 of the License, or any later version.
9  *
10  * This library is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13  * Lesser General Public License for more details.
14  *
15  * You should have received a copy of the GNU Lesser General Public
16  * License along with this library; if not, write to the Free Software
17  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
18  * USA.
19  *
20  * Initial developer(s): Nicolas Tachker (ScalAgent)
21  * Contributor(s):
22  */
23 package com.scalagent.joram.mom.dest.ftp;
24
25 import java.io.*;
26 import java.net.*;
27
28 public class TransferImplRef
29   implements TransferItf {
30
31   public String JavaDoc getFile(String JavaDoc protocol,
32                         String JavaDoc host,
33                         int port,
34                         String JavaDoc user,
35                         String JavaDoc pass,
36                         String JavaDoc remotePath,
37                         String JavaDoc localPath,
38                         String JavaDoc remoteFileName,
39                         String JavaDoc localFileName,
40                         String JavaDoc type,
41                         long crc) throws Exception JavaDoc {
42     
43     StringBuffer JavaDoc sb = new StringBuffer JavaDoc();
44     
45     sb.append("ftp://");
46     sb.append(user);
47     sb.append(":");
48     sb.append(pass);
49     sb.append("@");
50     sb.append(host);
51     if (port > -1) {
52       sb.append(":");
53       sb.append(port);
54     }
55     sb.append("/");
56     if (remotePath != null)
57       sb.append(remotePath + "/");
58     sb.append(remoteFileName);
59     sb.append(";type=");
60     sb.append(type);
61
62     URL url = new URL(sb.toString());
63
64     URLConnection urlc = url.openConnection();
65     InputStream is = urlc.getInputStream();
66     
67     File file = new File(localPath,localFileName);
68     
69     BufferedOutputStream bos = new BufferedOutputStream(
70       new FileOutputStream(file));
71     
72     int c = is.read();
73     while (c != -1) {
74       bos.write(c);
75       c = is.read();
76     }
77     bos.flush();
78     bos.close();
79     is.close();
80
81     if (crc > 0 && crc != file.length())
82       throw new Exception JavaDoc("CRC ERROR.");
83
84     return file.getAbsolutePath();
85   }
86 }
87
Popular Tags