1 22 package org.objectweb.petals.jbi.messaging.types; 23 24 import java.io.ByteArrayInputStream ; 25 26 import javax.jbi.messaging.MessageExchange.Role; 27 import javax.xml.transform.stream.StreamSource ; 28 29 import junit.framework.TestCase; 30 31 import org.objectweb.petals.jbi.messaging.MessageExchangeImpl; 32 import org.objectweb.petals.jbi.messaging.NormalizedMessageImpl; 33 34 39 public class RobustInOnlyImplTest extends TestCase { 40 41 private MessageExchangeImpl messageExchangeImpl; 42 43 private NormalizedMessageImpl normalizedMessageImpl; 44 45 public void setUp() throws Exception { 46 messageExchangeImpl = new MessageExchangeImpl(null); 47 48 normalizedMessageImpl = new NormalizedMessageImpl(); 49 50 StreamSource source = new StreamSource (); 51 byte[] msgByte = "test message".getBytes(); 52 ByteArrayInputStream in = new ByteArrayInputStream (msgByte); 53 source.setInputStream(in); 54 55 normalizedMessageImpl.setContent(source); 56 57 } 58 59 public void testConstructor() throws Exception { 60 normalizedMessageImpl.setProperty("test", "valuein"); 61 messageExchangeImpl.setPattern(MessageExchangeImpl.IN_OUT_PATTERN); 62 messageExchangeImpl.setMessage(normalizedMessageImpl, "in"); 63 new RobustInOnlyImpl(messageExchangeImpl, Role.CONSUMER); 64 65 assertEquals(messageExchangeImpl.getPattern(), MessageExchangeImpl.ROBUST_IN_ONLY_PATTERN); 66 } 67 68 } 69 | Popular Tags |