@@ -0,0 +1,3475 @@
+/**%0A * Licensed to the Apache Software Foundation (ASF) under one or more%0A * contributor license agreements.  See the NOTICE file distributed with%0A * this work for additional information regarding copyright ownership.%0A * The ASF licenses this file to You under the Apache License, Version 2.0%0A * (the %22License%22); you may not use this file except in compliance with%0A * the License.  You may obtain a copy of the License at%0A *%0A *      http://www.apache.org/licenses/LICENSE-2.0%0A *%0A * Unless required by applicable law or agreed to in writing, software%0A * distributed under the License is distributed on an %22AS IS%22 BASIS,%0A * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0A * See the License for the specific language governing permissions and%0A * limitations under the License.%0A */%0Apackage org.apache.qpid.jms.provider.amqp;%0A%0Aimport static org.junit.Assert.assertEquals;%0Aimport static org.junit.Assert.assertNotNull;%0Aimport static org.junit.Assert.assertTrue;%0A%0Aimport java.io.IOException;%0Aimport java.net.URI;%0A%0Aimport org.apache.qpid.jms.provider.Provider;%0Aimport org.apache.qpid.jms.test.QpidJmsTestCase;%0Aimport org.apache.qpid.jms.test.testpeer.TestAmqpPeer;%0Aimport org.junit.After;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0A/**%0A * Test basic functionality of the AmqpProviderFactory%0A */%0Apublic class AmqpProviderFactoryTest extends QpidJmsTestCase %7B%0A%0A    private TestAmqpPeer testPeer;%0A    private URI peerURI;%0A%0A    @Override%0A    @Before%0A    public void setUp() throws Exception %7B%0A        testPeer = new TestAmqpPeer();%0A        peerURI = new URI(%22amqp://localhost:%22 + testPeer.getServerPort());%0A    %7D%0A%0A    @Override%0A    @After%0A    public void tearDown() throws Exception %7B%0A        if (testPeer != null) %7B%0A            testPeer.close();%0A            testPeer = null;%0A        %7D%0A    %7D%0A%0A    @Test(timeout = 10000)%0A    public void testGetName() throws IOException, Exception %7B%0A        AmqpProviderFactory factory = new AmqpProviderFactory();%0A        assertEquals(%22AMQP%22, factory.getName());%0A    %7D%0A%0A    @Test(timeout = 10000)%0A    public void testCreateProvider() throws IOException, Exception %7B%0A        Provider provider = AmqpProviderFactory.create(peerURI);%0A        assertNotNull(provider);%0A        assertTrue(provider instanceof AmqpProvider);%0A    %7D%0A%0A    @Test(timeout = 10000, expected=IllegalArgumentException.class)%0A    public void testCreateProviderFailsWithBadOption() throws IOException, Exception %7B%0A        URI badOptionsURI = new URI(peerURI.toString() + %22?amqp.badOption=true%22);%0A        AmqpProviderFactory.create(badOptionsURI);%0A    %7D%0A%0A    @Test(timeout = 10000)%0A    public void testCreateProviderAppliesOptions() throws IOException, Exception %7B%0A        URI configuredURI = new URI(peerURI.toString() +%0A            %22?amqp.presettleConsumers=true%22 +%0A            %22&amqp.presettleProducers=true%22 +%0A            %22&amqp.traceFrames=true%22 +%0A            %22&amqp.traceBytes=true%22 +%0A            %22&amqp.channelMax=32%22);%0A        Provider provider = AmqpProviderFactory.create(configuredURI);%0A        assertNotNull(provider);%0A        assertTrue(provider instanceof AmqpProvider);%0A%0A        AmqpProvider amqpProvider = (AmqpProvider) provider;%0A%0A        assertEquals(true, amqpProvider.isPresettleConsumers());%0A        assertEquals(true, amqpProvider.isPresettleProducers());%0A        assertEquals(true, amqpProvider.isTraceBytes());%0A        assertEquals(true, amqpProvider.isTraceFrames());%0A        assertEquals(32, amqpProvider.getChannelMax());%0A    %7D%0A%7D%0A

Test some basics of the AmqpProviderFactory.