Moving 1.x branches

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@835142 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 0 insertions, 526 deletions

diff --git a/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/AxiomTestCase.java b/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/AxiomTestCase.java
deleted file mode 100644
index 3d328339a7..0000000000
--- a/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/AxiomTestCase.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*

- * 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.tuscany.sca.binding.notification.encoding;

-

-import java.io.ByteArrayInputStream;

-import java.io.StringWriter;

-

-import junit.framework.TestCase;

-

-import org.apache.axiom.om.OMElement;

-import org.apache.axiom.om.impl.builder.StAXOMBuilder;

-import org.junit.Assert;

-

-public class AxiomTestCase extends TestCase {

-

-    private static String wsnt = "http://docs.oasis-open.org/wsn/b-2";

-    private static String wsa = "http://schemas.xmlsoap.org/ws/2004/08/addressing";

-    private static String testUrl1 = "http://localhost:8081/test";

-    private static String testUrl2 = "http://localhost:8082/test";

-    private static String testNewProducerResponse =

-        "<wsnt:NewProducerResponse xmlns:wsnt=\"" + wsnt + "\" ConsumerSequenceType=\"EndConsumers\">" +

-            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-        "</wsnt:NewProducerResponse>";

-    

-    public void testAxiom() {

-        try {

-            StAXOMBuilder builder = new StAXOMBuilder(new ByteArrayInputStream(testNewProducerResponse.getBytes()));

-            OMElement element = builder.getDocumentElement();

-            Assert.assertNotNull(element);

-            

-            StringWriter sw = new StringWriter();

-            element.serialize(sw);

-            sw.flush();

-            Assert.assertEquals(sw.toString(),testNewProducerResponse);

-        } catch(Throwable e) {

-            e.printStackTrace();

-        }

-    }

-}

diff --git a/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/EncodingTestCase.java b/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/EncodingTestCase.java
deleted file mode 100644
index 3dcd2b9b00..0000000000
--- a/branches/sca-java-20080910/modules/binding-notification/src/test/java/org/apache/tuscany/sca/binding/notification/encoding/EncodingTestCase.java
+++ /dev/null
@@ -1,470 +0,0 @@
-/*

- * 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.tuscany.sca.binding.notification.encoding;

-

-import java.io.StringReader;

-import java.io.StringWriter;

-import java.util.Iterator;

-

-import javax.xml.stream.XMLInputFactory;

-import javax.xml.stream.XMLOutputFactory;

-import javax.xml.stream.XMLStreamReader;

-import javax.xml.stream.XMLStreamWriter;

-

-import junit.framework.Assert;

-import junit.framework.TestCase;

-

-/**

- * @version $Rev$ $Date$

- */

