KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > mule > providers > http > HttpStreamMessageAdapter


1 /*
2  * $Id: HttpStreamMessageAdapter.java 3167 2006-09-22 15:47:04Z holger $
3  * --------------------------------------------------------------------------------------
4  * Copyright (c) MuleSource, Inc. All rights reserved. http://www.mulesource.com
5  *
6  * The software in this package is published under the terms of the MuleSource MPL
7  * license, a copy of which has been included with this distribution in the
8  * LICENSE.txt file.
9  */
10
11 package org.mule.providers.http;
12
13 import java.io.InputStream JavaDoc;
14 import java.io.OutputStream JavaDoc;
15
16 import org.apache.commons.httpclient.HttpMethod;
17 import org.mule.config.i18n.Message;
18 import org.mule.config.i18n.Messages;
19 import org.mule.providers.streaming.StreamMessageAdapter;
20 import org.mule.umo.provider.OutputHandler;
21
22 /**
23  * A HttpStream adapter that can be used with the HttpClientMessageDispatcher who
24  * knows when to release the Http Connection.
25  */
26 public class HttpStreamMessageAdapter extends StreamMessageAdapter
27 {
28     private static final long serialVersionUID = -7836682641618511926L;
29
30     protected volatile HttpMethod httpMethod;
31
32     public HttpStreamMessageAdapter(InputStream JavaDoc in)
33     {
34         super(in);
35     }
36
37     public HttpStreamMessageAdapter(InputStream JavaDoc in, OutputStream JavaDoc out)
38     {
39         super(in, out);
40     }
41
42     public HttpStreamMessageAdapter(OutputHandler handler)
43     {
44         super(handler);
45     }
46
47     public HttpStreamMessageAdapter(OutputStream JavaDoc out, OutputHandler handler)
48     {
49         super(out, handler);
50     }
51
52     public HttpStreamMessageAdapter(InputStream JavaDoc in, OutputStream JavaDoc out, OutputHandler handler)
53     {
54         super(in, out, handler);
55     }
56
57     public HttpMethod getHttpMethod()
58     {
59         return httpMethod;
60     }
61
62     public void setHttpMethod(HttpMethod httpMethod)
63     {
64         this.httpMethod = httpMethod;
65     }
66
67     public void release()
68     {
69         if (httpMethod == null)
70         {
71             throw new IllegalStateException JavaDoc(new Message(Messages.X_IS_NULL, "httpMethod object").toString());
72         }
73         else
74         {
75             httpMethod.releaseConnection();
76         }
77     }
78 }
79
Popular Tags