1 14 15 package org.apache.activemq.store.kahadaptor; 16 17 import org.apache.activemq.command.MessageId; 18 import org.apache.activemq.kaha.StoreEntry; 19 20 25 public class ConsumerMessageRef{ 26 27 private MessageId messageId; 28 private StoreEntry messageEntry; 29 private StoreEntry ackEntry; 30 31 34 public StoreEntry getAckEntry(){ 35 return this.ackEntry; 36 } 37 38 41 public void setAckEntry(StoreEntry ackEntry){ 42 this.ackEntry=ackEntry; 43 } 44 45 48 public StoreEntry getMessageEntry(){ 49 return this.messageEntry; 50 } 51 52 55 public void setMessageEntry(StoreEntry messageEntry){ 56 this.messageEntry=messageEntry; 57 } 58 59 60 63 public MessageId getMessageId(){ 64 return this.messageId; 65 } 66 67 68 71 public void setMessageId(MessageId messageId){ 72 this.messageId=messageId; 73 } 74 75 public String toString() { 76 return "ConsumerMessageRef[" + messageId +"]"; 77 } 78 79 80 } 81 | Popular Tags |