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 class MessageAckTest extends BaseCommandTestSupport { 40 41 42 public static MessageAckTest SINGLETON = new MessageAckTest(); 43 44 public Object createObject() throws Exception { 45 MessageAck info = new MessageAck(); 46 populateObject(info); 47 return info; 48 } 49 50 protected void populateObject(Object object) throws Exception { 51 super.populateObject(object); 52 MessageAck info = (MessageAck) object; 53 54 info.setDestination(createActiveMQDestination("Destination:1")); 55 info.setTransactionId(createTransactionId("TransactionId:2")); 56 info.setConsumerId(createConsumerId("ConsumerId:3")); 57 info.setAckType((byte) 1); 58 info.setFirstMessageId(createMessageId("FirstMessageId:4")); 59 info.setLastMessageId(createMessageId("LastMessageId:5")); 60 info.setMessageCount(1); 61 } 62 } 63 | Popular Tags |