From 5679bee55bff358c70c6843432a65ca639913792 Mon Sep 17 00:00:00 2001 From: Marnie McCormack Date: Thu, 2 Nov 2006 11:39:35 +0000 Subject: 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 --- .../client/protocol/TestAMQProtocolSession.java | 114 +++++++++++++++++++++ .../apache/qpid/client/protocol/TestIoSession.java | 96 +++++++++++++++++ 2 files changed, 210 insertions(+) create mode 100644 java/client/test/src/org/apache/qpid/client/protocol/TestAMQProtocolSession.java create mode 100644 java/client/test/src/org/apache/qpid/client/protocol/TestIoSession.java (limited to 'java/client') 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; + } +} -- cgit v1.2.1