diff options
author | Martin Ritchie <ritchiem@apache.org> | 2006-11-08 13:06:13 +0000 |
---|---|---|
committer | Martin Ritchie <ritchiem@apache.org> | 2006-11-08 13:06:13 +0000 |
commit | e1f683c2d4aa7bf08801681574665919def39a28 (patch) | |
tree | 7e0b4eb19131d12850fa0e2f856655d4ee03de4e | |
parent | d941569df066c360fcebdc2475d1c102299d23f5 (diff) | |
download | qpid-python-e1f683c2d4aa7bf08801681574665919def39a28.tar.gz |
Removed duplicate JNDI test updated @Ignore-s on a few failing tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/java@472484 13f79535-47bb-0310-9956-ffa450edef68
8 files changed, 168 insertions, 662 deletions
diff --git a/client/test/src/org/apache/qpid/framing/FieldTableTest.java b/client/test/src/org/apache/qpid/framing/FieldTableTest.java new file mode 100644 index 0000000000..ae90c8ddde --- /dev/null +++ b/client/test/src/org/apache/qpid/framing/FieldTableTest.java @@ -0,0 +1,164 @@ +/* + * + * 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.framing; + +import junit.framework.JUnit4TestAdapter; +import org.apache.mina.common.ByteBuffer; +import org.apache.xml.security.utils.Base64; +import org.apache.xml.security.exceptions.Base64DecodingException; +import org.apache.qpid.framing.AMQFrameDecodingException; +import org.apache.qpid.framing.FieldTable; +import org.apache.qpid.framing.ContentHeaderBody; +import org.apache.qpid.framing.BasicContentHeaderProperties; +import static org.junit.Assert.assertEquals; +import org.junit.Test; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.Reader; +import java.util.Enumeration; +import java.util.Properties; + +public class FieldTableTest +{ + @Test + public void dataDump() throws IOException, AMQFrameDecodingException, Base64DecodingException + { + byte[] data = readBase64("content.txt"); + System.out.println("Got " + data.length + " bytes of data"); + for (int i = 0; i < 100; i++) + { + System.out.print((char) data[i]); + } + System.out.println(); + int size = 4194304; + ByteBuffer buffer = ByteBuffer.allocate(data.length); + buffer.put(data); + buffer.flip(); + FieldTable table = new FieldTable(buffer, size); + } + + /* + @Test + public void case1() throws AMQFrameDecodingException, IOException + { + testEncoding(load("FieldTableTest.properties")); + } + + @Test + public void case2() throws AMQFrameDecodingException, IOException + { + testEncoding(load("FieldTableTest2.properties")); + } + */ + void testEncoding(FieldTable table) throws AMQFrameDecodingException + { + assertEquivalent(table, encodeThenDecode(table)); + } + + public void assertEquivalent(FieldTable table1, FieldTable table2) + { + for (Object o : table1.keySet()) + { + String key = (String) o; + assertEquals("Values for " + key + " did not match", table1.get(key), table2.get(key)); + //System.out.println("Values for " + key + " matched (" + table1.get(key) + ")"); + } + } + + FieldTable encodeThenDecode(FieldTable table) throws AMQFrameDecodingException + { + ContentHeaderBody header = new ContentHeaderBody(); + header.classId = 6; + BasicContentHeaderProperties properties = new BasicContentHeaderProperties(); + header.properties = properties; + + properties.setHeaders(table); + int size = header.getSize(); + + //encode + ByteBuffer buffer = ByteBuffer.allocate(size); + header.writePayload(buffer); + + //decode + buffer.flip(); + + header = new ContentHeaderBody(); + header.populateFromBuffer(buffer, size); + + return ((BasicContentHeaderProperties) header.properties).getHeaders(); + } + + byte[] readBase64(String name) throws IOException, Base64DecodingException + { + String content = read(new InputStreamReader(getClass().getResourceAsStream(name))); + return Base64.decode(content); + } + + FieldTable load(String name) throws IOException + { + return populate(new FieldTable(), read(name)); + } + + Properties read(String name) throws IOException + { + Properties p = new Properties(); + p.load(getClass().getResourceAsStream(name)); + return p; + } + + FieldTable populate(FieldTable table, Properties properties) + { + for (Enumeration i = properties.propertyNames(); i.hasMoreElements();) + { + String key = (String) i.nextElement(); + String value = properties.getProperty(key); + try{ + int ival = Integer.parseInt(value); + table.put(key, (long) ival); + } + catch(NumberFormatException e) + { + table.put(key, value); + } + } + return table; + } + + static String read(Reader in) throws IOException + { + return read(in instanceof BufferedReader ? (BufferedReader) in : new BufferedReader(in)); + } + + static String read(BufferedReader in) throws IOException + { + StringBuffer buffer = new StringBuffer(); + String line = in.readLine(); + while (line != null){ + buffer.append(line).append(" "); + line = in.readLine(); + } + return buffer.toString(); + } + + public static junit.framework.Test suite() + { + return new JUnit4TestAdapter(FieldTableTest.class); + } +} diff --git a/client/test/src/org/apache/qpid/jndi/referenceabletest/Bind.java b/client/test/src/org/apache/qpid/jndi/referenceabletest/Bind.java deleted file mode 100644 index 48523183fb..0000000000 --- a/client/test/src/org/apache/qpid/jndi/referenceabletest/Bind.java +++ /dev/null @@ -1,210 +0,0 @@ -/* - * - * 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.jndi.referenceabletest; - -import org.apache.qpid.client.AMQConnection; -import org.apache.qpid.client.AMQConnectionFactory; -import org.apache.qpid.client.AMQTopic; -import org.apache.qpid.url.URLSyntaxException; -import org.junit.Assert; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.JMSException; -import javax.jms.Session; -import javax.jms.Topic; -import javax.naming.Context; -import javax.naming.InitialContext; -import javax.naming.NameAlreadyBoundException; -import javax.naming.NamingException; -import javax.naming.NoInitialContextException; -import java.io.File; -import java.util.Hashtable; - -/** - * Usage: To run these you need to have the sun JNDI SPI for the FileSystem. - * This can be downloaded from sun here: - * http://java.sun.com/products/jndi/downloads/index.html - * Click : Download JNDI 1.2.1 & More button - * Download: File System Service Provider, 1.2 Beta 3 - * and add the two jars in the lib dir to your class path. - * <p/> - * Also you need to create the directory /temp/qpid-jndi-test - */ -class Bind -{ - public static final String DEFAULT_PROVIDER_FILE_PATH = System.getProperty("java.io.tmpdir") + "/JNDITest"; - public static final String PROVIDER_URL = "file://" + DEFAULT_PROVIDER_FILE_PATH; - - String _connectionFactoryString = ""; - - String _connectionString = "amqp://guest:guest@clientid/testpath?brokerlist='vm://:1'"; - Topic _topic = null; - - boolean _bound = false; - - public Bind() throws NameAlreadyBoundException, NoInitialContextException - { - this(false); - } - - public Bind(boolean output) throws NameAlreadyBoundException, NoInitialContextException - { - // Set up the environment for creating the initial context - Hashtable env = new Hashtable(11); - env.put(Context.INITIAL_CONTEXT_FACTORY, - "com.sun.jndi.fscontext.RefFSContextFactory"); - env.put(Context.PROVIDER_URL, PROVIDER_URL); - - - File file = new File(PROVIDER_URL.substring(PROVIDER_URL.indexOf("://") + 3)); - - if (file.exists() && !file.isDirectory()) - { - System.out.println("Couldn't make directory file already exists"); - return; - } - else - { - if (!file.exists()) - { - if (!file.mkdirs()) - { - System.out.println("Couldn't make directory"); - return; - } - } - } - - Connection connection = null; - try - { - // Create the initial context - Context ctx = new InitialContext(env); - - // Create the connection factory to be bound - ConnectionFactory connectionFactory = null; - // Create the Connection to be bound - - - try - { - connectionFactory = new AMQConnectionFactory(_connectionString); - connection = connectionFactory.createConnection(); - - _connectionFactoryString = ((AMQConnectionFactory) connectionFactory).getConnectionURL().getURL(); - } - catch (JMSException jmsqe) - { - Assert.fail("Unable to create Connection:" + jmsqe); - } - catch (URLSyntaxException urlse) - { - Assert.fail("Unable to create Connection:" + urlse); - } - - try - { - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - - _topic = session.createTopic("Fruity"); - } - catch (JMSException jmse) - { - - } - // Perform the binds - ctx.bind("ConnectionFactory", connectionFactory); - if (output) - { - System.out.println("Bound factory\n" + ((AMQConnectionFactory) connectionFactory).getConnectionURL()); - } - ctx.bind("Connection", connection); - if (output) - { - System.out.println("Bound Connection\n" + ((AMQConnection) connection).toURL()); - } - ctx.bind("Topic", _topic); - if (output) - { - System.out.println("Bound Topic:\n" + ((AMQTopic) _topic).toURL()); - } - _bound = true; - - // Check that it is bound - //Object obj = ctx.lookup("Connection"); - //System.out.println(((AMQConnection)obj).toURL()); - - // Close the context when we're done - ctx.close(); - } - catch (NamingException e) - { - System.out.println("Operation failed: " + e); - if (e instanceof NameAlreadyBoundException) - { - throw(NameAlreadyBoundException) e; - } - - if (e instanceof NoInitialContextException) - { - throw(NoInitialContextException) e; - } - } - finally - { - try - { - if (connection != null) - { - connection.close(); - } - } - catch (JMSException e) - { - //ignore just want it closed - } - } - } - - public String connectionFactoryValue() - { - return _connectionFactoryString; - } - - public String connectionValue() - { - return _connectionString; - } - - public String topicValue() - { - return ((AMQTopic) _topic).toURL(); - } - - public boolean bound() - { - return _bound; - } - - public static void main(String[] args) throws NameAlreadyBoundException, NoInitialContextException - { - new Bind(true); - } -} - diff --git a/client/test/src/org/apache/qpid/jndi/referenceabletest/JNDIReferenceableTest.java b/client/test/src/org/apache/qpid/jndi/referenceabletest/JNDIReferenceableTest.java deleted file mode 100644 index 1b3caf8d47..0000000000 --- a/client/test/src/org/apache/qpid/jndi/referenceabletest/JNDIReferenceableTest.java +++ /dev/null @@ -1,123 +0,0 @@ -/* - * - * 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.jndi.referenceabletest; - -import org.junit.Test; -import org.junit.Assert; -import org.junit.After; -import org.junit.Before; -import org.apache.qpid.client.transport.TransportConnection; -import org.apache.qpid.client.vmbroker.AMQVMBrokerCreationException; -import junit.framework.JUnit4TestAdapter; - -import javax.naming.NameAlreadyBoundException; -import javax.naming.NoInitialContextException; - - -/** - * Usage: To run these you need to have the sun JNDI SPI for the FileSystem. - * This can be downloaded from sun here: - * http://java.sun.com/products/jndi/downloads/index.html - * Click : Download JNDI 1.2.1 & More button - * Download: File System Service Provider, 1.2 Beta 3 - * and add the two jars in the lib dir to your class path. - * <p/> - * Also you need to create the directory /temp/qpid-jndi-test - */ -public class JNDIReferenceableTest -{ - @Before - public void createVMBroker() - { - try - { - TransportConnection.createVMBroker(1); - } - catch (AMQVMBrokerCreationException e) - { - Assert.fail("Unable to create broker: " + e); - } - } - - @After - public void stopVmBroker() - { - TransportConnection.killVMBroker(1); - } - - @Test - public void referenceable() - { - Bind b = null; - try - { - try - { - b = new Bind(); - } - catch (NameAlreadyBoundException e) - { - if (new Unbind().unbound()) - { - try - { - b = new Bind(); - } - catch (NameAlreadyBoundException ee) - { - Assert.fail("Unable to clear bound objects for test."); - } - } - else - { - Assert.fail("Unable to clear bound objects for test."); - } - } - } - catch (NoInitialContextException e) - { - Assert.fail("You don't have the File System SPI on you class path.\n" + - "This can be downloaded from sun here:\n" + - "http://java.sun.com/products/jndi/downloads/index.html\n" + - "Click : Download JNDI 1.2.1 & More button\n" + - "Download: File System Service Provider, 1.2 Beta 3\n" + - "and add the two jars in the lib dir to your class path."); - } - - Assert.assertTrue(b.bound()); - - Lookup l = new Lookup(); - - Assert.assertTrue(l.connectionFactoryValue().equals(b.connectionFactoryValue())); - - Assert.assertTrue(l.connectionValue().equals(b.connectionValue())); - - Assert.assertTrue(l.topicValue().equals(b.topicValue())); - - - Unbind u = new Unbind(); - - Assert.assertTrue(u.unbound()); - - } - - public static junit.framework.Test suite() - { - return new JUnit4TestAdapter(JNDIReferenceableTest.class); - } -} diff --git a/client/test/src/org/apache/qpid/jndi/referenceabletest/Lookup.java b/client/test/src/org/apache/qpid/jndi/referenceabletest/Lookup.java deleted file mode 100644 index f2530b03b6..0000000000 --- a/client/test/src/org/apache/qpid/jndi/referenceabletest/Lookup.java +++ /dev/null @@ -1,136 +0,0 @@ -/* - * - * 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.jndi.referenceabletest; - -import org.apache.qpid.client.AMQConnection; -import org.apache.qpid.client.AMQConnectionFactory; -import org.apache.qpid.client.AMQTopic; - -import javax.naming.Context; -import javax.naming.InitialContext; -import javax.naming.NamingException; -import javax.jms.JMSException; -import java.io.File; -import java.util.Hashtable; - - -/** - * Usage: To run these you need to have the sun JNDI SPI for the FileSystem. - * This can be downloaded from sun here: - * http://java.sun.com/products/jndi/downloads/index.html - * Click : Download JNDI 1.2.1 & More button - * Download: File System Service Provider, 1.2 Beta 3 - * and add the two jars in the lib dir to your class path. - * <p/> - * Also you need to create the directory /temp/qpid-jndi-test - */ -class Lookup -{ - public static final String DEFAULT_PROVIDER_FILE_PATH = System.getProperty("java.io.tmpdir") + "/JNDITest"; - public static final String PROVIDER_URL = "file://" + DEFAULT_PROVIDER_FILE_PATH; - - AMQTopic _topic = null; - AMQConnection _connection = null; - AMQConnectionFactory _connectionFactory = null; - private String _connectionURL; - - public Lookup() - { - // Set up the environment for creating the initial context - Hashtable env = new Hashtable(11); - env.put(Context.INITIAL_CONTEXT_FACTORY, - "com.sun.jndi.fscontext.RefFSContextFactory"); - env.put(Context.PROVIDER_URL, PROVIDER_URL); - - File file = new File(PROVIDER_URL.substring(PROVIDER_URL.indexOf("://") + 3)); - - if (file.exists() && !file.isDirectory()) - { - System.out.println("Couldn't make directory file already exists"); - return; - } - else - { - if (!file.exists()) - { - if (!file.mkdirs()) - { - System.out.println("Couldn't make directory"); - return; - } - } - } - - try - { - // Create the initial context - Context ctx = new InitialContext(env); - - _topic = (AMQTopic) ctx.lookup("Topic"); - - _connection = (AMQConnection) ctx.lookup("Connection"); - - _connectionURL = _connection.toURL(); - - _connectionFactory = (AMQConnectionFactory) ctx.lookup("ConnectionFactory"); - //System.out.println(topic); - - // Close the context when we're done - ctx.close(); - } - catch (NamingException e) - { - System.out.println("Operation failed: " + e); - } - finally - { - try - { - if (_connection != null) - { - _connection.close(); - } - } - catch (JMSException e) - { - //ignore just need to close - } - } - } - - public String connectionFactoryValue() - { - return _connectionFactory.getConnectionURL().toString(); - } - - public String connectionValue() - { - return _connectionURL; - } - - public String topicValue() - { - return _topic.toURL(); - } - - public static void main(String[] args) - { - new Lookup(); - } -} - diff --git a/client/test/src/org/apache/qpid/jndi/referenceabletest/Unbind.java b/client/test/src/org/apache/qpid/jndi/referenceabletest/Unbind.java deleted file mode 100644 index 3440ffd6ce..0000000000 --- a/client/test/src/org/apache/qpid/jndi/referenceabletest/Unbind.java +++ /dev/null @@ -1,158 +0,0 @@ -/* - * - * 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.jndi.referenceabletest; - -import javax.naming.Context; -import javax.naming.InitialContext; -import javax.naming.NameNotFoundException; -import javax.naming.NamingException; -import javax.jms.Connection; -import javax.jms.JMSException; -import java.io.File; -import java.util.Hashtable; - -/** - * Usage: To run these you need to have the sun JNDI SPI for the FileSystem. - * This can be downloaded from sun here: - * http://java.sun.com/products/jndi/downloads/index.html - * Click : Download JNDI 1.2.1 & More button - * Download: File System Service Provider, 1.2 Beta 3 - * and add the two jars in the lib dir to your class path. - * <p/> - * Also you need to create the directory /temp/qpid-jndi-test - */ -class Unbind -{ - public static final String DEFAULT_PROVIDER_FILE_PATH = System.getProperty("java.io.tmpdir") + "/JNDITest"; - public static final String PROVIDER_URL = "file://" + DEFAULT_PROVIDER_FILE_PATH; - - boolean _unbound = false; - - public Unbind() - { - this(false); - } - - public Unbind(boolean output) - { - // Set up the environment for creating the initial context - Hashtable env = new Hashtable(11); - env.put(Context.INITIAL_CONTEXT_FACTORY, - "com.sun.jndi.fscontext.RefFSContextFactory"); - env.put(Context.PROVIDER_URL, PROVIDER_URL); - - File file = new File(PROVIDER_URL.substring(PROVIDER_URL.indexOf("://") + 3)); - - if (file.exists() && !file.isDirectory()) - { - System.out.println("Couldn't make directory file already exists"); - return; - } - else - { - if (!file.exists()) - { - if (!file.mkdirs()) - { - System.out.println("Couldn't make directory"); - return; - } - } - } - - try - { - // Create the initial context - Context ctx = new InitialContext(env); - - // Remove the binding - ctx.unbind("ConnectionFactory"); - ctx.unbind("Connection"); - ctx.unbind("Topic"); - - // Check that it is gone - Object obj = null; - try - { - obj = ctx.lookup("ConnectionFactory"); - } - catch (NameNotFoundException ne) - { - if (output) - { - System.out.println("unbind ConnectionFactory successful"); - } - try - { - obj = ctx.lookup("Connection"); - try - { - ((Connection) obj).close(); - } - catch (JMSException e) - { - //ignore just need to close - } - } - catch (NameNotFoundException ne2) - { - if (output) - { - System.out.println("unbind Connection successful"); - } - - try - { - obj = ctx.lookup("Topic"); - } - catch (NameNotFoundException ne3) - { - if (output) - { - System.out.println("unbind Topic successful"); - } - _unbound = true; - } - } - } - - //System.out.println("unbind failed; object still there: " + obj); - - // Close the context when we're done - - ctx.close(); - - } - catch (NamingException e) - { - System.out.println("Operation failed: " + e); - } - } - - public boolean unbound() - { - return _unbound; - } - - public static void main(String[] args) - { - - new Unbind(true); - } -} - diff --git a/client/test/src/org/apache/qpid/jndi/referenceabletest/UnitTests.java b/client/test/src/org/apache/qpid/jndi/referenceabletest/UnitTests.java deleted file mode 100644 index 0d5550cef9..0000000000 --- a/client/test/src/org/apache/qpid/jndi/referenceabletest/UnitTests.java +++ /dev/null @@ -1,33 +0,0 @@ -/* - * - * 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.jndi.referenceabletest; - -import org.junit.runner.RunWith; -import org.junit.runners.Suite; -import org.apache.qpid.ack.*; -import junit.framework.JUnit4TestAdapter; - -@RunWith(Suite.class) -@Suite.SuiteClasses({JNDIReferenceableTest.class}) -public class UnitTests -{ - public static junit.framework.Test suite() - { - return new JUnit4TestAdapter(org.apache.qpid.jndi.referenceabletest.UnitTests.class); - } -} diff --git a/client/test/src/org/apache/qpid/test/unit/client/connection/ConnectionTest.java b/client/test/src/org/apache/qpid/test/unit/client/connection/ConnectionTest.java index d88ca8322d..72630d0c8f 100644 --- a/client/test/src/org/apache/qpid/test/unit/client/connection/ConnectionTest.java +++ b/client/test/src/org/apache/qpid/test/unit/client/connection/ConnectionTest.java @@ -28,6 +28,7 @@ import org.junit.Test; import org.junit.Assert; import org.junit.Before; import org.junit.After; +import org.junit.Ignore; import javax.jms.Connection; @@ -73,7 +74,7 @@ public class ConnectionTest } } - @Test + @Test @Ignore //fixme The inVM broker currently has no authentication .. need a way to add it public void passwordFailureConnection() throws Exception { try diff --git a/client/test/src/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java b/client/test/src/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java index d9e01204bc..b3c6661c61 100644 --- a/client/test/src/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java +++ b/client/test/src/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java @@ -21,6 +21,7 @@ import org.junit.Test; import org.junit.Assert; import org.junit.Before; import org.junit.After; +import org.junit.Ignore; import org.apache.qpid.client.AMQConnectionURL; import org.apache.qpid.client.AMQBrokerDetails; import org.apache.qpid.client.vmbroker.AMQVMBrokerCreationException; @@ -323,7 +324,7 @@ public class ConnectionURLTest Assert.assertTrue(connectionurl.getBrokerCount() == 1); } - @Test + @Test @Ignore //FIXME Connection now parses but result is wrong public void wrongOptionSeperatorInBroker() { String url = "amqp://user:@/test?brokerlist='tcp://localhost:5672+option='value''"; |