-public class EncodingTestCase extends TestCase {

-    

-    private static String wsnt = "http://docs.oasis-open.org/wsn/b-2";

-    private static String wsa = "http://schemas.xmlsoap.org/ws/2004/08/addressing";

-    private static String testUrl = "http://localhost:8080/test";

-    private static String testUrl1 = "http://localhost:8081/test";

-    private static String testUrl2 = "http://localhost:8082/test";

-    private static String bid1 = "UUID1";

-    private static String bid2 = "UUID2";

-    private static String testSubscribe =

-        "<wsnt:Subscribe xmlns:wsnt=\"" + wsnt + "\">" +

-            "<wsnt:ConsumerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl + "</wsa:Address>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:ConsumerReference>" +

-        "</wsnt:Subscribe>";

-    private static String testNewConsumerResponse =

-        "<wsnt:NewConsumerResponse xmlns:wsnt=\"" + wsnt + "\" ProducerSequenceType=\"EndProducers\">" +

-            "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl + "</wsa:Address>" +

-            "</wsa:EndpointReference>" +

-        "</wsnt:NewConsumerResponse>";

-    private static String testNewProducerResponse =

-        "<wsnt:NewProducerResponse xmlns:wsnt=\"" + wsnt + "\" ConsumerSequenceType=\"EndConsumers\">" +

-            "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-            "</wsa:EndpointReference>" +

-            "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-            "</wsa:EndpointReference>" +

-        "</wsnt:NewProducerResponse>";

-    private static String testNoProducersResponse =

-        "<wsnt:NewConsumerResponse xmlns:wsnt=\"" + wsnt + "\" ProducerSequenceType=\"NoProducers\" />";

-    private static String testNewBroker =

-        "<wsnt:NewBroker xmlns:wsnt=\"" + wsnt + "\">" +

-            "<wsnt:BrokerConsumerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-                    "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                        "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid1 + "</wsnt:BrokerID>" +

-                    "</wsa:ReferenceProperties>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:BrokerConsumerReference>" +

-            "<wsnt:BrokerProducerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-                    "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                        "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid2 + "</wsnt:BrokerID>" +

-                    "</wsa:ReferenceProperties>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:BrokerProducerReference>" +

-        "</wsnt:NewBroker>";

-    private static String testNewBrokerResponse1 =

-        "<wsnt:NewBrokerResponse xmlns:wsnt=\"" + wsnt + "\" FirstBroker=\"true\">" +

-            "<wsnt:EndConsumers xmlns:wsnt=\"" + wsnt + "\" ConsumerSequenceType=\"EndConsumers\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-                "</wsa:EndpointReference>" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:EndConsumers>" +

-            "<wsnt:EndProducers xmlns:wsnt=\"" + wsnt + "\" ProducerSequenceType=\"NoProducers\" />" +

-        "</wsnt:NewBrokerResponse>";

-    private static String testNewBrokerResponse2 =

-        "<wsnt:NewBrokerResponse xmlns:wsnt=\"" + wsnt + "\" FirstBroker=\"false\">" +

-            "<wsnt:Brokers xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsnt:Broker xmlns:wsnt=\"" + wsnt + "\">" +

-                    "<wsnt:BrokerConsumerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                        "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-                            "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                                "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid1 + "</wsnt:BrokerID>" +

-                            "</wsa:ReferenceProperties>" +

-                        "</wsa:EndpointReference>" +

-                    "</wsnt:BrokerConsumerReference>" +

-                    "<wsnt:BrokerProducerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                        "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-                            "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                                "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid2 + "</wsnt:BrokerID>" +

-                            "</wsa:ReferenceProperties>" +

-                        "</wsa:EndpointReference>" +

-                    "</wsnt:BrokerProducerReference>" +

-                "</wsnt:Broker>" +

-            "</wsnt:Brokers>" +

-        "</wsnt:NewBrokerResponse>";

-    private static String testRemoveBroker =

-        "<wsnt:RemoveBroker xmlns:wsnt=\"" + wsnt + "\">" +

-            "<wsnt:BrokerConsumerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl + "</wsa:Address>" +

-                    "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                        "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid1 + "</wsnt:BrokerID>" +

-                    "</wsa:ReferenceProperties>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:BrokerConsumerReference>" +

-            "<wsnt:NeighborBrokerConsumers xmlns:wsnt=\"" + wsnt + "\" ConsumerSequenceType=\"BrokerConsumers\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-                "</wsa:EndpointReference>" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:NeighborBrokerConsumers>" +

-        "</wsnt:RemoveBroker>";

-    private static String testReplaceBrokerConnection =

-        "<wsnt:ReplaceBrokerConnection xmlns:wsnt=\"" + wsnt + "\">" +

-            "<wsnt:RemovedBroker xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                    "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl + "</wsa:Address>" +

-                    "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                        "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid1 + "</wsnt:BrokerID>" +

-                    "</wsa:ReferenceProperties>" +

-                "</wsa:EndpointReference>" +

-            "</wsnt:RemovedBroker>" +

-            "<wsnt:Neighbors xmlns:wsnt=\"" + wsnt + "\">" +

-                "<wsnt:Broker xmlns:wsnt=\"" + wsnt + "\">" +

-                    "<wsnt:BrokerConsumerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                        "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl1 + "</wsa:Address>" +

-                            "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                                "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid1 + "</wsnt:BrokerID>" +

-                            "</wsa:ReferenceProperties>" +

-                        "</wsa:EndpointReference>" +

-                    "</wsnt:BrokerConsumerReference>" +

-                    "<wsnt:BrokerProducerReference xmlns:wsnt=\"" + wsnt + "\">" +

-                        "<wsa:EndpointReference xmlns:wsa=\"" + wsa + "\">" +

-                            "<wsa:Address xmlns:wsa=\"" + wsa + "\">" + testUrl2 + "</wsa:Address>" +

-                            "<wsa:ReferenceProperties xmlns:wsa=\"" + wsa + "\">" +

-                                "<wsnt:BrokerID xmlns:wsnt=\"" + wsnt + "\">" + bid2 + "</wsnt:BrokerID>" +

-                            "</wsa:ReferenceProperties>" +

-                        "</wsa:EndpointReference>" +

-                    "</wsnt:BrokerProducerReference>" +

-                "</wsnt:Broker>" +

-            "</wsnt:Neighbors>" +

-        "</wsnt:ReplaceBrokerConnection>";

-    

-    public void testSubscribe() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        SubscribeEnDeCoder sed = new SubscribeEnDeCoder(der);

-        sed.start();

-        ConsumerReferenceEnDeCoder cred = new ConsumerReferenceEnDeCoder(der);

-        cred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testSubscribe));

-        reader.next();

-        Subscribe subscribe = (Subscribe)der.decode(reader);

