001: /**
002: * Licensed to the Apache Software Foundation (ASF) under one
003: * or more contributor license agreements. See the NOTICE file
004: * distributed with this work for additional information
005: * regarding copyright ownership. The ASF licenses this file
006: * to you under the Apache License, Version 2.0 (the
007: * "License"); you may not use this file except in compliance
008: * with the License. You may obtain a copy of the License at
009: *
010: * http://www.apache.org/licenses/LICENSE-2.0
011: *
012: * Unless required by applicable law or agreed to in writing,
013: * software distributed under the License is distributed on an
014: * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
015: * KIND, either express or implied. See the License for the
016: * specific language governing permissions and limitations
017: * under the License.
018: */package org.apache.cxf.systest.coloc;
019:
020: import java.util.ResourceBundle;
021:
022: import javax.xml.ws.Holder;
023:
024: import static junit.framework.Assert.assertEquals;
025:
026: import org.apache.commons.logging.Log;
027: import org.apache.cxf.common.i18n.Message;
028: import org.apache.cxf.interceptor.Fault;
029: import org.apache.headers.coloc.types.FaultDetailT;
030: import org.apache.headers.coloc.types.HeaderInfo;
031: import org.apache.headers.coloc.types.InHeaderResponseT;
032: import org.apache.headers.coloc.types.InHeaderT;
033: import org.apache.headers.coloc.types.InoutHeaderResponseT;
034: import org.apache.headers.coloc.types.InoutHeaderT;
035: import org.apache.headers.coloc.types.OutHeaderResponseT;
036: import org.apache.headers.coloc.types.OutHeaderT;
037: import org.apache.headers.coloc.types.PingMeResponseT;
038: import org.apache.headers.coloc.types.PingMeT;
039: import org.apache.headers.rpc_lit.HeaderTester;
040: import org.apache.headers.rpc_lit.PingMeFault;
041:
042: public class BaseHeaderTesterRpcLitImpl implements HeaderTester {
043: private Log logger;
044:
045: public InHeaderResponseT inHeader(InHeaderT in, HeaderInfo header) {
046: getLogger().debug("Server: inHeader called");
047: assertEquals(HeaderTesterUtil.IN_REQUEST_TYPE, in
048: .getRequestType());
049: assertEquals(HeaderTesterUtil.IN_MESSAGE, header.getMessage());
050: assertEquals(HeaderTesterUtil.IN_ORIGINATOR, header
051: .getOriginator());
052:
053: InHeaderResponseT inHeaderResponse = new InHeaderResponseT();
054: inHeaderResponse
055: .setResponseType(HeaderTesterUtil.OUT_RESPONSE_TYPE);
056: return inHeaderResponse;
057: }
058:
059: public InoutHeaderResponseT inoutHeader(InoutHeaderT in,
060: Holder<HeaderInfo> header) {
061: getLogger().debug("Server: inoutHeader called");
062: assertEquals(HeaderTesterUtil.INOUT_REQUEST_TYPE_IN, in
063: .getRequestType());
064: assertEquals(HeaderTesterUtil.INOUT_MESSAGE_IN, header.value
065: .getMessage());
066: assertEquals(HeaderTesterUtil.INOUT_ORIGINATOR_IN, header.value
067: .getOriginator());
068:
069: HeaderInfo out = new HeaderInfo();
070: out.setMessage(HeaderTesterUtil.INOUT_MESSAGE_OUT);
071: out.setOriginator(HeaderTesterUtil.INOUT_ORIGINATOR_OUT);
072: header.value = out;
073:
074: InoutHeaderResponseT inoutHeaderResponse = new InoutHeaderResponseT();
075: inoutHeaderResponse
076: .setResponseType(HeaderTesterUtil.INOUT_REQUEST_TYPE_OUT);
077: return inoutHeaderResponse;
078: }
079:
080: public void outHeader(OutHeaderT in,
081: Holder<OutHeaderResponseT> out, Holder<HeaderInfo> header) {
082: getLogger().debug("Server: outHeader called");
083: assertEquals(HeaderTesterUtil.OUT_REQUEST_TYPE, in
084: .getRequestType());
085:
086: HeaderInfo outHeader = new HeaderInfo();
087: outHeader.setMessage(HeaderTesterUtil.OUT_MESSAGE_OUT);
088: outHeader.setOriginator(HeaderTesterUtil.OUT_ORIGINATOR_OUT);
089: header.value = outHeader;
090:
091: OutHeaderResponseT resp = new OutHeaderResponseT();
092: resp.setResponseType(HeaderTesterUtil.OUT_RESPONSE_TYPE);
093: out.value = resp;
094: }
095:
096: public PingMeResponseT pingMe(PingMeT in) throws PingMeFault {
097: String msgType = in.getFaultType();
098: getLogger().debug("Server: in pingMe:" + msgType);
099: if ("USER".equals(msgType)) {
100:
101: FaultDetailT detail = new FaultDetailT();
102: detail.setMajor((short) 1);
103: detail.setMinor((short) 2);
104: throw new PingMeFault("USER FAULT TEST", detail);
105: } else if ("SYSTEM".equals(msgType)) {
106: throw new Fault(new Message(HeaderTesterUtil.EX_STRING,
107: (ResourceBundle) null,
108: new Object[] { "FAULT TEST" }));
109: } else if ("RUNTIME".equals(msgType)) {
110: throw new IllegalArgumentException(
111: HeaderTesterUtil.EX_STRING);
112: }
113:
114: return new PingMeResponseT();
115: }
116:
117: public void init(Log log) {
118: logger = log;
119: }
120:
121: protected Log getLogger() {
122: return logger;
123: }
124: }
|