01: package org.objectweb.celtix.bus.transports.jms;
02:
03: import java.io.InputStream;
04: import org.objectweb.celtix.context.GenericMessageContext;
05: import org.objectweb.celtix.context.InputStreamMessageContext;
06:
07: public class JMSInputStreamContext extends GenericMessageContext
08: implements InputStreamMessageContext {
09:
10: protected InputStream inStream;
11:
12: public JMSInputStreamContext(InputStream ins) {
13: inStream = ins;
14: }
15:
16: public InputStream getInputStream() {
17: return inStream;
18: }
19:
20: public void setInputStream(InputStream ins) {
21: inStream = ins;
22: }
23:
24: public void setFault(boolean isFault) {
25:
26: }
27:
28: public boolean isFault() {
29: return false;
30: }
31:
32: }
|