1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26 package com.mjh.switchrmi.transport.http;
27
28 import com.mjh.switchrmi.*;
29
30 import java.io.IOException;
31 import java.io.InputStream;
32 import java.io.OutputStream;
33
34 import javax.servlet.http.HttpServletRequest;
35 import javax.servlet.http.HttpServletResponse;
36
37 public class HttpServletTransport
38 extends RmiTransportBase
39 {
40 private HttpServletRequest request;
41 private HttpServletResponse response;
42
43 public HttpServletTransport()
44 {
45 super.setType(RmiTransport.SYNCHRONOUS);
46 super.setName("http");
47 }
48
49 public void setServletRequest(HttpServletRequest req)
50 {
51 request = req;
52 }
53
54 public void setServletResponse(HttpServletResponse resp)
55 {
56 response = resp;
57 }
58
59 public InputStream getInputStream(RmiContext context)
60 throws IOException
61 {
62 return request.getInputStream();
63 }
64
65 public OutputStream getOutputStream(RmiContext context)
66 throws IOException
67 {
68 return response.getOutputStream();
69 }
70
71 public void send(RmiContext context)
72 {
73 response.setHeader("Cache-Control", "no-cache");
74 }
75 }