|
1 package org.objectweb.celtix.bus.ws.rm.persistence.file;
2
3 import java.io.File  ;
4 import java.math.BigInteger ;
5 import java.util.ArrayList ;
6 import java.util.Collection ;
7 import java.util.Map ;
8
9 import org.objectweb.celtix.ws.rm.Identifier;
10 import org.objectweb.celtix.ws.rm.persistence.RMDestinationSequence;
11 import org.objectweb.celtix.ws.rm.persistence.RMMessage;
12 import org.objectweb.celtix.ws.rm.persistence.RMSourceSequence;
13 import org.objectweb.celtix.ws.rm.persistence.RMStore;
14
15 public class RMFileStore implements RMStore {
16 public static final String FILE_STORE_DIR =
17 "org.objectweb.celtix.rm.persistence.file.dir";
18
19 private File root;
20
21 public void init(Map <String , String > params) {
22 String dirName = params.get(FILE_STORE_DIR);
23 if (null == dirName) {
24 dirName = ".";
25 }
26 root = new File (dirName);
27 assert null != root;
28 }
29
30
31 public void createDestinationSequence(RMDestinationSequence seq) {
32
34 }
35
36 public void createSourceSequence(RMSourceSequence seq) {
37
39 }
40
41 public Collection <RMDestinationSequence> getDestinationSequences(String endpointIdentifier) {
42 return new ArrayList <RMDestinationSequence>();
43 }
44
45 public Collection <RMMessage> getMessages(Identifier sid, boolean outbound) {
46 return new ArrayList <RMMessage>();
47 }
48
49 public Collection <RMSourceSequence> getSourceSequences(String endpointIdentifier) {
50 return new ArrayList <RMSourceSequence>();
51 }
52
53 public void persistIncoming(RMDestinationSequence seq, RMMessage msg) {
54
56 }
57
58 public void persistOutgoing(RMSourceSequence seq, RMMessage msg) {
59
61 }
62
63 public void removeMessages(Identifier sid, Collection <BigInteger > messageNrs, boolean outbound) {
64
66 }
67
68 public void removeDestinationSequence(Identifier sid) {
69
71 }
72
73 public void removeSourceSequence(Identifier sid) {
74
76 }
77
78 }
79 |
Popular Tags |
Java API By Example, From Geeks To Geeks.