1 45 package org.exolab.jms.messagemgr; 46 47 import javax.jms.JMSException ; 48 import javax.jms.MessageConsumer ; 49 50 51 57 class TopicConsumerMessageHandle extends AbstractConsumerMessageHandle { 58 59 65 private boolean _delivered = false; 66 67 68 75 public TopicConsumerMessageHandle(MessageHandle handle, 76 ConsumerEndpoint consumer) 77 throws JMSException { 78 super(handle, consumer); 79 init(handle); 80 } 81 82 90 public TopicConsumerMessageHandle(MessageHandle handle, String persistentId) 91 throws JMSException { 92 super(handle, persistentId); 93 init(handle); 94 } 95 96 103 public void setDelivered(boolean delivered) { 104 _delivered = delivered; 105 } 106 107 112 public boolean getDelivered() { 113 return _delivered; 114 } 115 116 121 private void init(MessageHandle handle) { 122 _delivered = handle.getDelivered(); 123 } 124 125 } 126 | Popular Tags |