[jbossws-commits] JBossWS SVN: r5127 - in stack/native/trunk/src/test: java/org/jboss/test/ws/jaxws/wsrm/oneway and 2 other directories.

Author: richard.opalka(a)jboss.com Date: 2007-11-28 06:47:54 -0500 (Wed, 28 Nov 2007) New Revision: 5127 Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/RMDeSerializationTestCase.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/RMOneWayTestCase.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/RMReqResTestCase.java stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMOneWayTestCase.properties stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMReqResTestCase.properties Removed: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/WSRMDeSerializationTestCase.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/ReqResTestCase.java stack/native/trunk/src/test/resources/jaxws/wsrm/properties/OneWayTestCase.properties stack/native/trunk/src/test/resources/jaxws/wsrm/properties/ReqResTestCase.properties Log: refactoring tests Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/RMDeSerializationTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/RMDeSerializationTestCase.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/RMDeSerializationTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -0,0 +1,577 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.wsrm.deserialization; + +import java.io.ByteArrayInputStream; +import java.util.List; + +import javax.xml.soap.SOAPMessage; + +import org.jboss.ws.extensions.wsrm.spi.RMProvider; +import org.jboss.ws.extensions.wsrm.spi.RMMessageFactory; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMAckRequested; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMCloseSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMCloseSequenceResponse; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMCreateSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMCreateSequenceResponse; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMIncompleteSequenceBehavior; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMSequenceAcknowledgement; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMSerializable; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMTerminateSequence; +import org.jboss.ws.extensions.wsrm.spi.protocol.RMTerminateSequenceResponse; +import org.jboss.wsf.test.JBossWSTest; + +/** + * WS-RM messages de/serialization test case + * @author richard.opalka(a)jboss.com + */ +public final class RMDeSerializationTestCase extends JBossWSTest +{ + private static final String WSRM_200702_NS = "http://docs.oasis-open.org/ws-rx/wsrm/200702"; + private static final RMMessageFactory WSRM_200702_FACTORY = RMProvider.getInstance(WSRM_200702_NS).getMessageFactory(); + + private static final String CREATE_SEQUENCE_MESSAGE + = "<soap:Envelope " + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:To>http://example.com/serviceB/123</wsa:To>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/CreateSequence... + + " <wsa:ReplyTo>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:ReplyTo>" + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:CreateSequence>" + + " <wsrm:AcksTo>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsrm:AcksTo>" + + " <wsrm:Expires>PT0S</wsrm:Expires>" + + " <wsrm:Offer>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:Endpoint>" + + " <wsa:Address>http://Business456.com/serviceA/ASDF</wsa:Address>&q... + + " </wsrm:Endpoint>" + + " <wsrm:Expires>PT1S</wsrm:Expires>" + + " <wsrm:IncompleteSequenceBehavior>DiscardEntireSequence</wsrm:IncompleteSequenceBehavior>" + + " </wsrm:Offer>" + + " </wsrm:CreateSequence>" + + " </soap:Body>" + + "</soap:Envelope>"; + + private static final String CREATE_SEQUENCE_RESPONSE_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" + + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/CreateSequence... + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:CreateSequenceResponse>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:Expires>PT0S</wsrm:Expires>" + + " <wsrm:IncompleteSequenceBehavior>DiscardFollowingFirstGap</wsrm:IncompleteSequenceBehavior>" + + " <wsrm:Accept>" + + " <wsrm:AcksTo>" + + " <wsa:Address>http://Business456.com/serviceA/ASDF</wsa:Address>&q... + + " </wsrm:AcksTo>" + + " </wsrm:Accept>" + + " </wsrm:CreateSequenceResponse>" + + " </soap:Body>" + + "</soap:Envelope>"; + + private static final String SEQUENCE_PLUS_ACKREQUESTED_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/71e0654e-5ce8-477b-bb9d</... + + " <wsa:To>http://example.com/serviceB/123</wsa:To>" + + " <wsa:From>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:From>" + + " <wsa:Action>http://example.com/serviceB/123/request</wsa:Action>&... + + " <wsrm:Sequence>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:MessageNumber>1</wsrm:MessageNumber>" + + " </wsrm:Sequence>" + + " <wsrm:AckRequested>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " </wsrm:AckRequested>" + + " </soap:Header>" + + " <soap:Body><!-- Some Application Data --></soap:Body>" + + "</soap:Envelope>"; + + private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1 + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... + + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" + + " <wsa:From>" + + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" + + " </wsa:From>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... + + " <wsrm:SequenceAcknowledgement>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:AcknowledgementRange Upper='1' Lower='1'/>" + + " <wsrm:AcknowledgementRange Upper='3' Lower='3'/>" + + " <wsrm:Final/>" + + " </wsrm:SequenceAcknowledgement>" + + " </soap:Header>" + + " <soap:Body/>" + + "</soap:Envelope>"; + + private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2 + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... + + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" + + " <wsa:From>" + + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" + + " </wsa:From>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... + + " <wsrm:SequenceAcknowledgement>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:Nack>2</wsrm:Nack>" + + " </wsrm:SequenceAcknowledgement>" + + " </soap:Header>" + + " <soap:Body/>" + + "</soap:Envelope>"; + + private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3 + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... + + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" + + " <wsa:From>" + + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" + + " </wsa:From>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... + + " <wsrm:SequenceAcknowledgement>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:None/>" + + " </wsrm:SequenceAcknowledgement>" + + " </soap:Header>" + + " <soap:Body/>" + + "</soap:Envelope>"; + + private static final String CLOSE_SEQUENCE_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:To>http://example.com/serviceB/123</wsa:To>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... + + " <wsa:From>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:From>" + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:CloseSequence>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:LastMsgNumber>3</wsrm:LastMsgNumber>" + + " </wsrm:CloseSequence>" + + " </soap:Body>" + + "</soap:Envelope>"; + + private static final String TERMINATE_SEQUENCE_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:To>http://example.com/serviceB/123</wsa:To>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... + + " <wsa:From>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:From>" + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:TerminateSequence>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " <wsrm:LastMsgNumber>3</wsrm:LastMsgNumber>" + + " </wsrm:TerminateSequence>" + + " </soap:Body>" + + "</soap:Envelope>"; + + private static final String CLOSE_SEQUENCE_RESPONSE_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:To>http://example.com/serviceA/789</wsa:To>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... + + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:From>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:From>" + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:CloseSequenceResponse>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " </wsrm:CloseSequenceResponse>" + + " </soap:Body>" + + "</soap:Envelope>"; + + private static final String TERMINATE_SEQUENCE_RESPONSE_MESSAGE + = "<soap:Envelope" + + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" + + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" + + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" + + " <soap:Header>" + + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:To>http://example.com/serviceA/789</wsa:To>" + + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... + + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... + + " <wsa:From>" + + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" + + " </wsa:From>" + + " </soap:Header>" + + " <soap:Body>" + + " <wsrm:TerminateSequenceResponse>" + + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... + + " </wsrm:TerminateSequenceResponse>" + + " </soap:Body>" + + "</soap:Envelope>"; + + public void testSequenceAcknowledgementDeserialization1() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1)); + // perform assertion + assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); + assertTrue(sequenceAcknowledgement.isFinal()); + assertFalse(sequenceAcknowledgement.isNone()); + assertEquals(sequenceAcknowledgement.getNacks().size(), 0); + List<RMSequenceAcknowledgement.AcknowledgementRange> ranges = sequenceAcknowledgement.getAcknowledgementRanges(); + assertEquals(ranges.size(), 2); + RMSequenceAcknowledgement.AcknowledgementRange firstRange = ranges.get(0); + assertEquals(firstRange.getLower(), 1); + assertEquals(firstRange.getLower(), 1); + RMSequenceAcknowledgement.AcknowledgementRange secondRange = ranges.get(1); + assertEquals(secondRange.getLower(), 3); + assertEquals(secondRange.getLower(), 3); + } + + public void testSequenceAcknowledgementSerialization1() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + // construct message + sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; + sequenceAcknowledgementMessage.setFinal(); + RMSequenceAcknowledgement.AcknowledgementRange firstRange = sequenceAcknowledgementMessage.newAcknowledgementRange(); + firstRange.setLower(1); + firstRange.setUpper(1); + sequenceAcknowledgementMessage.addAcknowledgementRange(firstRange); + RMSequenceAcknowledgement.AcknowledgementRange secondRange = sequenceAcknowledgementMessage.newAcknowledgementRange(); + secondRange.setLower(3); + secondRange.setUpper(3); + sequenceAcknowledgementMessage.addAcknowledgementRange(secondRange); + // perform assertion + assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1, WSRM_200702_FACTORY); + } + + public void testSequenceAcknowledgementDeserialization2() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2)); + // perform assertion + assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); + assertFalse(sequenceAcknowledgement.isFinal()); + assertFalse(sequenceAcknowledgement.isNone()); + assertEquals(sequenceAcknowledgement.getAcknowledgementRanges().size(), 0); + List<Long> nacks = sequenceAcknowledgement.getNacks(); + assertEquals(nacks.size(), 1); + assertEquals(nacks.get(0).longValue(), 2); + } + + public void testSequenceAcknowledgementSerialization2() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + // construct message + sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; + sequenceAcknowledgementMessage.addNack(2); + // perform assertion + assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2, WSRM_200702_FACTORY); + } + + public void testSequenceAcknowledgementDeserialization3() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3)); + // perform assertion + assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); + assertFalse(sequenceAcknowledgement.isFinal()); + assertTrue(sequenceAcknowledgement.isNone()); + assertEquals(sequenceAcknowledgement.getAcknowledgementRanges().size(), 0); + assertEquals(sequenceAcknowledgement.getNacks().size(), 0); + } + + public void testSequenceAcknowledgementSerialization3() throws Exception + { + RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); + // construct message + sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; + sequenceAcknowledgementMessage.setNone(); + // perform assertion + assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3, WSRM_200702_FACTORY); + } + + public void testCreateSequenceMessageDeserialization() throws Exception + { + RMCreateSequence createSequenceMessage = WSRM_200702_FACTORY.newCreateSequence(); + createSequenceMessage.deserializeFrom(toSOAPMessage(CREATE_SEQUENCE_MESSAGE)); + // perform assertion + assertEquals(createSequenceMessage.getAcksTo(), "http://Business456.com/serviceA/789"); + assertEquals(createSequenceMessage.getExpires(), "PT0S"); + RMCreateSequence.Offer offer = createSequenceMessage.getOffer(); + assertEquals(offer.getIdentifier(), "http://Business456.com/RM/ABC"); + assertEquals(offer.getEndpoint(), "http://Business456.com/serviceA/ASDF"); + assertEquals(offer.getExpires(), "PT1S"); + assertEquals(offer.getIncompleteSequenceBehavior(), RMIncompleteSequenceBehavior.DISCARD_ENTIRE_SEQUENCE); + } + + public void testCreateSequenceMessageSerialization() throws Exception + { + RMCreateSequence createSequenceMessage = WSRM_200702_FACTORY.newCreateSequence(); + // construct message + createSequenceMessage.setAcksTo("http://Business456.com/serviceA/789...; + createSequenceMessage.setExpires("PT0S"); + RMCreateSequence.Offer offer = createSequenceMessage.newOffer(); + offer.setIdentifier("http://Business456.com/RM/ABC"); + offer.setEndpoint("http://Business456.com/serviceA/ASDF"); + offer.setExpires("PT1S"); + offer.setIncompleteSequenceBehavior(RMIncompleteSequenceBehavior.DISCARD_ENTIRE_SEQUENCE); + createSequenceMessage.setOffer(offer); + // perform assertion + assertEquals(createSequenceMessage, CREATE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testCreateSequenceResponseMessageDeserialization() throws Exception + { + RMCreateSequenceResponse createSequenceResponseMessage = WSRM_200702_FACTORY.newCreateSequenceResponse(); + createSequenceResponseMessage.deserializeFrom(toSOAPMessage(CREATE_SEQUENCE_RESPONSE_MESSAGE)); + // perform assertion + assertEquals(createSequenceResponseMessage.getIdentifier(), "http://Business456.com/RM/ABC"); + assertEquals(createSequenceResponseMessage.getExpires(), "PT0S"); + assertEquals(createSequenceResponseMessage.getIncompleteSequenceBehavior(), RMIncompleteSequenceBehavior.DISCARD_FOLLOWING_FIRST_GAP); + RMCreateSequenceResponse.Accept accept = createSequenceResponseMessage.getAccept(); + assertEquals(accept.getAcksTo(), "http://Business456.com/serviceA/ASDF"); + } + + public void testCreateSequenceResponseMessageSerialization() throws Exception + { + RMCreateSequenceResponse createSequenceResponse = WSRM_200702_FACTORY.newCreateSequenceResponse(); + // construct message + createSequenceResponse.setIdentifier("http://Business456.com/RM/ABC&...; + createSequenceResponse.setExpires("PT0S"); + createSequenceResponse.setIncompleteSequenceBehavior(RMIncompleteSequenceBehavior.DISCARD_FOLLOWING_FIRST_GAP); + RMCreateSequenceResponse.Accept accept = createSequenceResponse.newAccept(); + accept.setAcksTo("http://Business456.com/serviceA/ASDF"); + createSequenceResponse.setAccept(accept); + // perform assertion + assertEquals(createSequenceResponse, CREATE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testCloseSequenceMessageDeserialization() throws Exception + { + RMCloseSequence closeSequence = WSRM_200702_FACTORY.newCloseSequence(); + closeSequence.deserializeFrom(toSOAPMessage(CLOSE_SEQUENCE_MESSAGE)); + // perform assertion + assertEquals(closeSequence.getIdentifier(), "http://Business456.com/RM/ABC"); + assertEquals(closeSequence.getLastMsgNumber(), 3); + } + + public void testCloseSequenceMessageSerialization() throws Exception + { + RMCloseSequence closeSequence = WSRM_200702_FACTORY.newCloseSequence(); + // construct message + closeSequence.setIdentifier("http://Business456.com/RM/ABC"); + closeSequence.setLastMsgNumber(3); + // perform assertion + assertEquals(closeSequence, CLOSE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testCloseSequenceResponseMessageDeserialization() throws Exception + { + RMCloseSequenceResponse closeSequenceResponse = WSRM_200702_FACTORY.newCloseSequenceResponse(); + closeSequenceResponse.deserializeFrom(toSOAPMessage(CLOSE_SEQUENCE_RESPONSE_MESSAGE)); + // perform assertion + assertEquals(closeSequenceResponse.getIdentifier(), "http://Business456.com/RM/ABC"); + } + + public void testCloseSequenceResponseMessageSerialization() throws Exception + { + RMCloseSequenceResponse closeSequenceResponse = WSRM_200702_FACTORY.newCloseSequenceResponse(); + // construct message + closeSequenceResponse.setIdentifier("http://Business456.com/RM/ABC&q...; + // perform assertion + assertEquals(closeSequenceResponse, CLOSE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testTerminateSequenceMessageDeserialization() throws Exception + { + RMTerminateSequence terminateSequence = WSRM_200702_FACTORY.newTerminateSequence(); + terminateSequence.deserializeFrom(toSOAPMessage(TERMINATE_SEQUENCE_MESSAGE)); + // perform assertion + assertEquals(terminateSequence.getIdentifier(), "http://Business456.com/RM/ABC"); + assertEquals(terminateSequence.getLastMsgNumber(), 3); + } + + public void testTerminateSequenceMessageSerialization() throws Exception + { + RMTerminateSequence terminateSequence = WSRM_200702_FACTORY.newTerminateSequence(); + // construct message + terminateSequence.setIdentifier("http://Business456.com/RM/ABC"); + terminateSequence.setLastMsgNumber(3); + // perform assertion + assertEquals(terminateSequence, TERMINATE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testTerminateSequenceResponseMessageDeserialization() throws Exception + { + RMTerminateSequenceResponse terminateSequenceResponse = WSRM_200702_FACTORY.newTerminateSequenceResponse(); + terminateSequenceResponse.deserializeFrom(toSOAPMessage(TERMINATE_SEQUENCE_RESPONSE_MESSAGE)); + // perform assertion + assertEquals(terminateSequenceResponse.getIdentifier(), "http://Business456.com/RM/ABC"); + } + + public void testTerminateSequenceResponseMessageSerialization() throws Exception + { + RMTerminateSequenceResponse terminateSequenceResponse = WSRM_200702_FACTORY.newTerminateSequenceResponse(); + // construct message + terminateSequenceResponse.setIdentifier("http://Business456.com/RM/A...; + // perform assertion + assertEquals(terminateSequenceResponse, TERMINATE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); + } + + public void testSequenceMessageSerialization() throws Exception + { + RMSequence sequence = WSRM_200702_FACTORY.newSequence(); + sequence.deserializeFrom(toSOAPMessage(SEQUENCE_PLUS_ACKREQUESTED_MESSAGE)); + // perform assertion + assertEquals(sequence.getIdentifier(), "http://Business456.com/RM/ABC"); + assertEquals(sequence.getMessageNumber(), 1); + } + + public void testSequenceMessageDeserialization() throws Exception + { + RMSequence sequence = WSRM_200702_FACTORY.newSequence(); + // construct message + sequence.setIdentifier("http://Business456.com/RM/ABC"); + sequence.setMessageNumber(1); + // perform assertion + assertEquals(sequence, SEQUENCE_PLUS_ACKREQUESTED_MESSAGE, WSRM_200702_FACTORY); + } + + public void testAckRequestedMessageSerialization() throws Exception + { + RMAckRequested ackRequested = WSRM_200702_FACTORY.newAckRequested(); + ackRequested.deserializeFrom(toSOAPMessage(SEQUENCE_PLUS_ACKREQUESTED_MESSAGE)); + // perform assertion + assertEquals(ackRequested.getIdentifier(), "http://Business456.com/RM/ABC"); + } + + public void testAckRequestedMessageDeserialization() throws Exception + { + RMAckRequested ackRequested = WSRM_200702_FACTORY.newAckRequested(); + // construct message + ackRequested.setIdentifier("http://Business456.com/RM/ABC"); + // perform assertion + assertEquals(ackRequested, SEQUENCE_PLUS_ACKREQUESTED_MESSAGE, WSRM_200702_FACTORY); + } + + // TODO: implement other de/serializations + + private static void assertEquals(RMSerializable serializable, String exemplar, RMMessageFactory factory) throws Exception + { + // serialize constructed message + SOAPMessage createdSOAPMessage = newEmptySOAPMessage(); + serializable.serializeTo(createdSOAPMessage); + // deserialize from constructed message + RMSerializable serializable1 = newEmptySerializable(factory, serializable); + serializable1.deserializeFrom(createdSOAPMessage); + // deserialize from reference message + RMSerializable serializable2 = newEmptySerializable(factory, serializable); + serializable2.deserializeFrom(toSOAPMessage(exemplar)); + // perform assertion + assertEquals(serializable1, serializable2); + } + + private static RMSerializable newEmptySerializable(RMMessageFactory factory, RMSerializable helper) + { + if (helper instanceof RMCreateSequence) + return factory.newCreateSequence(); + if (helper instanceof RMCreateSequenceResponse) + return factory.newCreateSequenceResponse(); + if (helper instanceof RMCloseSequence) + return factory.newCloseSequence(); + if (helper instanceof RMCloseSequenceResponse) + return factory.newCloseSequenceResponse(); + if (helper instanceof RMTerminateSequence) + return factory.newTerminateSequence(); + if (helper instanceof RMTerminateSequenceResponse) + return factory.newTerminateSequenceResponse(); + if (helper instanceof RMSequence) + return factory.newSequence(); + if (helper instanceof RMAckRequested) + return factory.newAckRequested(); + if (helper instanceof RMSequenceAcknowledgement) + return factory.newSequenceAcknowledgement(); + + throw new IllegalArgumentException(); + } + + private static SOAPMessage toSOAPMessage(String data) throws Exception + { + javax.xml.soap.MessageFactory factory = javax.xml.soap.MessageFactory.newInstance(); + return factory.createMessage(null, new ByteArrayInputStream(data.getBytes())); + } + + private static SOAPMessage newEmptySOAPMessage() throws Exception + { + javax.xml.soap.MessageFactory factory = javax.xml.soap.MessageFactory.newInstance(); + return factory.createMessage(); + } + +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/RMDeSerializationTestCase.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Deleted: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/WSRMDeSerializationTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/WSRMDeSerializationTestCase.java 2007-11-28 11:19:31 UTC (rev 5126) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/deserialization/WSRMDeSerializationTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -1,577 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005, JBoss Inc., and individual contributors as indicated - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.test.ws.jaxws.wsrm.deserialization; - -import java.io.ByteArrayInputStream; -import java.util.List; - -import javax.xml.soap.SOAPMessage; - -import org.jboss.ws.extensions.wsrm.spi.RMProvider; -import org.jboss.ws.extensions.wsrm.spi.RMMessageFactory; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMAckRequested; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMCloseSequence; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMCloseSequenceResponse; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMCreateSequence; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMCreateSequenceResponse; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMIncompleteSequenceBehavior; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMSequence; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMSequenceAcknowledgement; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMSerializable; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMTerminateSequence; -import org.jboss.ws.extensions.wsrm.spi.protocol.RMTerminateSequenceResponse; -import org.jboss.wsf.test.JBossWSTest; - -/** - * WS-RM messages de/serialization test case - * @author richard.opalka(a)jboss.com - */ -public final class WSRMDeSerializationTestCase extends JBossWSTest -{ - private static final String WSRM_200702_NS = "http://docs.oasis-open.org/ws-rx/wsrm/200702"; - private static final RMMessageFactory WSRM_200702_FACTORY = RMProvider.getInstance(WSRM_200702_NS).getMessageFactory(); - - private static final String CREATE_SEQUENCE_MESSAGE - = "<soap:Envelope " - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:To>http://example.com/serviceB/123</wsa:To>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/CreateSequence... - + " <wsa:ReplyTo>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:ReplyTo>" - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:CreateSequence>" - + " <wsrm:AcksTo>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsrm:AcksTo>" - + " <wsrm:Expires>PT0S</wsrm:Expires>" - + " <wsrm:Offer>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:Endpoint>" - + " <wsa:Address>http://Business456.com/serviceA/ASDF</wsa:Address>&q... - + " </wsrm:Endpoint>" - + " <wsrm:Expires>PT1S</wsrm:Expires>" - + " <wsrm:IncompleteSequenceBehavior>DiscardEntireSequence</wsrm:IncompleteSequenceBehavior>" - + " </wsrm:Offer>" - + " </wsrm:CreateSequence>" - + " </soap:Body>" - + "</soap:Envelope>"; - - private static final String CREATE_SEQUENCE_RESPONSE_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" - + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/CreateSequence... - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:CreateSequenceResponse>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:Expires>PT0S</wsrm:Expires>" - + " <wsrm:IncompleteSequenceBehavior>DiscardFollowingFirstGap</wsrm:IncompleteSequenceBehavior>" - + " <wsrm:Accept>" - + " <wsrm:AcksTo>" - + " <wsa:Address>http://Business456.com/serviceA/ASDF</wsa:Address>&q... - + " </wsrm:AcksTo>" - + " </wsrm:Accept>" - + " </wsrm:CreateSequenceResponse>" - + " </soap:Body>" - + "</soap:Envelope>"; - - private static final String SEQUENCE_PLUS_ACKREQUESTED_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/71e0654e-5ce8-477b-bb9d</... - + " <wsa:To>http://example.com/serviceB/123</wsa:To>" - + " <wsa:From>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:From>" - + " <wsa:Action>http://example.com/serviceB/123/request</wsa:Action>&... - + " <wsrm:Sequence>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:MessageNumber>1</wsrm:MessageNumber>" - + " </wsrm:Sequence>" - + " <wsrm:AckRequested>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " </wsrm:AckRequested>" - + " </soap:Header>" - + " <soap:Body><!-- Some Application Data --></soap:Body>" - + "</soap:Envelope>"; - - private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1 - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... - + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" - + " <wsa:From>" - + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" - + " </wsa:From>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... - + " <wsrm:SequenceAcknowledgement>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:AcknowledgementRange Upper='1' Lower='1'/>" - + " <wsrm:AcknowledgementRange Upper='3' Lower='3'/>" - + " <wsrm:Final/>" - + " </wsrm:SequenceAcknowledgement>" - + " </soap:Header>" - + " <soap:Body/>" - + "</soap:Envelope>"; - - private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2 - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... - + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" - + " <wsa:From>" - + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" - + " </wsa:From>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... - + " <wsrm:SequenceAcknowledgement>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:Nack>2</wsrm:Nack>" - + " </wsrm:SequenceAcknowledgement>" - + " </soap:Header>" - + " <soap:Body/>" - + "</soap:Envelope>"; - - private static final String SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3 - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://example.com/guid/0baaf88d-483b-4ecf-a6d8</wsa:... - + " <wsa:To>http://Business456.com/serviceA/789</wsa:To>" - + " <wsa:From>" - + " <wsa:Address>http://example.com/serviceB/123</wsa:Address>" - + " </wsa:From>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/SequenceAcknow... - + " <wsrm:SequenceAcknowledgement>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:None/>" - + " </wsrm:SequenceAcknowledgement>" - + " </soap:Header>" - + " <soap:Body/>" - + "</soap:Envelope>"; - - private static final String CLOSE_SEQUENCE_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:To>http://example.com/serviceB/123</wsa:To>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... - + " <wsa:From>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:From>" - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:CloseSequence>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:LastMsgNumber>3</wsrm:LastMsgNumber>" - + " </wsrm:CloseSequence>" - + " </soap:Body>" - + "</soap:Envelope>"; - - private static final String TERMINATE_SEQUENCE_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:To>http://example.com/serviceB/123</wsa:To>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... - + " <wsa:From>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:From>" - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:TerminateSequence>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " <wsrm:LastMsgNumber>3</wsrm:LastMsgNumber>" - + " </wsrm:TerminateSequence>" - + " </soap:Body>" - + "</soap:Envelope>"; - - private static final String CLOSE_SEQUENCE_RESPONSE_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:To>http://example.com/serviceA/789</wsa:To>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... - + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:From>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:From>" - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:CloseSequenceResponse>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " </wsrm:CloseSequenceResponse>" - + " </soap:Body>" - + "</soap:Envelope>"; - - private static final String TERMINATE_SEQUENCE_RESPONSE_MESSAGE - = "<soap:Envelope" - + " xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\"" - + " xmlns:wsrm=\"http://docs.oasis-open.org/ws-rx/wsrm/200702\"" - + " xmlns:wsa=\"http://www.w3.org/2005/08/addressing\">" - + " <soap:Header>" - + " <wsa:MessageID>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:To>http://example.com/serviceA/789</wsa:To>" - + " <wsa:Action>http://docs.oasis-open.org/ws-rx/wsrm/200702/TerminateSeque... - + " <wsa:RelatesTo>http://Business456.com/guid/0baaf88d-483b-4ecf-a6d8</... - + " <wsa:From>" - + " <wsa:Address>http://Business456.com/serviceA/789</wsa:Address>" - + " </wsa:From>" - + " </soap:Header>" - + " <soap:Body>" - + " <wsrm:TerminateSequenceResponse>" - + " <wsrm:Identifier>http://Business456.com/RM/ABC</wsrm:Identifier>&... - + " </wsrm:TerminateSequenceResponse>" - + " </soap:Body>" - + "</soap:Envelope>"; - - public void testSequenceAcknowledgementDeserialization1() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1)); - // perform assertion - assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); - assertTrue(sequenceAcknowledgement.isFinal()); - assertFalse(sequenceAcknowledgement.isNone()); - assertEquals(sequenceAcknowledgement.getNacks().size(), 0); - List<RMSequenceAcknowledgement.AcknowledgementRange> ranges = sequenceAcknowledgement.getAcknowledgementRanges(); - assertEquals(ranges.size(), 2); - RMSequenceAcknowledgement.AcknowledgementRange firstRange = ranges.get(0); - assertEquals(firstRange.getLower(), 1); - assertEquals(firstRange.getLower(), 1); - RMSequenceAcknowledgement.AcknowledgementRange secondRange = ranges.get(1); - assertEquals(secondRange.getLower(), 3); - assertEquals(secondRange.getLower(), 3); - } - - public void testSequenceAcknowledgementSerialization1() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - // construct message - sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; - sequenceAcknowledgementMessage.setFinal(); - RMSequenceAcknowledgement.AcknowledgementRange firstRange = sequenceAcknowledgementMessage.newAcknowledgementRange(); - firstRange.setLower(1); - firstRange.setUpper(1); - sequenceAcknowledgementMessage.addAcknowledgementRange(firstRange); - RMSequenceAcknowledgement.AcknowledgementRange secondRange = sequenceAcknowledgementMessage.newAcknowledgementRange(); - secondRange.setLower(3); - secondRange.setUpper(3); - sequenceAcknowledgementMessage.addAcknowledgementRange(secondRange); - // perform assertion - assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_1, WSRM_200702_FACTORY); - } - - public void testSequenceAcknowledgementDeserialization2() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2)); - // perform assertion - assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); - assertFalse(sequenceAcknowledgement.isFinal()); - assertFalse(sequenceAcknowledgement.isNone()); - assertEquals(sequenceAcknowledgement.getAcknowledgementRanges().size(), 0); - List<Long> nacks = sequenceAcknowledgement.getNacks(); - assertEquals(nacks.size(), 1); - assertEquals(nacks.get(0).longValue(), 2); - } - - public void testSequenceAcknowledgementSerialization2() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - // construct message - sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; - sequenceAcknowledgementMessage.addNack(2); - // perform assertion - assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_2, WSRM_200702_FACTORY); - } - - public void testSequenceAcknowledgementDeserialization3() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgement = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - sequenceAcknowledgement.deserializeFrom(toSOAPMessage(SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3)); - // perform assertion - assertEquals(sequenceAcknowledgement.getIdentifier(), "http://Business456.com/RM/ABC"); - assertFalse(sequenceAcknowledgement.isFinal()); - assertTrue(sequenceAcknowledgement.isNone()); - assertEquals(sequenceAcknowledgement.getAcknowledgementRanges().size(), 0); - assertEquals(sequenceAcknowledgement.getNacks().size(), 0); - } - - public void testSequenceAcknowledgementSerialization3() throws Exception - { - RMSequenceAcknowledgement sequenceAcknowledgementMessage = WSRM_200702_FACTORY.newSequenceAcknowledgement(); - // construct message - sequenceAcknowledgementMessage.setIdentifier("http://Business456.com...; - sequenceAcknowledgementMessage.setNone(); - // perform assertion - assertEquals(sequenceAcknowledgementMessage, SEQUENCE_ACKNOWLEDGEMENT_MESSAGE_3, WSRM_200702_FACTORY); - } - - public void testCreateSequenceMessageDeserialization() throws Exception - { - RMCreateSequence createSequenceMessage = WSRM_200702_FACTORY.newCreateSequence(); - createSequenceMessage.deserializeFrom(toSOAPMessage(CREATE_SEQUENCE_MESSAGE)); - // perform assertion - assertEquals(createSequenceMessage.getAcksTo(), "http://Business456.com/serviceA/789"); - assertEquals(createSequenceMessage.getExpires(), "PT0S"); - RMCreateSequence.Offer offer = createSequenceMessage.getOffer(); - assertEquals(offer.getIdentifier(), "http://Business456.com/RM/ABC"); - assertEquals(offer.getEndpoint(), "http://Business456.com/serviceA/ASDF"); - assertEquals(offer.getExpires(), "PT1S"); - assertEquals(offer.getIncompleteSequenceBehavior(), RMIncompleteSequenceBehavior.DISCARD_ENTIRE_SEQUENCE); - } - - public void testCreateSequenceMessageSerialization() throws Exception - { - RMCreateSequence createSequenceMessage = WSRM_200702_FACTORY.newCreateSequence(); - // construct message - createSequenceMessage.setAcksTo("http://Business456.com/serviceA/789...; - createSequenceMessage.setExpires("PT0S"); - RMCreateSequence.Offer offer = createSequenceMessage.newOffer(); - offer.setIdentifier("http://Business456.com/RM/ABC"); - offer.setEndpoint("http://Business456.com/serviceA/ASDF"); - offer.setExpires("PT1S"); - offer.setIncompleteSequenceBehavior(RMIncompleteSequenceBehavior.DISCARD_ENTIRE_SEQUENCE); - createSequenceMessage.setOffer(offer); - // perform assertion - assertEquals(createSequenceMessage, CREATE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testCreateSequenceResponseMessageDeserialization() throws Exception - { - RMCreateSequenceResponse createSequenceResponseMessage = WSRM_200702_FACTORY.newCreateSequenceResponse(); - createSequenceResponseMessage.deserializeFrom(toSOAPMessage(CREATE_SEQUENCE_RESPONSE_MESSAGE)); - // perform assertion - assertEquals(createSequenceResponseMessage.getIdentifier(), "http://Business456.com/RM/ABC"); - assertEquals(createSequenceResponseMessage.getExpires(), "PT0S"); - assertEquals(createSequenceResponseMessage.getIncompleteSequenceBehavior(), RMIncompleteSequenceBehavior.DISCARD_FOLLOWING_FIRST_GAP); - RMCreateSequenceResponse.Accept accept = createSequenceResponseMessage.getAccept(); - assertEquals(accept.getAcksTo(), "http://Business456.com/serviceA/ASDF"); - } - - public void testCreateSequenceResponseMessageSerialization() throws Exception - { - RMCreateSequenceResponse createSequenceResponse = WSRM_200702_FACTORY.newCreateSequenceResponse(); - // construct message - createSequenceResponse.setIdentifier("http://Business456.com/RM/ABC&...; - createSequenceResponse.setExpires("PT0S"); - createSequenceResponse.setIncompleteSequenceBehavior(RMIncompleteSequenceBehavior.DISCARD_FOLLOWING_FIRST_GAP); - RMCreateSequenceResponse.Accept accept = createSequenceResponse.newAccept(); - accept.setAcksTo("http://Business456.com/serviceA/ASDF"); - createSequenceResponse.setAccept(accept); - // perform assertion - assertEquals(createSequenceResponse, CREATE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testCloseSequenceMessageDeserialization() throws Exception - { - RMCloseSequence closeSequence = WSRM_200702_FACTORY.newCloseSequence(); - closeSequence.deserializeFrom(toSOAPMessage(CLOSE_SEQUENCE_MESSAGE)); - // perform assertion - assertEquals(closeSequence.getIdentifier(), "http://Business456.com/RM/ABC"); - assertEquals(closeSequence.getLastMsgNumber(), 3); - } - - public void testCloseSequenceMessageSerialization() throws Exception - { - RMCloseSequence closeSequence = WSRM_200702_FACTORY.newCloseSequence(); - // construct message - closeSequence.setIdentifier("http://Business456.com/RM/ABC"); - closeSequence.setLastMsgNumber(3); - // perform assertion - assertEquals(closeSequence, CLOSE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testCloseSequenceResponseMessageDeserialization() throws Exception - { - RMCloseSequenceResponse closeSequenceResponse = WSRM_200702_FACTORY.newCloseSequenceResponse(); - closeSequenceResponse.deserializeFrom(toSOAPMessage(CLOSE_SEQUENCE_RESPONSE_MESSAGE)); - // perform assertion - assertEquals(closeSequenceResponse.getIdentifier(), "http://Business456.com/RM/ABC"); - } - - public void testCloseSequenceResponseMessageSerialization() throws Exception - { - RMCloseSequenceResponse closeSequenceResponse = WSRM_200702_FACTORY.newCloseSequenceResponse(); - // construct message - closeSequenceResponse.setIdentifier("http://Business456.com/RM/ABC&q...; - // perform assertion - assertEquals(closeSequenceResponse, CLOSE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testTerminateSequenceMessageDeserialization() throws Exception - { - RMTerminateSequence terminateSequence = WSRM_200702_FACTORY.newTerminateSequence(); - terminateSequence.deserializeFrom(toSOAPMessage(TERMINATE_SEQUENCE_MESSAGE)); - // perform assertion - assertEquals(terminateSequence.getIdentifier(), "http://Business456.com/RM/ABC"); - assertEquals(terminateSequence.getLastMsgNumber(), 3); - } - - public void testTerminateSequenceMessageSerialization() throws Exception - { - RMTerminateSequence terminateSequence = WSRM_200702_FACTORY.newTerminateSequence(); - // construct message - terminateSequence.setIdentifier("http://Business456.com/RM/ABC"); - terminateSequence.setLastMsgNumber(3); - // perform assertion - assertEquals(terminateSequence, TERMINATE_SEQUENCE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testTerminateSequenceResponseMessageDeserialization() throws Exception - { - RMTerminateSequenceResponse terminateSequenceResponse = WSRM_200702_FACTORY.newTerminateSequenceResponse(); - terminateSequenceResponse.deserializeFrom(toSOAPMessage(TERMINATE_SEQUENCE_RESPONSE_MESSAGE)); - // perform assertion - assertEquals(terminateSequenceResponse.getIdentifier(), "http://Business456.com/RM/ABC"); - } - - public void testTerminateSequenceResponseMessageSerialization() throws Exception - { - RMTerminateSequenceResponse terminateSequenceResponse = WSRM_200702_FACTORY.newTerminateSequenceResponse(); - // construct message - terminateSequenceResponse.setIdentifier("http://Business456.com/RM/A...; - // perform assertion - assertEquals(terminateSequenceResponse, TERMINATE_SEQUENCE_RESPONSE_MESSAGE, WSRM_200702_FACTORY); - } - - public void testSequenceMessageSerialization() throws Exception - { - RMSequence sequence = WSRM_200702_FACTORY.newSequence(); - sequence.deserializeFrom(toSOAPMessage(SEQUENCE_PLUS_ACKREQUESTED_MESSAGE)); - // perform assertion - assertEquals(sequence.getIdentifier(), "http://Business456.com/RM/ABC"); - assertEquals(sequence.getMessageNumber(), 1); - } - - public void testSequenceMessageDeserialization() throws Exception - { - RMSequence sequence = WSRM_200702_FACTORY.newSequence(); - // construct message - sequence.setIdentifier("http://Business456.com/RM/ABC"); - sequence.setMessageNumber(1); - // perform assertion - assertEquals(sequence, SEQUENCE_PLUS_ACKREQUESTED_MESSAGE, WSRM_200702_FACTORY); - } - - public void testAckRequestedMessageSerialization() throws Exception - { - RMAckRequested ackRequested = WSRM_200702_FACTORY.newAckRequested(); - ackRequested.deserializeFrom(toSOAPMessage(SEQUENCE_PLUS_ACKREQUESTED_MESSAGE)); - // perform assertion - assertEquals(ackRequested.getIdentifier(), "http://Business456.com/RM/ABC"); - } - - public void testAckRequestedMessageDeserialization() throws Exception - { - RMAckRequested ackRequested = WSRM_200702_FACTORY.newAckRequested(); - // construct message - ackRequested.setIdentifier("http://Business456.com/RM/ABC"); - // perform assertion - assertEquals(ackRequested, SEQUENCE_PLUS_ACKREQUESTED_MESSAGE, WSRM_200702_FACTORY); - } - - // TODO: implement other de/serializations - - private static void assertEquals(RMSerializable serializable, String exemplar, RMMessageFactory factory) throws Exception - { - // serialize constructed message - SOAPMessage createdSOAPMessage = newEmptySOAPMessage(); - serializable.serializeTo(createdSOAPMessage); - // deserialize from constructed message - RMSerializable serializable1 = newEmptySerializable(factory, serializable); - serializable1.deserializeFrom(createdSOAPMessage); - // deserialize from reference message - RMSerializable serializable2 = newEmptySerializable(factory, serializable); - serializable2.deserializeFrom(toSOAPMessage(exemplar)); - // perform assertion - assertEquals(serializable1, serializable2); - } - - private static RMSerializable newEmptySerializable(RMMessageFactory factory, RMSerializable helper) - { - if (helper instanceof RMCreateSequence) - return factory.newCreateSequence(); - if (helper instanceof RMCreateSequenceResponse) - return factory.newCreateSequenceResponse(); - if (helper instanceof RMCloseSequence) - return factory.newCloseSequence(); - if (helper instanceof RMCloseSequenceResponse) - return factory.newCloseSequenceResponse(); - if (helper instanceof RMTerminateSequence) - return factory.newTerminateSequence(); - if (helper instanceof RMTerminateSequenceResponse) - return factory.newTerminateSequenceResponse(); - if (helper instanceof RMSequence) - return factory.newSequence(); - if (helper instanceof RMAckRequested) - return factory.newAckRequested(); - if (helper instanceof RMSequenceAcknowledgement) - return factory.newSequenceAcknowledgement(); - - throw new IllegalArgumentException(); - } - - private static SOAPMessage toSOAPMessage(String data) throws Exception - { - javax.xml.soap.MessageFactory factory = javax.xml.soap.MessageFactory.newInstance(); - return factory.createMessage(null, new ByteArrayInputStream(data.getBytes())); - } - - private static SOAPMessage newEmptySOAPMessage() throws Exception - { - javax.xml.soap.MessageFactory factory = javax.xml.soap.MessageFactory.newInstance(); - return factory.createMessage(); - } - -} Deleted: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java 2007-11-28 11:19:31 UTC (rev 5126) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/OneWayTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -1,118 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005, JBoss Inc., and individual contributors as indicated - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.test.ws.jaxws.wsrm.oneway; - -import static org.jboss.test.ws.jaxws.wsrm.Helper.*; - -import java.io.File; -import java.io.FileInputStream; -import java.io.IOException; -import java.net.URL; -import java.util.Properties; -import java.util.concurrent.TimeUnit; - -import javax.xml.namespace.QName; -import javax.xml.ws.BindingProvider; -import javax.xml.ws.Service; - -import junit.framework.Test; - -import org.jboss.ws.extensions.wsrm.api.RMProvider; -import org.jboss.ws.extensions.wsrm.api.RMSequence; -import org.jboss.wsf.test.JBossWSTest; -import org.jboss.wsf.test.JBossWSTestSetup; -import org.jboss.test.ws.jaxws.wsrm.OneWayServiceIface; - -/** - * Reliable JBoss WebService client invoking one way methods - * - * @author richard.opalka(a)jboss.com - * @since 22-Aug-2007 - */ -public class OneWayTestCase extends JBossWSTest -{ - private static final Properties props = new Properties(); - private String targetNS = "http://wsrm.jaxws.ws.test.jboss.org/"; - private OneWayServiceIface proxy; - private final boolean emulatorOn = Boolean.parseBoolean((String)props.get("emulator")); - private final boolean addressable = Boolean.parseBoolean((String)props.get("addressable")); - private final String serviceURL = "http://" + getServerHost() + ":" + props.getProperty("port") + props.getProperty("path"); - - static - { - // load test properties - File propertiesFile = new File("resources/jaxws/wsrm/properties/OneWayTestCase.properties"); - try - { - props.load(new FileInputStream(propertiesFile)); - } - catch (IOException ignore) - { - ignore.printStackTrace(); - } - } - - public static Test suite() - { - return new JBossWSTestSetup(OneWayTestCase.class, props.getProperty("archives")); - } - - @Override - protected void setUp() throws Exception - { - super.setUp(); - QName serviceName = new QName(targetNS, "OneWayService"); - URL wsdlURL = new URL(serviceURL + "?wsdl"); - Service service = Service.create(wsdlURL, serviceName); - proxy = (OneWayServiceIface)service.getPort(OneWayServiceIface.class); - } - - public void testOneWayMethods() throws Exception - { - System.out.println("FIXME [JBWS-515] Provide an initial implementation for WS-ReliableMessaging"); - System.out.println("FIXME [JBWS-1699] Implement the basic message exchange that is required for WS-RM"); - System.out.println("FIXME [JBWS-1700] Provide a comprehensive test case for WS-RM"); - if (true) return; // disable WS-RM tests - they cause regression in hudson - - RMSequence sequence = null; - if (emulatorOn) - { - RMProvider wsrmProvider = (RMProvider)proxy; - sequence = wsrmProvider.createSequence(addressable); - System.out.println("Created sequence with id=" + sequence.getOutboundId()); - } - setAddrProps(proxy, "http://useless/action1", serviceURL); - proxy.method1(); - setAddrProps(proxy, "http://useless/action2", serviceURL); - proxy.method2("Hello World"); - setAddrProps(proxy, "http://useless/action3", serviceURL); - proxy.method3(new String[] {"Hello","World"}); - if (emulatorOn) - { - if (!sequence.isCompleted(1000, TimeUnit.MILLISECONDS)) { - fail("Sequence not completed within specified time amount"); - } else { - sequence.terminate(); - } - } - } -} Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/RMOneWayTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/RMOneWayTestCase.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/RMOneWayTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -0,0 +1,117 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.wsrm.oneway; + +import static org.jboss.test.ws.jaxws.wsrm.Helper.*; + +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.net.URL; +import java.util.Properties; +import java.util.concurrent.TimeUnit; + +import javax.xml.namespace.QName; +import javax.xml.ws.Service; + +import junit.framework.Test; + +import org.jboss.ws.extensions.wsrm.api.RMProvider; +import org.jboss.ws.extensions.wsrm.api.RMSequence; +import org.jboss.wsf.test.JBossWSTest; +import org.jboss.wsf.test.JBossWSTestSetup; +import org.jboss.test.ws.jaxws.wsrm.OneWayServiceIface; + +/** + * Reliable JBoss WebService client invoking one way methods + * + * @author richard.opalka(a)jboss.com + * @since 22-Aug-2007 + */ +public class RMOneWayTestCase extends JBossWSTest +{ + private static final Properties props = new Properties(); + private String targetNS = "http://wsrm.jaxws.ws.test.jboss.org/"; + private OneWayServiceIface proxy; + private final boolean emulatorOn = Boolean.parseBoolean((String)props.get("emulator")); + private final boolean addressable = Boolean.parseBoolean((String)props.get("addressable")); + private final String serviceURL = "http://" + getServerHost() + ":" + props.getProperty("port") + props.getProperty("path"); + + static + { + // load test properties + File propertiesFile = new File("resources/jaxws/wsrm/properties/RMOneWayTestCase.properties"); + try + { + props.load(new FileInputStream(propertiesFile)); + } + catch (IOException ignore) + { + ignore.printStackTrace(); + } + } + + public static Test suite() + { + return new JBossWSTestSetup(RMOneWayTestCase.class, props.getProperty("archives")); + } + + @Override + protected void setUp() throws Exception + { + super.setUp(); + QName serviceName = new QName(targetNS, "OneWayService"); + URL wsdlURL = new URL(serviceURL + "?wsdl"); + Service service = Service.create(wsdlURL, serviceName); + proxy = (OneWayServiceIface)service.getPort(OneWayServiceIface.class); + } + + public void testOneWayMethods() throws Exception + { + System.out.println("FIXME [JBWS-515] Provide an initial implementation for WS-ReliableMessaging"); + System.out.println("FIXME [JBWS-1699] Implement the basic message exchange that is required for WS-RM"); + System.out.println("FIXME [JBWS-1700] Provide a comprehensive test case for WS-RM"); + if (true) return; // disable WS-RM tests - they cause regression in hudson + + RMSequence sequence = null; + if (emulatorOn) + { + RMProvider wsrmProvider = (RMProvider)proxy; + sequence = wsrmProvider.createSequence(addressable); + System.out.println("Created sequence with id=" + sequence.getOutboundId()); + } + setAddrProps(proxy, "http://useless/action1", serviceURL); + proxy.method1(); + setAddrProps(proxy, "http://useless/action2", serviceURL); + proxy.method2("Hello World"); + setAddrProps(proxy, "http://useless/action3", serviceURL); + proxy.method3(new String[] {"Hello","World"}); + if (emulatorOn) + { + if (!sequence.isCompleted(1000, TimeUnit.MILLISECONDS)) { + fail("Sequence not completed within specified time amount"); + } else { + sequence.terminate(); + } + } + } +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/oneway/RMOneWayTestCase.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Added: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/RMReqResTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/RMReqResTestCase.java (rev 0) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/RMReqResTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -0,0 +1,203 @@ +/* + * JBoss, Home of Professional Open Source + * Copyright 2005, JBoss Inc., and individual contributors as indicated + * by the @authors tag. See the copyright.txt in the distribution for a + * full listing of individual contributors. + * + * This is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as + * published by the Free Software Foundation; either version 2.1 of + * the License, or (at your option) any later version. + * + * This software is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this software; if not, write to the Free + * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA + * 02110-1301 USA, or see the FSF site: http://www.fsf.org. + */ +package org.jboss.test.ws.jaxws.wsrm.reqres; + +import static org.jboss.test.ws.jaxws.wsrm.Helper.*; + +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.net.URL; +import java.util.Properties; +import java.util.concurrent.Future; +import java.util.concurrent.TimeUnit; + +import javax.xml.namespace.QName; +import javax.xml.ws.AsyncHandler; +import javax.xml.ws.Response; +import javax.xml.ws.Service; + +import junit.framework.Test; + +import org.jboss.wsf.test.JBossWSTest; +import org.jboss.wsf.test.JBossWSTestSetup; +import org.jboss.test.ws.jaxws.wsrm.ReqResServiceIface; + +import org.jboss.ws.extensions.wsrm.api.RMProvider; +import org.jboss.ws.extensions.wsrm.api.RMSequence; + +/** + * Reliable JBoss WebService client invoking req/res methods + * + * @author richard.opalka(a)jboss.com + * @since 22-Aug-2007 + */ +public class RMReqResTestCase extends JBossWSTest +{ + private static final Properties props = new Properties(); + private static final String HELLO_WORLD_MSG = "Hello World"; + private static final String TARGET_NS = "http://org.jboss.ws/jaxws/wsrm"; + private final String serviceURL = "http://" + getServerHost() + ":" + props.getProperty("port") + props.getProperty("path"); + private Exception handlerException; + private boolean asyncHandlerCalled; + private ReqResServiceIface proxy; + private final boolean emulatorOn = Boolean.parseBoolean((String)props.get("emulator")); + private final boolean addressable = Boolean.parseBoolean((String)props.get("addressable")); + + static + { + // load test properties + File propertiesFile = new File("resources/jaxws/wsrm/properties/RMReqResTestCase.properties"); + try + { + props.load(new FileInputStream(propertiesFile)); + } + catch (IOException ignore) + { + ignore.printStackTrace(); + } + } + + private enum InvocationType + { + SYNC, ASYNC, ASYNC_FUTURE + } + + public static Test suite() + { + return new JBossWSTestSetup(RMReqResTestCase.class, props.getProperty("archives")); + } + + @Override + protected void setUp() throws Exception + { + super.setUp(); + + if (proxy == null) + { + QName serviceName = new QName(TARGET_NS, "ReqResService"); + URL wsdlURL = new URL(serviceURL + "?wsdl"); + Service service = Service.create(wsdlURL, serviceName); + proxy = (ReqResServiceIface)service.getPort(ReqResServiceIface.class); + } + } + + public void testSynchronousInvocation() throws Exception + { + doReliableMessageExchange(proxy, InvocationType.SYNC); + } + + public void testAsynchronousInvocation() throws Exception + { + doReliableMessageExchange(proxy, InvocationType.ASYNC); + } + + public void testAsynchronousInvocationUsingFuture() throws Exception + { + doReliableMessageExchange(proxy, InvocationType.ASYNC_FUTURE); + } + + private void doSynchronousInvocation() throws Exception + { + assertEquals(proxy.echo(HELLO_WORLD_MSG), HELLO_WORLD_MSG); + } + + private void doAsynchronousInvocation() throws Exception + { + Response<String> response = proxy.echoAsync(HELLO_WORLD_MSG); + assertEquals(response.get(), HELLO_WORLD_MSG); // hidden future pattern + } + + private void doAsynchronousInvocationUsingFuture() throws Exception + { + AsyncHandler<String> handler = new AsyncHandler<String>() + { + public void handleResponse(Response<String> response) + { + try + { + String retStr = (String) response.get(1000, TimeUnit.MILLISECONDS); + assertEquals(HELLO_WORLD_MSG, retStr); + asyncHandlerCalled = true; + } + catch (Exception ex) + { + handlerException = ex; + } + } + }; + Future<?> future = proxy.echoAsync(HELLO_WORLD_MSG, handler); + future.get(1000, TimeUnit.MILLISECONDS); + ensureAsyncStatus(); + } + + private void ensureAsyncStatus() throws Exception + { + if (handlerException != null) throw handlerException; + assertTrue("Async handler called", asyncHandlerCalled); + handlerException = null; + asyncHandlerCalled = false; + } + + private void invokeWebServiceMethod(InvocationType invocationType) throws Exception + { + switch (invocationType) { + case SYNC: doSynchronousInvocation(); break; + case ASYNC: doAsynchronousInvocation(); break; + case ASYNC_FUTURE: doAsynchronousInvocationUsingFuture(); break; + default : fail("Unknown invocation type"); + } + } + + private void doReliableMessageExchange(Object proxyObject, InvocationType invocationType) throws Exception + { + System.out.println("FIXME [JBWS-515] Provide an initial implementation for WS-ReliableMessaging"); + System.out.println("FIXME [JBWS-1699] Implement the basic message exchange that is required for WS-RM"); + System.out.println("FIXME [JBWS-1700] Provide a comprehensive test case for WS-RM"); + if (true) return; // disable WS-RM tests - they cause regression in hudson + + RMSequence sequence = null; + if (emulatorOn) + { + RMProvider wsrmProvider = (RMProvider)proxyObject; + sequence = wsrmProvider.createSequence(addressable); + System.out.println("Created sequence with outbound id=" + sequence.getOutboundId()); + System.out.println("Created sequence with inbound id=" + sequence.getInboundId()); + } + setAddrProps(proxy, "http://useless/action", serviceURL); + invokeWebServiceMethod(invocationType); + setAddrProps(proxy, "http://useless/action", serviceURL); + invokeWebServiceMethod(invocationType); + setAddrProps(proxy, "http://useless/action", serviceURL); + invokeWebServiceMethod(invocationType); + if (emulatorOn) + { + if (!sequence.isCompleted(1000, TimeUnit.MILLISECONDS)) { + sequence.discard(); + fail("Sequence not completed within specified time amount"); + } else { + sequence.terminate(); + } + } + } + +} Property changes on: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/RMReqResTestCase.java ___________________________________________________________________ Name: svn:keywords + Id Revision Name: svn:eol-style + LF Deleted: stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/ReqResTestCase.java =================================================================== --- stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/ReqResTestCase.java 2007-11-28 11:19:31 UTC (rev 5126) +++ stack/native/trunk/src/test/java/org/jboss/test/ws/jaxws/wsrm/reqres/ReqResTestCase.java 2007-11-28 11:47:54 UTC (rev 5127) @@ -1,203 +0,0 @@ -/* - * JBoss, Home of Professional Open Source - * Copyright 2005, JBoss Inc., and individual contributors as indicated - * by the @authors tag. See the copyright.txt in the distribution for a - * full listing of individual contributors. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.jboss.test.ws.jaxws.wsrm.reqres; - -import static org.jboss.test.ws.jaxws.wsrm.Helper.*; - -import java.io.File; -import java.io.FileInputStream; -import java.io.IOException; -import java.net.URL; -import java.util.Properties; -import java.util.concurrent.Future; -import java.util.concurrent.TimeUnit; - -import javax.xml.namespace.QName; -import javax.xml.ws.AsyncHandler; -import javax.xml.ws.Response; -import javax.xml.ws.Service; - -import junit.framework.Test; - -import org.jboss.wsf.test.JBossWSTest; -import org.jboss.wsf.test.JBossWSTestSetup; -import org.jboss.test.ws.jaxws.wsrm.ReqResServiceIface; - -import org.jboss.ws.extensions.wsrm.api.RMProvider; -import org.jboss.ws.extensions.wsrm.api.RMSequence; - -/** - * Reliable JBoss WebService client invoking req/res methods - * - * @author richard.opalka(a)jboss.com - * @since 22-Aug-2007 - */ -public class ReqResTestCase extends JBossWSTest -{ - private static final Properties props = new Properties(); - private static final String HELLO_WORLD_MSG = "Hello World"; - private static final String TARGET_NS = "http://org.jboss.ws/jaxws/wsrm"; - private final String serviceURL = "http://" + getServerHost() + ":" + props.getProperty("port") + props.getProperty("path"); - private Exception handlerException; - private boolean asyncHandlerCalled; - private ReqResServiceIface proxy; - private final boolean emulatorOn = Boolean.parseBoolean((String)props.get("emulator")); - private final boolean addressable = Boolean.parseBoolean((String)props.get("addressable")); - - static - { - // load test properties - File propertiesFile = new File("resources/jaxws/wsrm/properties/ReqResTestCase.properties"); - try - { - props.load(new FileInputStream(propertiesFile)); - } - catch (IOException ignore) - { - ignore.printStackTrace(); - } - } - - private enum InvocationType - { - SYNC, ASYNC, ASYNC_FUTURE - } - - public static Test suite() - { - return new JBossWSTestSetup(ReqResTestCase.class, props.getProperty("archives")); - } - - @Override - protected void setUp() throws Exception - { - super.setUp(); - - if (proxy == null) - { - QName serviceName = new QName(TARGET_NS, "ReqResService"); - URL wsdlURL = new URL(serviceURL + "?wsdl"); - Service service = Service.create(wsdlURL, serviceName); - proxy = (ReqResServiceIface)service.getPort(ReqResServiceIface.class); - } - } - - public void testSynchronousInvocation() throws Exception - { - doReliableMessageExchange(proxy, InvocationType.SYNC); - } - - public void testAsynchronousInvocation() throws Exception - { - doReliableMessageExchange(proxy, InvocationType.ASYNC); - } - - public void testAsynchronousInvocationUsingFuture() throws Exception - { - doReliableMessageExchange(proxy, InvocationType.ASYNC_FUTURE); - } - - private void doSynchronousInvocation() throws Exception - { - assertEquals(proxy.echo(HELLO_WORLD_MSG), HELLO_WORLD_MSG); - } - - private void doAsynchronousInvocation() throws Exception - { - Response<String> response = proxy.echoAsync(HELLO_WORLD_MSG); - assertEquals(response.get(), HELLO_WORLD_MSG); // hidden future pattern - } - - private void doAsynchronousInvocationUsingFuture() throws Exception - { - AsyncHandler<String> handler = new AsyncHandler<String>() - { - public void handleResponse(Response<String> response) - { - try - { - String retStr = (String) response.get(1000, TimeUnit.MILLISECONDS); - assertEquals(HELLO_WORLD_MSG, retStr); - asyncHandlerCalled = true; - } - catch (Exception ex) - { - handlerException = ex; - } - } - }; - Future<?> future = proxy.echoAsync(HELLO_WORLD_MSG, handler); - future.get(1000, TimeUnit.MILLISECONDS); - ensureAsyncStatus(); - } - - private void ensureAsyncStatus() throws Exception - { - if (handlerException != null) throw handlerException; - assertTrue("Async handler called", asyncHandlerCalled); - handlerException = null; - asyncHandlerCalled = false; - } - - private void invokeWebServiceMethod(InvocationType invocationType) throws Exception - { - switch (invocationType) { - case SYNC: doSynchronousInvocation(); break; - case ASYNC: doAsynchronousInvocation(); break; - case ASYNC_FUTURE: doAsynchronousInvocationUsingFuture(); break; - default : fail("Unknown invocation type"); - } - } - - private void doReliableMessageExchange(Object proxyObject, InvocationType invocationType) throws Exception - { - System.out.println("FIXME [JBWS-515] Provide an initial implementation for WS-ReliableMessaging"); - System.out.println("FIXME [JBWS-1699] Implement the basic message exchange that is required for WS-RM"); - System.out.println("FIXME [JBWS-1700] Provide a comprehensive test case for WS-RM"); - if (true) return; // disable WS-RM tests - they cause regression in hudson - - RMSequence sequence = null; - if (emulatorOn) - { - RMProvider wsrmProvider = (RMProvider)proxyObject; - sequence = wsrmProvider.createSequence(addressable); - System.out.println("Created sequence with outbound id=" + sequence.getOutboundId()); - System.out.println("Created sequence with inbound id=" + sequence.getInboundId()); - } - setAddrProps(proxy, "http://useless/action", serviceURL); - invokeWebServiceMethod(invocationType); - setAddrProps(proxy, "http://useless/action", serviceURL); - invokeWebServiceMethod(invocationType); - setAddrProps(proxy, "http://useless/action", serviceURL); - invokeWebServiceMethod(invocationType); - if (emulatorOn) - { - if (!sequence.isCompleted(1000, TimeUnit.MILLISECONDS)) { - sequence.discard(); - fail("Sequence not completed within specified time amount"); - } else { - sequence.terminate(); - } - } - } - -} Deleted: stack/native/trunk/src/test/resources/jaxws/wsrm/properties/OneWayTestCase.properties =================================================================== --- stack/native/trunk/src/test/resources/jaxws/wsrm/properties/OneWayTestCase.properties 2007-11-28 11:19:31 UTC (rev 5126) +++ stack/native/trunk/src/test/resources/jaxws/wsrm/properties/OneWayTestCase.properties 2007-11-28 11:47:54 UTC (rev 5127) @@ -1,7 +0,0 @@ -port=8080 -#path=/jaxws-wsrm/OneWayService -path=/jaxws-wsrm-one-way-emulator/OneWayService -#archives=jaxws-wsrm.war, jaxws-wsrm-client.jar -archives=jaxws-wsrm-one-way-emulator.war, jaxws-wsrm-client.jar -emulator=true -addressable=true \ No newline at end of file Added: stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMOneWayTestCase.properties =================================================================== --- stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMOneWayTestCase.properties (rev 0) +++ stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMOneWayTestCase.properties 2007-11-28 11:47:54 UTC (rev 5127) @@ -0,0 +1,7 @@ +port=8080 +#path=/jaxws-wsrm/OneWayService +path=/jaxws-wsrm-one-way-emulator/OneWayService +#archives=jaxws-wsrm.war, jaxws-wsrm-client.jar +archives=jaxws-wsrm-one-way-emulator.war, jaxws-wsrm-client.jar +emulator=true +addressable=true \ No newline at end of file Added: stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMReqResTestCase.properties =================================================================== --- stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMReqResTestCase.properties (rev 0) +++ stack/native/trunk/src/test/resources/jaxws/wsrm/properties/RMReqResTestCase.properties 2007-11-28 11:47:54 UTC (rev 5127) @@ -0,0 +1,7 @@ +port=8080 +#path=/jaxws-wsrm/ReqResService +path=/jaxws-wsrm-req-res-emulator/ReqResService +#archives=jaxws-wsrm.war, jaxws-wsrm-client.jar +archives=jaxws-wsrm-req-res-emulator.war, jaxws-wsrm-client.jar +emulator=true +addressable=true Deleted: stack/native/trunk/src/test/resources/jaxws/wsrm/properties/ReqResTestCase.properties =================================================================== --- stack/native/trunk/src/test/resources/jaxws/wsrm/properties/ReqResTestCase.properties 2007-11-28 11:19:31 UTC (rev 5126) +++ stack/native/trunk/src/test/resources/jaxws/wsrm/properties/ReqResTestCase.properties 2007-11-28 11:47:54 UTC (rev 5127) @@ -1,7 +0,0 @@ -port=8080 -#path=/jaxws-wsrm/ReqResService -path=/jaxws-wsrm-req-res-emulator/ReqResService -#archives=jaxws-wsrm.war, jaxws-wsrm-client.jar -archives=jaxws-wsrm-req-res-emulator.war, jaxws-wsrm-client.jar -emulator=true -addressable=true