Test classes for QPID-4 changes to AMQProtocolSession.generateQueueName

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@470337 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 210 insertions, 0 deletions

diff --git a/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java b/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
new file mode 100644
index 0000000000..4197eeebf8
--- /dev/null
+++ b/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
@@ -0,0 +1,114 @@
+/*

+ *

+ * Copyright (c) 2006 The Apache Software Foundation

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *    http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ *

+ */

+package org.apache.qpid.client.protocol;

+

+import org.apache.qpid.client.AMQConnection;

+import org.apache.mina.common.IoSession;

+import org.junit.Before;

+import org.junit.Test;

+import org.junit.After;

+import junit.framework.JUnit4TestAdapter;

+import junit.framework.Assert;

+

+public class TestAMQProtocolSession extends AMQProtocolSession {

+

+    //private Strings for test values and expected results

+    private String _brokenAddress;

+    private String _generatedAddress;

+    private String _emptyAddress;

+    private String _generatedAddress_2;

+    private String _validAddress;

+    private String _generatedAddress_3;

+    private int _port;

+    private TestAMQProtocolSession _testSession;

+

+    public TestAMQProtocolSession()

+    {

+

+    }

+

+    public TestAMQProtocolSession(AMQProtocolHandler protocolHandler, IoSession protocolSession, AMQConnection connection)

+    {

+        super(protocolHandler,protocolSession,connection);

+    }

+

+    public TestIoSession getMinaProtocolSession()

+    {

+        return (TestIoSession) _minaProtocolSession;

+    }

+

+    @Before

+    public void setUp()

+    {

+        //don't care about the values set here apart from the dummy IoSession

+        _testSession = new TestAMQProtocolSession(null,new TestIoSession(),null);

+

+        //initialise addresses for test and expected results

+        _port = 123;

+        _brokenAddress = "tcp://myAddress;";

+        _generatedAddress = "tmp_tcp:myAddress:123_1";

+        _emptyAddress = "";

+        _generatedAddress_2 = "tmp_localhost127.0.0.1:123_2";

+        _validAddress = "abc";

+        _generatedAddress_3 = "tmp_abc:123_3";

+

+    }

+

+    @Test

+    public void TestGenerateQueueName()

+    {

+        String testAddress;

+

+        //test address with / and ; chars which generateQueueName should remove

+        _testSession.getMinaProtocolSession().setStringLocalAddress(_brokenAddress);

+        _testSession.getMinaProtocolSession().setLocalPort(_port);

+

+        testAddress = _testSession.generateQueueName();

+        Assert.assertEquals("Failure when generating a queue name from an address with special chars",_generatedAddress,testAddress);

+

+        //test empty address

+        _testSession.getMinaProtocolSession().setStringLocalAddress(_emptyAddress);

+

+        testAddress = _testSession.generateQueueName();

+        Assert.assertEquals("Failure when generating a queue name from an empty address",_generatedAddress_2,testAddress);

+

+        //test address with no special chars

+        _testSession.getMinaProtocolSession().setStringLocalAddress(_validAddress);

+

+        testAddress = _testSession.generateQueueName();

+        Assert.assertEquals("Failure when generating a queue name from an address with no special chars",_generatedAddress_3,testAddress);

+

+    }

+

+    public static junit.framework.Test suite()

+    {

+        return new JUnit4TestAdapter(TestAMQProtocolSession.class);

+    }

+

+    @After

+    public void tearDown()

+    {

+        _testSession = null;

+        _brokenAddress = null;

+        _generatedAddress = null;

+        _emptyAddress = null;

+        _generatedAddress_2 = null;

+        _validAddress = null;

+        _generatedAddress_3 = null;

+    }

+}

diff --git a/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java b/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
new file mode 100644
index 0000000000..fd9565ba5f
--- /dev/null
+++ b/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
@@ -0,0 +1,96 @@
+/*

+ *

+ * Copyright (c) 2006 The Apache Software Foundation

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *    http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ *

+ */

+package org.apache.qpid.client.protocol;

+

+import org.apache.mina.common.support.BaseIoSession;

+import org.apache.mina.common.*;

+

+import java.net.SocketAddress;

+import java.net.InetSocketAddress;

+

+public class TestIoSession extends BaseIoSession {

+

+    private String _stringLocalAddress;

+    private int _localPort;

+

+    public SocketAddress getLocalAddress()

+    {

+        //create a new address for testing purposes using member variables

+        return new InetSocketAddress(_stringLocalAddress,_localPort);

+    }

+

+    protected void updateTrafficMask() {

+       //dummy

+    }

+

+    public IoService getService() {

+        return null;

+    }

+

+    public IoServiceConfig getServiceConfig() {

+        return null;

+    }

+

+    public IoHandler getHandler() {

+        return null;

+    }

+

+    public IoSessionConfig getConfig() {

+        return null;

+    }

+

+    public IoFilterChain getFilterChain() {

+        return null;

+    }

+

+    public TransportType getTransportType() {

+        return null;

+    }

+

+    public SocketAddress getRemoteAddress() {

+        return null;

+    }

+

+    public SocketAddress getServiceAddress() {

+        return null;

+    }

+

+    public int getScheduledWriteRequests() {

+        return 0;

+    }

+

+    public int getScheduledWriteBytes() {

+        return 0;

+    }

+

+    public String getStringLocalAddress() {

+        return _stringLocalAddress;

+    }

+

+    public void setStringLocalAddress(String _stringLocalAddress) {

+        this._stringLocalAddress = _stringLocalAddress;

+    }

+

+    public int getLocalPort() {

+        return _localPort;

+    }

+

+    public void setLocalPort(int _localPort) {

+        this._localPort = _localPort;

+    }

+}