View Javadoc

1   /*
2    * Copyright  1999-2004 The Apache Software Foundation.
3    *
4    *  Licensed under the Apache License, Version 2.0 (the "License");
5    *  you may not use this file except in compliance with the License.
6    *  You may obtain a copy of the License at
7    *
8    *      http://www.apache.org/licenses/LICENSE-2.0
9    *
10   *  Unless required by applicable law or agreed to in writing, software
11   *  distributed under the License is distributed on an "AS IS" BASIS,
12   *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   *  See the License for the specific language governing permissions and
14   *  limitations under the License.
15   *
16   */
17  package org.apache.sandesha.storage.dao;
18  
19  import org.apache.sandesha.RMMessageContext;
20  
21  import java.util.Set;
22  
23  /***
24   * @author Chamikara Jayalath
25   * @author Jaliya Ekanayaka
26   */
27  
28  public class SandeshaDatabaseDAO implements ISandeshaDAO {
29      public SandeshaDatabaseDAO(byte endPoint) {
30      }
31  
32      public boolean addIncomingSequence(String sequenceId) {
33          return false;
34      }
35  
36      public boolean addOutgoingSequence(String sequenceId) {
37          return false;
38      }
39  
40      public boolean addPriorityMessage(RMMessageContext message) {
41          return false;
42      }
43  
44      public RMMessageContext getNextPriorityMessageContextToSend() {
45          return null;
46      }
47  
48      public boolean addMessageToIncomingSequence(String sequenceId, Long msgNo, RMMessageContext rmMessageContext) {
49          return false;
50      }
51  
52      public boolean addMessageToOutgoingSequence(String sequenceId, RMMessageContext rmMessageContext) {
53          return false;
54      }
55  
56      public boolean isIncomingSequenceExists(String sequenceId) {
57          return false;
58      }
59  
60      public boolean isOutgoingSequenceExists(String sequenceId) {
61          return false;
62      }
63  
64      public boolean isIncomingMessageExists(String sequenceId, Long msgNo) {
65          return false;
66      }
67  
68      public RMMessageContext getNextMsgContextToProcess(Object seq) {
69          return null;
70      }
71  
72      public RMMessageContext getNextOutgoingMsgContextToSend() {
73          return null;
74      }
75  
76      public Object getRandomSeqToProcess() {
77          return null;
78      }
79  
80      public Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId) {
81          return null;
82      }
83  
84      public void setOutSequence(String sequenceId, String outSequenceId) {
85  
86      }
87  
88      public void setOutSequenceApproved(String sequenceID, boolean approved) {
89  
90      }
91  
92      public String getSequenceOfOutSequence(String outsequenceId) {
93          return null;
94      }
95  
96      public void removeCreateSequenceMsg(String messageId) {
97  
98      }
99  
100     public long getNextOutgoingMessageNumber(String sequenceId) {
101         return 0;
102     }
103 
104     public RMMessageContext checkForResponseMessage(String requestId, String seqId) {
105         return null;
106     }
107 
108     public String searchForSequenceId(String messageId) {
109         return null;
110     }
111 
112     public void markOutgoingMessageToDelete(String sequenceId, Long msgNumber) {
113 
114     }
115 
116     public void setAckReceived(String seqId, long msgNo) {
117 
118     }
119 
120     public void addLowPriorityMessage(RMMessageContext msg) {
121 
122     }
123 
124     public RMMessageContext getNextLowPriorityMessageContextToSend() {
125         return null;
126     }
127 
128     public void addSendMsgNo(String seqId, long msgNo) {
129 
130     }
131 
132     public boolean isSentMsg(String seqId, long msgNo) {
133         return false;
134     }
135 
136     public boolean hasLastIncomingMsgReceived(String seqId) {
137         return false;
138     }
139 
140     public long getLastIncomingMsgNo(String seqId) {
141         return 0;
142     }
143 
144     public void addRequestedSequence(String seqId) {
145 
146     }
147 
148     public boolean isRequestedSeqPresent(String seqId) {
149         return false;
150     }
151 
152     public String getKeyFromIncomingSequenceId(String incomingSeqID) {
153         return null;
154     }
155 
156     public String getKeyFromOutgoingSequenceId(String outgoingSeqID) {
157         return null;
158     }
159 
160     public void setTerminateSend(String seqId) {
161 
162     }
163 
164     public void setTerminateReceived(String seqId) {
165 
166     }
167 
168     public boolean isAllOutgoingTerminateSent() {
169         return false;
170     }
171 
172     public boolean isAllIncommingTerminateReceived() {
173         return false;
174     }
175 
176     public void setAcksTo(String seqId, String acksTo) {
177 
178     }
179 
180     public String getAcksTo(String seqId) {
181         return null;
182     }
183 
184     public void addOffer(String msgID, String offerID) {
185 
186     }
187 
188     public String getOffer(String msgID) {
189         return null;
190     }
191 
192     public void clear() {
193 
194     }
195 
196     public boolean isOutgoingTerminateSent(String seqId) {
197         return false;
198     }
199 
200     public boolean isIncommingTerminateReceived(String seqId) {
201         return false;
202     }
203 
204     public void updateFinalMessageArrivedTime(String sequenceID) {
205 
206     }
207 
208     public void sendAck(String sequenceId) {
209 
210     }
211 
212     public void removeAllAcks(String sequenceID) {
213 
214     }
215 }