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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
