/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you 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.axis2.engine;
import junit.framework.TestCase;
import org.apache.axiom.soap.SOAP12Constants;
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.description.TransportInDescription;
import org.apache.axis2.description.TransportOutDescription;
import org.apache.axis2.transport.http.CommonsHTTPTransportSender;
import org.apache.axis2.transport.http.SimpleHTTPServer;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import javax.xml.namespace.QName;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
public class OptionsSaveTest extends TestCase {
protected static final Log log = LogFactory.getLog(OptionsSaveTest.class);
private transient QName serviceName = new QName("NullService");
private transient QName operationName = new QName("DummyOp");
private String testArg = null;
public OptionsSaveTest(String arg0) {
super(arg0);
testArg = new String(arg0);
initAll();
}
protected void initAll() {
}
protected void setUp() throws Exception {
//org.apache.log4j.BasicConfigurator.configure();
}
public void testSaveAndRestore() throws Exception {
File theFile = null;
String theFilename = null;
boolean saved = false;
boolean restored = false;
boolean done = false;
boolean comparesOk = false;
AxisConfiguration axisConfiguration = new AxisConfiguration();
ConfigurationContext configurationContext = new ConfigurationContext(axisConfiguration);
log.debug("OptionsSaveTest:testSaveAndRestore(): BEGIN ---------------");
// ---------------------------------------------------------
// setup an options object to use
// ---------------------------------------------------------
Options options = new Options();
options.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
options.setExceptionToBeThrownOnSOAPFault(true);
options.setTimeOutInMilliSeconds(5000L);
options.setUseSeparateListener(false);
options.setAction("SoapAction");
options.setFaultTo(new EndpointReference("http://ws.apache.org/axis2/faultTo"));
options.setFrom(new EndpointReference("http://ws.apache.org/axis2/from"));
options.setTo(new EndpointReference("http://ws.apache.org/axis2/to"));
options.setReplyTo(new EndpointReference(AddressingConstants.Final.WSA_ANONYMOUS_URL));
TransportOutDescription transportOut = new TransportOutDescription("null");
TransportOutDescription transportOut2 = new TransportOutDescription("happy");
TransportOutDescription transportOut3 = new TransportOutDescription("golucky");
transportOut.setSender(new CommonsHTTPTransportSender());
transportOut2.setSender(new CommonsHTTPTransportSender());
transportOut3.setSender(new CommonsHTTPTransportSender());
options.setTransportOut(transportOut);
axisConfiguration.addTransportOut(transportOut3);
axisConfiguration.addTransportOut(transportOut2);
axisConfiguration.addTransportOut(transportOut);
TransportInDescription transportIn = new TransportInDescription("null");
TransportInDescription transportIn2 = new TransportInDescription("always");
TransportInDescription transportIn3 = new TransportInDescription("thebest");
transportIn.setReceiver(new SimpleHTTPServer());
transportIn2.setReceiver(new SimpleHTTPServer());
transportIn3.setReceiver(new SimpleHTTPServer());
options.setTransportIn(transportIn);
axisConfiguration.addTransportIn(transportIn2);
axisConfiguration.addTransportIn(transportIn);
axisConfiguration.addTransportIn(transportIn3);
options.setMessageId("msgId012345");
options.setProperty("key01", "value01");
options.setProperty("key02", "value02");
options.setProperty("key03", "value03");
options.setProperty("key04", "value04");
options.setProperty("key05", "value05");
options.setProperty("key06", "value06");
options.setProperty("key07", "value07");
options.setProperty("key08", "value08");
options.setProperty("key09", "value09");
options.setProperty("key10", "value10");
// TODO: setup a parent
// ---------------------------------------------------------
// setup a temporary file to use
// ---------------------------------------------------------
try {
theFile = File.createTempFile("optionsSave", null);
theFilename = theFile.getName();
log.debug("OptionsSaveTest:testSaveAndRestore(): temp file = [" + theFilename + "]");
}
catch (Exception ex) {
log.debug("OptionsSaveTest:testSaveAndRestore(): error creating temp file = [" +
ex.getMessage() + "]");
theFile = null;
}
if (theFile != null) {
// ---------------------------------------------------------
// save to the temporary file
// ---------------------------------------------------------
try {
// setup an output stream to a physical file
FileOutputStream outStream = new FileOutputStream(theFile);
// attach a stream capable of writing objects to the
// stream connected to the file
ObjectOutputStream outObjStream = new ObjectOutputStream(outStream);
// try to save the message context
log.debug("OptionsSaveTest:testSaveAndRestore(): saving .....");
saved = false;
outObjStream.writeObject(options);
// close out the streams
outObjStream.flush();
outObjStream.close();
outStream.flush();
outStream.close();
saved = true;
log.debug(
"OptionsSaveTest:testSaveAndRestore(): ....save operation completed.....");
long filesize = theFile.length();
log.debug("OptionsSaveTest:testSaveAndRestore(): file size after save [" +
filesize + "] temp file = [" + theFilename + "]");
}
catch (Exception ex2) {
if (saved != true) {
log.debug("OptionsSaveTest:testSaveAndRestore(): error during save [" +
ex2.getClass().getName() + " : " + ex2.getMessage() + "]");
ex2.printStackTrace();
} else {
log.debug("OptionsSaveTest:testSaveAndRestore(): error during restore [" +
ex2.getClass().getName() + " : " + ex2.getMessage() + "]");
ex2.printStackTrace();
}
}
assertTrue(saved);
// ---------------------------------------------------------
// restore from the temporary file
// ---------------------------------------------------------
try {
// setup an input stream to the file
FileInputStream inStream = new FileInputStream(theFile);
// attach a stream capable of reading objects from the
// stream connected to the file
ObjectInputStream inObjStream = new ObjectInputStream(inStream);
// try to restore the options
log.debug("OptionsSaveTest:testSaveAndRestore(): restoring .....");
restored = false;
Options options_restored = (Options) inObjStream.readObject();
inObjStream.close();
inStream.close();
options_restored.activate(configurationContext);
restored = true;
log.debug(
"OptionsSaveTest:testSaveAndRestore(): ....restored operation completed.....");
comparesOk = options_restored.isEquivalent(options);
log.debug("OptionsSaveTest:testSaveAndRestore(): Options equivalency [" +
comparesOk + "]");
}
catch (Exception ex2) {
log.debug("OptionsSaveTest:testSaveAndRestore(): error during restore [" +
ex2.getClass().getName() + " : " + ex2.getMessage() + "]");
ex2.printStackTrace();
}
assertTrue(restored);
assertTrue(comparesOk);
// if the save/restore of the object succeeded,
// then don't keep the temporary file around
boolean removeTmpFile = saved && restored && comparesOk;
if (removeTmpFile) {
try {
theFile.delete();
}
catch (Exception e) {
// just absorb it
}
}
// indicate that the temp file was created ok
done = true;
}
// this is false when there are problems with the temporary file
assertTrue(done);
log.debug("OptionsSaveTest:testSaveAndRestore(): END ---------------");
}
}