1 18 package org.apache.activemq.openwire.v2; 19 20 import java.io.DataInputStream ; 21 import java.io.DataOutputStream ; 22 import java.io.IOException ; 23 24 import org.apache.activemq.openwire.*; 25 import org.apache.activemq.command.*; 26 27 28 39 public abstract class MessageTestSupport extends BaseCommandTestSupport { 40 41 42 protected void populateObject(Object object) throws Exception { 43 super.populateObject(object); 44 Message info = (Message) object; 45 46 info.setProducerId(createProducerId("ProducerId:1")); 47 info.setDestination(createActiveMQDestination("Destination:2")); 48 info.setTransactionId(createTransactionId("TransactionId:3")); 49 info.setOriginalDestination(createActiveMQDestination("OriginalDestination:4")); 50 info.setMessageId(createMessageId("MessageId:5")); 51 info.setOriginalTransactionId(createTransactionId("OriginalTransactionId:6")); 52 info.setGroupID("GroupID:7"); 53 info.setGroupSequence(1); 54 info.setCorrelationId("CorrelationId:8"); 55 info.setPersistent(true); 56 info.setExpiration(1); 57 info.setPriority((byte) 1); 58 info.setReplyTo(createActiveMQDestination("ReplyTo:9")); 59 info.setTimestamp(2); 60 info.setType("Type:10"); 61 { 62 byte data[] = "Content:11".getBytes(); 63 info.setContent(new org.apache.activemq.util.ByteSequence(data,0,data.length)); 64 } 65 { 66 byte data[] = "MarshalledProperties:12".getBytes(); 67 info.setMarshalledProperties(new org.apache.activemq.util.ByteSequence(data,0,data.length)); 68 } 69 info.setDataStructure(createDataStructure("DataStructure:13")); 70 info.setTargetConsumerId(createConsumerId("TargetConsumerId:14")); 71 info.setCompressed(false); 72 info.setRedeliveryCounter(2); 73 { 74 BrokerId value[] = new BrokerId[2]; 75 for( int i=0; i < 2; i++ ) { 76 value[i] = createBrokerId("BrokerPath:15"); 77 } 78 info.setBrokerPath(value); 79 } 80 info.setArrival(3); 81 info.setUserID("UserID:16"); 82 info.setRecievedByDFBridge(true); 83 info.setDroppable(false); 84 } 85 } 86 | Popular Tags |