circuitbreaker/invocations/UrlInvocation.java

package dk.thoerup.circuitbreaker.invocations;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.net.URL;
import java.net.URLConnection;

import dk.thoerup.circuitbreaker.CircuitInvocation;

public class UrlInvocation implements CircuitInvocation {

        private String urlStr;
        private int timeout;
        
        public UrlInvocation(String url) {
                this(url,1000);
        }
        
        public UrlInvocation(String url, int timeout) {
                this.urlStr = url;
                this.timeout = timeout;
        }       
        
        public byte[] proceed() throws Exception {
                URLConnection con = new URL(urlStr).openConnection();
                con.setConnectTimeout( timeout );
                InputStream is = con.getInputStream();
                ByteArrayOutputStream os = new ByteArrayOutputStream();
                byte[] message = new byte[8192];
                int readBytes = 0;;
                while ((readBytes = is.read(message)) != -1) {
                        os.write(message, 0, readBytes);
                }
                is.close();
                os.close();
                return os.toByteArray();
        }

}
1	torben	469	package dk.thoerup.circuitbreaker.invocations;
2
3			import java.io.ByteArrayOutputStream;
4			import java.io.InputStream;
5			import java.net.URL;
6			import java.net.URLConnection;
7
8			import dk.thoerup.circuitbreaker.CircuitInvocation;
9
10			public class UrlInvocation implements CircuitInvocation {
11
12			private String urlStr;
13			private int timeout;
14
15			public UrlInvocation(String url) {
16			this(url,1000);
17			}
18
19			public UrlInvocation(String url, int timeout) {
20			this.urlStr = url;
21			this.timeout = timeout;
22			}
23
24			public byte[] proceed() throws Exception {
25			URLConnection con = new URL(urlStr).openConnection();
26			con.setConnectTimeout( timeout );
27			InputStream is = con.getInputStream();
28			ByteArrayOutputStream os = new ByteArrayOutputStream();
29	torben	622	byte[] message = new byte[8192];
30	torben	469	int readBytes = 0;;
31			while ((readBytes = is.read(message)) != -1) {
32			os.write(message, 0, readBytes);
33			}
34			is.close();
35			os.close();
36			return os.toByteArray();
37			}
38
39			}