Author: marnie
Date: Thu Nov 2 03:39:35 2006
New Revision: 470337
URL: http://svn.apache.org/viewvc?view=rev&rev=470337
Log:
Test classes for QPID-4 changes to AMQProtocolSession.generateQueueName
Added:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
Added:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java?view=auto&rev=470337
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java
Thu Nov 2 03:39:35 2006
@@ -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;
+ }
+}
Added:
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java?view=auto&rev=470337
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java
Thu Nov 2 03:39:35 2006
@@ -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;
+ }
+}
