KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > objectweb > celtix > bus > ws > rm > RMPropertiesImpl


1 package org.objectweb.celtix.bus.ws.rm;
2
3 import java.util.ArrayList JavaDoc;
4 import java.util.Collection JavaDoc;
5
6 import org.objectweb.celtix.ws.rm.AckRequestedType;
7 import org.objectweb.celtix.ws.rm.RMProperties;
8 import org.objectweb.celtix.ws.rm.SequenceAcknowledgement;
9 import org.objectweb.celtix.ws.rm.SequenceType;
10
11 public class RMPropertiesImpl implements RMProperties {
12     private SequenceType sequence;
13     private Collection JavaDoc<SequenceAcknowledgement> acks;
14     private Collection JavaDoc<AckRequestedType> acksRequested;
15     
16     public Collection JavaDoc<SequenceAcknowledgement> getAcks() {
17         return acks;
18     }
19     
20     public Collection JavaDoc<AckRequestedType> getAcksRequested() {
21         return acksRequested;
22     }
23     
24     public SequenceType getSequence() {
25         return sequence;
26     }
27     
28     public void setAcks(Collection JavaDoc<SequenceAcknowledgement> a) {
29         acks = a;
30     }
31     
32     public void setAcksRequested(Collection JavaDoc<AckRequestedType> ar) {
33         acksRequested = ar;
34     }
35     
36     public void setSequence(SequenceType s) {
37         sequence = s;
38     }
39     
40     protected void setSequence(SourceSequence seq) {
41         SequenceType s = RMUtils.getWSRMFactory().createSequenceType();
42         s.setIdentifier(seq.getIdentifier());
43         s.setMessageNumber(seq.getCurrentMessageNr());
44         if (seq.isLastMessage()) {
45             s.setLastMessage(new SequenceType.LastMessage());
46         }
47         setSequence(s);
48     }
49     
50     protected void addAck(DestinationSequence seq) {
51         if (null == acks) {
52             acks = new ArrayList JavaDoc<SequenceAcknowledgement>();
53         }
54         SequenceAcknowledgement ack = seq.getAcknowledgment();
55         acks.add(ack);
56         seq.acknowledgmentSent();
57     }
58   
59 }
60
Popular Tags