| 1 10 11 package org.objectweb.celtix.bus.bindings; 12 13 import java.io.ByteArrayInputStream ; 14 import java.io.InputStream ; 15 16 import org.objectweb.celtix.context.GenericMessageContext; 17 import org.objectweb.celtix.context.InputStreamMessageContext; 18 19 20 24 public class TestInputStreamContext 25 extends GenericMessageContext 26 implements InputStreamMessageContext { 27 28 private static final long serialVersionUID = 1L; 29 private final byte[] byteArray; 30 private InputStream inputStream; 31 32 public TestInputStreamContext() { 33 this(null); 34 } 35 36 public TestInputStreamContext(byte[] bArray) { 37 byteArray = bArray; 38 } 40 41 public InputStream getInputStream() { 42 if (null != inputStream) { 43 return inputStream; 44 } 45 if (null != byteArray) { 46 return new ByteArrayInputStream (byteArray); 47 } 48 return null; 49 } 50 51 public void setInputStream(InputStream ins) { 52 inputStream = ins; 53 } 54 55 public boolean isFault() { 56 return false; 57 } 58 59 public void setFault(boolean b) { 60 } 61 } 62 | Popular Tags |