-        Assert.assertEquals(subscribe.getConsumerReference().getReference().getEndpointAddress().getAddress().toString(), testUrl);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(subscribe, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testSubscribe);

-    }

-    

-    public void testNewConsumerResponse() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewConsumerResponseEnDeCoder ncred = new NewConsumerResponseEnDeCoder(der);

-        ncred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNewConsumerResponse));

-        reader.next();

-        NewConsumerResponse newConsumerResponse = (NewConsumerResponse)der.decode(reader);

-        Assert.assertEquals(newConsumerResponse.getSequenceType(), "EndProducers");

-        Assert.assertEquals(newConsumerResponse.getReferenceSequence().iterator().next().getEndpointAddress().getAddress().toString(),

-                            testUrl);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newConsumerResponse, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNewConsumerResponse);

-    }

-    

-    public void testNoProducersResponse() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewConsumerResponseEnDeCoder ncred = new NewConsumerResponseEnDeCoder(der);

-        ncred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNoProducersResponse));

-        reader.next();

-        NewConsumerResponse newConsumerResponse = (NewConsumerResponse)der.decode(reader);

-        Assert.assertEquals(newConsumerResponse.getSequenceType(), "NoProducers");

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newConsumerResponse, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNoProducersResponse);

-    }

-    

-    public void testNewProducerResponse() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewProducerResponseEnDeCoder npred = new NewProducerResponseEnDeCoder(der);

-        npred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNewProducerResponse));

-        reader.next();

-        NewProducerResponse newProducerResponse = (NewProducerResponse)der.decode(reader);

-        Assert.assertEquals(newProducerResponse.getSequenceType(), "EndConsumers");

-        Iterator<EndpointReference> it = newProducerResponse.getReferenceSequence().iterator();

-        it.next();

-        Assert.assertEquals(it.next().getEndpointAddress().getAddress().toString(), testUrl2);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newProducerResponse, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNewProducerResponse);

-    }

-

-    public void testNewBroker() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewBrokerEnDeCoder nbed = new NewBrokerEnDeCoder(der);

-        nbed.start();

-        BrokerConsumerReferenceEnDeCoder bcred = new BrokerConsumerReferenceEnDeCoder(der);

-        bcred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        ReferencePropertiesEnDeCoder rped = new ReferencePropertiesEnDeCoder(der); 

-        rped.start();

-        BrokerIDEnDeCoder bied = new BrokerIDEnDeCoder(der);

-        bied.start();

-        BrokerProducerReferenceEnDeCoder bpred = new BrokerProducerReferenceEnDeCoder(der);

-        bpred.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNewBroker));

-        reader.next();

-        NewBroker newBroker = (NewBroker)der.decode(reader);

-        Assert.assertEquals(newBroker.getBrokerConsumerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl1);

-        Assert.assertEquals(newBroker.getBrokerProducerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl2);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newBroker, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNewBroker);

-    }

-

-    public void testNewBrokerRespnse1() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewBrokerResponseEnDeCoder nbred = new NewBrokerResponseEnDeCoder(der);

-        nbred.start();

-        EndProducersEnDeCoder epred = new EndProducersEnDeCoder(der);

-        epred.start();

-        EndConsumersEnDeCoder ecred = new EndConsumersEnDeCoder(der);

-        ecred.start();

-        EndpointReferenceEnDeCoder ered = new EndpointReferenceEnDeCoder(der);

-        ered.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNewBrokerResponse1));

-        reader.next();

-        NewBrokerResponse newBrokerResponse = (NewBrokerResponse)der.decode(reader);

-        Assert.assertFalse(!newBrokerResponse.isFirstBroker());

-        Assert.assertEquals(newBrokerResponse.getEndProducers().getSequenceType(), "NoProducers");

-        Assert.assertEquals(newBrokerResponse.getEndConsumers().getSequenceType(), "EndConsumers");

-        Assert.assertEquals(newBrokerResponse.getEndConsumers().getReferenceSequence().get(0).getEndpointAddress().getAddress().toString(),

-                            testUrl1);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newBrokerResponse, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNewBrokerResponse1);

-    }

-

-    public void testNewBrokerRespnse2() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        NewBrokerResponseEnDeCoder nbred = new NewBrokerResponseEnDeCoder(der);

-        nbred.start();

-        BrokersEnDeCoder bsed = new BrokersEnDeCoder(der);

-        bsed.start();

-        BrokerEnDeCoder bed = new BrokerEnDeCoder(der);

-        bed.start();

-        BrokerConsumerReferenceEnDeCoder bcred = new BrokerConsumerReferenceEnDeCoder(der);

-        bcred.start();

-        BrokerProducerReferenceEnDeCoder bpred = new BrokerProducerReferenceEnDeCoder(der);

-        bpred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        ReferencePropertiesEnDeCoder rped = new ReferencePropertiesEnDeCoder(der); 

