jaliya 2005/02/28 06:49:13
Modified: sandesha/lib addressing-SNAPSHOT.jar
sandesha/src/org/apache/sandesha EnvelopeCreator.java
Added: sandesha/lib axis-wsdl4j-1.2-RC1.jar
commons-logging-1.0.3.jar
sandesha maven.xml project.properties project.xml
sandesha/test/org/apache/sandesha SimpleServerImpl.java
sandesha/test/org/apache/sandesha/storage
TCClientStorageManager.java
Removed: sandesha/lib commons-logging-SNAPSHOT.jar
wsdl4j-1.5-SNAPSHOT.jar
sandesha/site forrest-targets.ent forrest.properties
status.xml
sandesha/site/src/documentation README.txt skinconf.xml
sandesha/site/src/documentation/content/xdocs
Configuration.xml Sandesha.xml SandeshaMonitor.xml
index.xml site.xml tabs.xml
sandesha/site/src/documentation/resources/images Thumbs.db
group-logo.gif group.svg icon.png project-logo.gif
project.svg
Log:
Re arranging the project site, maven integration
Revision Changes Path
1.2 +101 -101 ws-fx/sandesha/lib/addressing-SNAPSHOT.jar
<<Binary file>>
1.1 ws-fx/sandesha/lib/axis-wsdl4j-1.2-RC1.jar
<<Binary file>>
1.1 ws-fx/sandesha/lib/commons-logging-1.0.3.jar
<<Binary file>>
1.21 +3 -12
ws-fx/sandesha/src/org/apache/sandesha/EnvelopeCreator.java
Index: EnvelopeCreator.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/EnvelopeCreator.java,v
retrieving revision 1.20
retrieving revision 1.21
diff -u -r1.20 -r1.21
--- EnvelopeCreator.java 28 Feb 2005 13:25:56 -0000 1.20
+++ EnvelopeCreator.java 28 Feb 2005 14:49:12 -0000 1.21
@@ -160,7 +160,7 @@
public static void addNamespaceDeclarations(SOAPEnvelope soapEnv) throws
Exception {
soapEnv.addNamespaceDeclaration(Constants.NS_PREFIX_RM,
Constants.NS_URI_RM);
-
soapEnv.addNamespaceDeclaration(org.apache.axis.message.addressing.Constants.NS_PREFIX_ADDRESSING,
org.apache.axis.message.addressing.Constants.NS_URI_ADDRESSING);
+
soapEnv.addNamespaceDeclaration(org.apache.axis.message.addressing.Constants.NS_PREFIX_ADDRESSING,
org.apache.axis.message.addressing.Constants.NS_URI_ADDRESSING_DEFAULT);
soapEnv.addNamespaceDeclaration(Constants.WSU_PREFIX,
Constants.NS_URI_WSU);
}
@@ -278,13 +278,7 @@
return responseEnvelope;
}
- /**
- * @param uuid
- * @param rmMessageContext
- * @param endPoint
- * @return @throws
- * MalformedURIException
- */
+
public static SOAPEnvelope createServiceRequestEnvelope(RMMessageContext
rmMessageContext) throws Exception {
//Variable for SOAPEnvelope
SOAPEnvelope requestEnvelope = null;
@@ -338,10 +332,7 @@
return requestEnvelope;
}
- /**
- * @param sequenceID
- * @return
- */
+
public static SOAPEnvelope createTerminatSeqMessage(RMMessageContext
rmMessageContext) throws Exception {
AddressingHeaders addressingHeaders =
rmMessageContext.getAddressingHeaders();
SOAPEnvelope terSeqEnv = createBasicEnvelop();
1.1 ws-fx/sandesha/maven.xml
Index: maven.xml
===================================================================
<?xml version="1.0" encoding="UTF-8"?>
<!-- $Revision: 1.1 $ $Date: 2005/02/28 14:49:13 $ -->
<project default="jar"
xmlns:j="jelly:core"
xmlns:maven="jelly:maven"
xmlns:deploy="deploy"
xmlns:ant="jelly:ant">
<goal name="setclasspath">
<path id="test.classpath">
<path refid="maven.dependency.classpath"/>
</path>
</goal>
<postGoal name="jar">
<ant:mkdir dir="${basedir}/target/lib"/>
<deploy:copy-deps todir="${basedir}/target/lib"/>
</postGoal>
<goal name="interop:compile" prereqs="java:compile">
<ant:javac srcdir="interop" destdir="${maven.build.dest}"
includes="**/*.java"
debug="${maven.compile.debug}"
optimize="${optimize}"
deprecation="${maven.compile.deprecation}">
<ant:classpath>
<pathelement location="${maven.build.dest}"/>
<path refid="maven.dependency.classpath"/>
</ant:classpath>
</ant:javac>
</goal>
<!-- to transforme htmls to xdocs -->
<preGoal name="xdoc:jelly-transform">
<attainGoal name="html2xdoc"/>
</preGoal>
</project>
1.1 ws-fx/sandesha/project.properties
Index: project.properties
===================================================================
#
-----------------------------------------------------------------------------
# Default properties for the Maven build. You can override these properties
# either by defining a build.properties file with the overriden properties
# or by passing them on the command line as system parameters (-D).
#
-----------------------------------------------------------------------------
# MAVEN CORE
##############
# comma-spearated list of remote JAR repository URLs
maven.repo.remote=http://www.apache.org/dist/java-repository,
http://dist.codehaus.org, http://www.ibiblio.org/maven,
http://cvs.apache.org/repository
# XDOC PLUGIN
###############
# Display project version and date on web site
maven.xdoc.date = left
maven.xdoc.version = ${pom.currentVersion}
maven.html2xdoc.enabled=false
maven.html2xdoc.dir=./xdocs
1.1 ws-fx/sandesha/project.xml
Index: project.xml
===================================================================
<?xml version="1.0" encoding="ISO-8859-1"?>
<project>
<!-- the version of maven's project object model -->
<pomVersion>3</pomVersion>
<!-- a unique name for this project -->
<id>Sandesha</id>
<!-- a short but descriptive name for the project -->
<name>Apache Sandesha</name>
<!-- The version of the project under development, e.g.
1.1, 1.2, 2.0-SNAPSHOT -->
<currentVersion>1.0</currentVersion>
<!-- details about the organization that 'owns' the project -->
<organization>
<name>Apache Web Services</name>
<url>http://ws.apache.org/</url>
<logo>http://www.apache.org/images/asf-logo.gif</logo>
</organization>
<!-- the year the project started -->
<inceptionYear>2003</inceptionYear>
<package>org.apache.sandesha</package>
<logo>http://ws.apache.org/ws-fx/sandesha/images/Sandesha.jpg</logo>
<description>Apache Sandesha is an implementation of the Web Services
ReliableMessaging (WS-ReliableMessaging), published by the IBM, Microsoft and
BEA as a joint specification, on top of Apache Axis (The Next Generation SOAP).
Apache Sandesha provides; An implementation for WS-ReliableMessaging with the
support to WS-Policy and WS- Addressing. Interoperability with other
WS-ReliableMessaging implementations. Sandesha provides a complete support
for WS-ReliableMessaging specification allowing a reliable communication
between web services as well as web services and clients. It also provides the
INORDER message delivery assurance for the users.
</description>
<!-- a short description of what the project does -->
<shortDescription>WS-ReliableMessaging implementation for Apache
Axis</shortDescription>
<!-- the project home page -->
<url>http://ws.apache.org/ws-fx/sandesha/</url>
<issueTrackingUrl>http://nagoya.apache.org/jira/browse/WSFX</issueTrackingUrl>
<siteAddress>ws.apache.org</siteAddress>
<siteDirectory>/ws-fx/sandesha/</siteDirectory>
<distributionDirectory>/www/ws.apache.org/builds/</distributionDirectory>
<!-- the version control repository and http url for online access
the connection element has the form:
scm:<system>:<system specific connection string> -->
<repository>
<connection>scm:cvs:pserver:[EMAIL
PROTECTED]:/home/cvspublic:ws-fx/sandesha/</connection>
<url>http://cvs.apache.org/viewcvs.cgi/ws-fx/sandesha/</url>
</repository>
<!-- any mailing lists for the project -->
<mailingLists>
<mailingList>
<name>WS-FX Developer List</name>
<subscribe>[EMAIL PROTECTED]</subscribe>
<unsubscribe>[EMAIL PROTECTED]</unsubscribe>
<archive>http://nagoya.apache.org/eyebrowse/SummarizeList?listId=221</archive>
</mailingList>
</mailingLists>
<!-- who the developers are for the project -->
<developers>
<developer>
<name>Davanum Srinivas</name>
<id>dims</id>
<email>[EMAIL PROTECTED]</email>
<organization>
</organization>
</developer>
<developer>
<name>Jaliya Ekanayake</name>
<id>jaliya</id>
<email>[EMAIL PROTECTED]</email>
<organization>
</organization>
</developer>
<developer>
<name>Chamikara Jayalath</name>
<id>chamikara</id>
<email>[EMAIL PROTECTED]</email>
<organization>
</organization>
</developer>
</developers>
<licenses>
<license>
<name>The Apache Software License, Version 2.0</name>
<url>http://www.apache.org/licenses/LICENSE-2.0</url>
<distribution>repo</distribution>
</license>
</licenses>
<!-- build information for the project -->
<build>
<nagEmailAddress>[EMAIL PROTECTED]</nagEmailAddress>
<sourceDirectory>src</sourceDirectory>
<!--<unitTestSourceDirectory>test</unitTestSourceDirectory> -->
<resources>
<resource>
<directory>conf</directory>
<includes>
<include>*.properties</include>
</includes>
</resource>
</resources>
<!-- <unitTest>-->
<!-- <includes>-->
<!-- <include>**/*TC*.java</include>-->
<!-- </includes>-->
<!-- <resources>-->
<!-- <resource>-->
<!-- <directory>test-resources</directory>-->
<!-- <includes>-->
<!-- <include>**/*.xml</include>-->
<!-- </includes>-->
<!-- </resource>-->
<!-- </resources>-->
<!-- </unitTest>-->
</build>
<!-- ============ -->
<!-- Dependencies -->
<!-- ============ -->
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<url>http://ws.apache.org/axis/</url>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis</artifactId>
<version>1.2-RC2</version>
<url>http://ws.apache.org/axis/</url>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis-jaxrpc</artifactId>
<version>1.2-RC2</version>
<url>http://ws.apache.org/axis/</url>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis-saaj</artifactId>
<version>1.2-RC2</version>
<url>http://ws.apache.org/axis/</url>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.0.3</version>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>commons-discovery</artifactId>
<version>SNAPSHOT</version>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis-ant</artifactId>
<version>SNAPSHOT</version>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis-saaj</artifactId>
<version>1.2-RC2</version>
<url>http://ws.apache.org/axis/</url>
</dependency>
<dependency>
<groupId>axis</groupId>
<artifactId>axis-wsdl4j</artifactId>
<version>1.2-RC1</version>
<properties>
<module>true</module>
</properties>
</dependency>
<dependency>
<groupId>addressing</groupId>
<artifactId>addressing</artifactId>
<version>SNAPSHOT</version>
<properties>
<module>true</module>
</properties>
</dependency>
</dependencies>
<!-- ======= -->
<!-- Reports -->
<!-- ======= -->
<!-- reports>
<report>maven-license-plugin</report>
<report>maven-checkstyle-plugin</report>
<report>maven-pmd-plugin</report>
<report>maven-jdepend-plugin</report>
<report>maven-changelog-plugin</report>
<report>maven-file-activity-plugin</report>
<report>maven-developer-activity-plugin</report>
<report>maven-jxr-plugin</report>
<report>maven-javadoc-plugin</report>
<report>maven-junit-report-plugin</report>
<report>maven-clover-plugin</report>
</reports -->
</project>
1.1
ws-fx/sandesha/test/org/apache/sandesha/SimpleServerImpl.java
Index: SimpleServerImpl.java
===================================================================
package org.apache.sandesha.test;
import java.io.File;
import java.net.ServerSocket;
import java.util.Iterator;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.namespace.QName;
import org.apache.axis.deployment.wsdd.WSDDDeployment;
import org.apache.axis.deployment.wsdd.WSDDDocument;
import org.apache.axis.transport.http.SimpleAxisServer;
import org.apache.axis.handlers.soap.SOAPService;
import org.apache.axis.EngineConfiguration;
import org.apache.axis.AxisEngine;
import org.apache.axis.description.JavaServiceDesc;
import org.apache.axis.server.AxisServer;
import org.apache.sandesha.ws.rm.providers.RMProvider;
import org.apache.sandesha.util.PropertyLoader;
import org.w3c.dom.Document;
/**
* Created by IntelliJ IDEA. User: Jaliya Date: Sep 13, 2004 Time: 2:31:47 PM
To
* change this template use Options | File Templates.
*/
public class SimpleServerImpl {
public static void main(String[] args) {
try {
SimpleAxisServer sas = new SimpleAxisServer();
DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();
dbf.setNamespaceAware(true);
DocumentBuilder db = dbf.newDocumentBuilder();
//Need to change the path
Document doc = db.parse(new File("config/server-config.wsdd"));
//Document doc = db.parse(new
File("D:\\Projects\\Sandesha\\Version1\\classes\\server-config.wsdd"));
//"C:/SandeshaPrj/SandeshaIMPL/PrjWorkspace/bin/server-config.wsdd"));
WSDDDocument wsdddoc = new WSDDDocument(doc);
WSDDDeployment wsdddep = wsdddoc.getDeployment();
sas.setMyConfig(wsdddep);
sas.getMyConfig().configureEngine(new AxisServer());
sas.setServerSocket(new
ServerSocket(PropertyLoader.getSimpleAxisServerPort()));
Thread serverThread = new Thread(sas);
serverThread.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}
1.1
ws-fx/sandesha/test/org/apache/sandesha/storage/TCClientStorageManager.java
Index: TCClientStorageManager.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.storage;
import java.util.Date;
import junit.framework.TestCase;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMMessageContext;
import org.apache.sandesha.client.ClientStorageManager;
import org.apache.sandesha.storage.queue.QueueException;
import org.apache.sandesha.storage.queue.SandeshaQueue;
/**
* @author Chamikara Jayalath
* @author Jaliya Ekanayaka
*/
public class TCClientStorageManager extends TestCase {
public void testOutGoingMessages() throws QueueException {
SandeshaQueue sq = SandeshaQueue.getInstance();
ClientStorageManager csm = new ClientStorageManager();
long l =
csm.getNextMessageNumber(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(l, 1);
RMMessageContext msg = new RMMessageContext();
msg.setMessageID("rmsg1");
msg.setSequenceID(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
sq.createNewOutgoingSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
sq.addMessageToOutgoingSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID,
msg);
l = csm.getNextMessageNumber(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(l, 2);
msg = new RMMessageContext();
msg.setMessageID("rmsg2");
msg.setSequenceID(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
sq.addMessageToOutgoingSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID,
msg);
l = csm.getNextMessageNumber(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(l, 3);
msg = new RMMessageContext();
msg.setMessageID("rmsg3");
msg.setSequenceID(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
sq.addMessageToOutgoingSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID,
msg);
l = csm.getNextMessageNumber(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(l, 4);
msg = new RMMessageContext();
msg.setMessageID("rmsg4");
msg.setSequenceID(Constants.CLIENT_DEFAULD_SEQUENCE_ID);
sq.addMessageToOutgoingSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID,
msg);
//csm.
//sq.displayOutgoingMap();
csm.setTemporaryOutSequence(Constants.CLIENT_DEFAULD_SEQUENCE_ID,
"temp1");
RMMessageContext createSeqReq1 = new RMMessageContext();
createSeqReq1
.setMessageType(Constants.MSG_TYPE_CREATE_SEQUENCE_REQUEST);
createSeqReq1.setMessageID("temp1");
//RMMessageContext createSeqReq2 = new RMMessageContext();
//createSeqReq2.setMessageType(Constants.MSG_TYPE_CREATE_SEQUENCE_REQUEST);
//createSeqReq2.setMessageID("temp2");
//sq.diaplayPriorityQueue();
//csm.addCreateSequenceRequest(createSeqReq1);
//sq.diaplayPriorityQueue();
csm.addCreateSequenceRequest(createSeqReq1);
//sq.displayPriorityQueue();
RMMessageContext msg1;
ClientStorageManager ssm1 = new ClientStorageManager();
//sq.displayPriorityQueue();
//msg1 = ssm1.getNextMessageToSend();
//assertEquals(msg1.getMessageID(),"temp1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getMessageID(), "temp1");
//sq.displayPriorityQueue();
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1, null);
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1, null);
RMMessageContext ack1 = new RMMessageContext();
ack1.setMessageID("msgack1");
csm.addAcknowledgement(ack1);
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getMessageID(), "msgack1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1, null);
RMMessageContext createSeq = new RMMessageContext();
createSeq.setMessageID("createSeqid1");
csm.addCreateSequenceResponse(createSeq);
sq.displayPriorityQueue();
csm.setApprovedOutSequence("temp1", "approved1");
sq.displayPriorityQueue();
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getMessageID(), "createSeqid1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg2");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg4");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg3");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1, null);
Date d1 = new Date();
long l1 = d1.getTime();
for (int i = 0; i < 2000000000; i++) {
}
Date d2 = new Date();
long l2 = d2.getTime();
if ((l2 - l1) < 4000) {
System.out.println("Error: Wait time was not enough");
return;
}
//msg1 = ssm1.getNextMessageToSend();
//assertEquals(msg1.getMessageID(),"temp2");
//ssm1.setApprovedOutSequence("temp2","approved2");
sq.displayPriorityQueue();
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg2");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg4");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg3");
msg1 = ssm1.getNextMessageToSend();
//System.out.println(msg1.getMessageID());
assertEquals(msg1, null);
//sq.displayResponseMap();
d1 = new Date();
l1 = d1.getTime();
for (int i = 0; i < 2140000000; i++) {
}
d2 = new Date();
l2 = d2.getTime();
if ((l2 - l1) < 4000) {
System.out.println("Error: Wait time was not enough");
return;
}
//Old messages must come again
msg1 = ssm1.getNextMessageToSend();
//System.out.println(msg1.getMessageID());
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg2");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg4");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg1");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg3");
//sq.displayResponseMap();
ssm1.setAcknowledged(Constants.CLIENT_DEFAULD_SEQUENCE_ID, 1);
ssm1.setAcknowledged(Constants.CLIENT_DEFAULD_SEQUENCE_ID, 2);
ssm1.setAcknowledged(Constants.CLIENT_DEFAULD_SEQUENCE_ID, 4);
//sq.displayResponseMap();
d1 = new Date();
l1 = d1.getTime();
for (int i = 0; i < 2140000000; i++) {
}
d2 = new Date();
l2 = d2.getTime();
if ((l2 - l1) < 4000) {
System.out.println("Error: Wait time was not enough");
return;
}
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1.getSequenceID(),
Constants.CLIENT_DEFAULD_SEQUENCE_ID);
assertEquals(msg1.getMessageID(), "rmsg3");
msg1 = ssm1.getNextMessageToSend();
assertEquals(msg1, null);
}
/*
* (non-Javadoc)
*
* @see junit.framework.TestCase#setUp()
*/
protected void setUp() throws Exception {
// TODO Auto-generated method stub
/*
* super.setUp();
*
* SandeshaQueue sq = SandeshaQueue.getInstance();
*
* sq.clear(true);
*
* sq.createNewIncomingSequence("test");
*
* RMMessageContext msg1 = new RMMessageContext();
* msg1.setMessageID("msgid1"); msg1.setSequenceID("test");
*
* RMMessageContext msg2 = new RMMessageContext();
* msg2.setMessageID("msgid2"); msg2.setSequenceID("test");
*
* RMMessageContext msg3 = new RMMessageContext();
* msg3.setMessageID("msgid3"); msg3.setSequenceID("test");
*
* RMMessageContext msg4 = new RMMessageContext();
* msg4.setMessageID("msgid4"); msg4.setSequenceID("test");
*
* sq.addMessageToIncomingSequence("test", new Long(1), msg1);
* sq.addMessageToIncomingSequence("test", new Long(2), msg2);
* sq.addMessageToIncomingSequence("test", new Long(3), msg3);
* sq.addMessageToIncomingSequence("test", new Long(4), msg4);
*/
}
}
