1 18 package org.apache.activemq.openwire.v1; 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 info.setProducerId(createProducerId("ProducerId:1")); 46 info.setDestination(createActiveMQDestination("Destination:2")); 47 info.setTransactionId(createTransactionId("TransactionId:3")); 48 info.setOriginalDestination(createActiveMQDestination("OriginalDestination:4")); 49 info.setMessageId(createMessageId("MessageId:5")); 50 info.setOriginalTransactionId(createTransactionId("OriginalTransactionId:6")); 51 info.setGroupID("GroupID:7"); 52 info.setGroupSequence(1); 53 info.setCorrelationId("CorrelationId:8"); 54 info.setPersistent(true); 55 info.setExpiration(1); 56 info.setPriority((byte) 1); 57 info.setReplyTo(createActiveMQDestination("ReplyTo:9")); 58 info.setTimestamp(2); 59 info.setType("Type:10"); 60 61 { 62 byte data[] = "Content:11".getBytes(); 63 info.setContent(new org.apache.activemq.util.ByteSequence(data,0,data.length)); 64 } 65 66 67 { 68 byte data[] = "MarshalledProperties:12".getBytes(); 69 info.setMarshalledProperties(new org.apache.activemq.util.ByteSequence(data,0,data.length)); 70 } 71 72 info.setDataStructure(createDataStructure("DataStructure:13")); 73 info.setTargetConsumerId(createConsumerId("TargetConsumerId:14")); 74 info.setCompressed(false); 75 info.setRedeliveryCounter(2); 76 77 { 78 BrokerId value[] = new BrokerId[2]; 79 for( int i=0; i < 2; i++ ) { 80 value[i] = createBrokerId("BrokerPath:15"); 81 } 82 info.setBrokerPath(value); 83 } 84 info.setArrival(3); 85 info.setUserID("UserID:16"); 86 info.setRecievedByDFBridge(true); 87 88 } 89 } 90 | Popular Tags |