You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ja...@apache.org on 2004/08/16 14:15:16 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.java
jaliya 2004/08/16 05:15:16
Added: sandesha/src/org/apache/sandesha/server/dao IServerDAO.java
Log:
This is used as the interface for the server side data accessing. This will be implemented by both ServerDatabaseDAO and ServerQueueDAO classes. Currently we have a queue implementation and will extend the persistance using a database later
Revision Changes Path
1.1 ws-fx/sandesha/src/org/apache/sandesha/server/dao/IServerDAO.java
Index: IServerDAO.java
===================================================================
/*
* Copyright 1999-2004 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
package org.apache.sandesha.server.dao;
import java.util.Iterator;
import java.util.Set;
import org.apache.sandesha.RMMessageContext;
/**
* @author Chamikara Jayalath
* @author Jaliya Ekanayaka
*/
public interface IServerDAO {
boolean addSequence(String sequenceId);
boolean addOutQueueMessage(RMMessageContext message);
RMMessageContext getNextMessageToSend();
boolean addMessageToSequence(String sequenceId,Long msgNo,RMMessageContext rmMessageContext);
boolean isSequenceExists(String sequenceId);
boolean isMessageExists(String sequenceId,Long msgNo);
RMMessageContext getNextMsgContextToProcess(String sequenceId);
String getRandomSeqIdToProcess();
Set getAllReceivedMsgNumsOfSeq(String sequenceId);
// boolean hasNewMessages();
}