-        rped.start();

-        BrokerIDEnDeCoder bied = new BrokerIDEnDeCoder(der);

-        bied.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testNewBrokerResponse2));

-        reader.next();

-        NewBrokerResponse newBrokerResponse = (NewBrokerResponse)der.decode(reader);

-        Assert.assertFalse(newBrokerResponse.isFirstBroker());

-        Assert.assertEquals(newBrokerResponse.getBrokers().getBrokerSequence().get(0)

-                            .getBrokerConsumerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl1);

-        Assert.assertEquals(newBrokerResponse.getBrokers().getBrokerSequence().get(0)

-                            .getBrokerProducerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl2);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(newBrokerResponse, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testNewBrokerResponse2);

-    }

-

-    public void testRemoveBroker() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        RemoveBrokerEnDeCoder rbed = new RemoveBrokerEnDeCoder(der);

-        rbed.start();

-        BrokerConsumerReferenceEnDeCoder bcred = new BrokerConsumerReferenceEnDeCoder(der);

-        bcred.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        ReferencePropertiesEnDeCoder rped = new ReferencePropertiesEnDeCoder(der); 

-        rped.start();

-        BrokerIDEnDeCoder bied = new BrokerIDEnDeCoder(der);

-        bied.start();

-        NeighborBrokerConsumersEnDeCoder nbced = new NeighborBrokerConsumersEnDeCoder(der);

-        nbced.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testRemoveBroker));

-        reader.next();

-        RemoveBroker removeBroker = (RemoveBroker)der.decode(reader);

-        Assert.assertEquals(removeBroker.getBrokerConsumerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl);

-        NeighborBrokerConsumers neighborBrokerConsumers = removeBroker.getNeighborBrokerConsumers();

-        Assert.assertEquals(neighborBrokerConsumers.getSequenceType(), "BrokerConsumers");

-        Iterator<EndpointReference> it = neighborBrokerConsumers.getReferenceSequence().iterator();

-        it.next();

-        Assert.assertEquals(it.next().getEndpointAddress().getAddress().toString(), testUrl2);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(removeBroker, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testRemoveBroker);

-    }

-

-    public void testReplaceBrokerConnection() throws Exception {

-        DefaultEncodingRegistry der = new DefaultEncodingRegistry();

-        ReplaceBrokerConnectionEnDeCoder rbced = new ReplaceBrokerConnectionEnDeCoder(der);

-        rbced.start();

-        RemovedBrokerEnDeCoder rbed = new RemovedBrokerEnDeCoder(der);

-        rbed.start();

-        EndpointReferenceEnDeCoder epred = new EndpointReferenceEnDeCoder(der);

-        epred.start();

-        EndpointAddressEnDeCoder eaed = new EndpointAddressEnDeCoder(der);

-        eaed.start();

-        ReferencePropertiesEnDeCoder rped = new ReferencePropertiesEnDeCoder(der); 

-        rped.start();

-        BrokerIDEnDeCoder bied = new BrokerIDEnDeCoder(der);

-        bied.start();

-        BrokerEnDeCoder bed = new BrokerEnDeCoder(der);

-        bed.start();

-        BrokerConsumerReferenceEnDeCoder bcred = new BrokerConsumerReferenceEnDeCoder(der);

-        bcred.start();

-        BrokerProducerReferenceEnDeCoder bpred = new BrokerProducerReferenceEnDeCoder(der);

-        bpred.start();

-        NeighborsEnDeCoder nced = new NeighborsEnDeCoder(der);

-        nced.start();

-        

-        XMLInputFactory xif = XMLInputFactory.newInstance();

-        XMLStreamReader reader = xif.createXMLStreamReader(new StringReader(testReplaceBrokerConnection));

-        reader.next();

-        ReplaceBrokerConnection replaceBrokerConnection = (ReplaceBrokerConnection)der.decode(reader);

-        Assert.assertEquals(replaceBrokerConnection.getRemovedBroker().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl);

-        Neighbors neighbors = replaceBrokerConnection.getNeighbors();

-        Assert.assertEquals(neighbors.getBrokerSequence().get(0)

-                            .getBrokerConsumerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl1);

-        Assert.assertEquals(neighbors.getBrokerSequence().get(0)

-                            .getBrokerProducerReference().getReference().getEndpointAddress().getAddress().toString(),

-                            testUrl2);

-        

-        XMLOutputFactory xof = XMLOutputFactory.newInstance();

-        StringWriter testWriter = new StringWriter();

-        XMLStreamWriter writer = xof.createXMLStreamWriter(testWriter);

-        der.encode(replaceBrokerConnection, writer);

-        writer.flush();

-        String encoded = testWriter.toString();

-        Assert.assertEquals(encoded, testReplaceBrokerConnection);

-    }

-}