[prev in list] [next in list] [prev in thread] [next in thread]
List: sandesha-dev
Subject: svn commit: r670536 -
From: gatfora () apache ! org
Date: 2008-06-23 12:19:16
Message-ID: 20080623121916.A4C812388A0C () eris ! apache ! org
[Download RAW message or body]
Author: gatfora
Date: Mon Jun 23 05:19:16 2008
New Revision: 670536
URL: http://svn.apache.org/viewvc?rev=670536&view=rev
Log:
Applying missing test for SANDESHA2-158
Added:
webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/utils/SandeshaUtilTest.java
Added: webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/utils/SandeshaUtilTest.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/utils/SandeshaUtilTest.java?rev=670536&view=auto
==============================================================================
--- webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/utils/SandeshaUtilTest.java \
(added)
+++ webservices/sandesha/trunk/java/modules/tests/src/test/java/org/apache/sandesha2/utils/SandeshaUtilTest.java \
Mon Jun 23 05:19:16 2008 @@ -0,0 +1,126 @@
+/*
+ * Copyright 2004,2005 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.sandesha2.utils;
+
+import java.util.ArrayList;
+
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.AxisModule;
+import org.apache.axis2.engine.Handler;
+import org.apache.axis2.engine.Phase;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.SandeshaTestCase;
+import org.apache.sandesha2.polling.PollingManager;
+import org.apache.sandesha2.storage.SandeshaStorageException;
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.Transaction;
+import org.apache.sandesha2.storage.beanmanagers.InvokerBeanMgr;
+import org.apache.sandesha2.storage.beanmanagers.RMDBeanMgr;
+import org.apache.sandesha2.storage.beanmanagers.RMSBeanMgr;
+import org.apache.sandesha2.storage.beanmanagers.SenderBeanMgr;
+import org.apache.sandesha2.transport.Sandesha2TransportOutDesc;
+import org.apache.sandesha2.util.SandeshaUtil;
+import org.apache.sandesha2.workers.SandeshaThread;
+
+public class SandeshaUtilTest extends SandeshaTestCase{
+
+
+ public SandeshaUtilTest(String s){
+ super(s);
+ }
+
+ private class DummyStorageManager extends StorageManager{
+
+ public DummyStorageManager(ConfigurationContext context) {
+ super(context);
+ }
+
+ public SandeshaThread getInvoker() {
+ return null;
+ }
+
+ public InvokerBeanMgr getInvokerBeanMgr() {
+ return null;
+ }
+
+ public PollingManager getPollingManager() {
+ return null;
+ }
+
+ public RMDBeanMgr getRMDBeanMgr() {
+ return null;
+ }
+
+ public RMSBeanMgr getRMSBeanMgr() {
+ return null;
+ }
+
+ public SandeshaThread getSender() {
+ return null;
+ }
+
+ public SenderBeanMgr getSenderBeanMgr() {return null;
+ }
+
+ public Transaction getTransaction() {
+ return null;
+ }
+
+ public boolean hasUserTransaction(MessageContext message) throws \
SandeshaStorageException { + return false;
+ }
+
+ public void initStorage(AxisModule moduleDesc) throws SandeshaStorageException {}
+
+ public void removeMessageContext(String storageKey) throws \
SandeshaStorageException {} +
+ public boolean requiresMessageSerialization() {
+ return false;
+ }
+
+ public MessageContext retrieveMessageContext(String storageKey, \
ConfigurationContext configContext) throws SandeshaStorageException { + return \
null; + }
+
+ public void storeMessageContext(String storageKey, MessageContext msgContext) \
throws SandeshaStorageException {} +
+ public void updateMessageContext(String storageKey, MessageContext msgContext) \
throws SandeshaStorageException {} +
+ }
+
+ public void testModifyExecutionChainForStoring() throws Exception{
+ ArrayList executionChain = new ArrayList();
+ executionChain.add(new Phase("one"));
+ executionChain.add(new Phase("two"));
+ executionChain.add(new Phase("MessageOut"));
+ executionChain.add(new Phase("Security"));
+
+ MessageContext mc = new MessageContext();
+ mc.setExecutionChain(executionChain);
+ mc.setTransportOut(new Sandesha2TransportOutDesc());
+ StorageManager sm = new DummyStorageManager(null);
+ SandeshaUtil.modifyExecutionChainForStoring(mc, sm);
+
+ ArrayList retransmittablePhases = (ArrayList) \
mc.getProperty(Sandesha2Constants.RETRANSMITTABLE_PHASES); +
+ assertEquals(2, mc.getExecutionChain().size());
+ assertEquals(2, retransmittablePhases.size());
+ assertEquals("MessageOut", ((Handler)retransmittablePhases.get(0)).getName());
+ assertEquals("Security", ((Handler)retransmittablePhases.get(1)).getName());
+ }
+}
+
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic