qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject [04/34] qpid-proton git commit: PROTON-1385: remove proton-j from the existing repo, it now has its own repo at: https://git-wip-us.apache.org/repos/asf/qpid-proton-j.git
Date Mon, 09 Jan 2017 15:24:40 GMT
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/InteropTest.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/InteropTest.java b/tests/java/org/apache/qpid/proton/InteropTest.java
deleted file mode 100644
index e9b8c58..0000000
--- a/tests/java/org/apache/qpid/proton/InteropTest.java
+++ /dev/null
@@ -1,219 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.proton;
-
-import org.apache.qpid.proton.amqp.Binary;
-import org.apache.qpid.proton.amqp.DescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.messaging.AmqpValue;
-import org.apache.qpid.proton.codec.AMQPDefinedTypes;
-import org.apache.qpid.proton.codec.Decoder;
-import org.apache.qpid.proton.codec.DecoderImpl;
-import org.apache.qpid.proton.codec.EncoderImpl;
-import org.apache.qpid.proton.message.Message;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertArrayEquals;
-import org.junit.Test;
-import java.lang.System;
-import java.nio.ByteBuffer;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.util.Vector;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-
-public class InteropTest
-{
-
-    static private File findTestsInteropDir()
-    {
-        File f = new File(System.getProperty("user.dir"));
-        while (f != null && !f.getName().equals("tests"))
-            f = f.getParentFile();
-        if (f != null && f.isDirectory())
-            return new File(f, "interop");
-        else
-            throw new Error("Cannot find tests/interop directory");
-    }
-
-    static File testsInteropDir = findTestsInteropDir();
-
-    byte[] getBytes(String name) throws IOException
-    {
-        File f = new File(testsInteropDir, name + ".amqp");
-        byte[] data = new byte[(int) f.length()];
-        FileInputStream fi = new FileInputStream(f);
-        assertEquals(f.length(), fi.read(data));
-        fi.close();
-        return data;
-    }
-
-    Message decodeMessage(String name) throws IOException
-    {
-        byte[] data = getBytes(name);
-        Message m = Proton.message();
-        m.decode(data, 0, data.length);
-        return m;
-    }
-
-    Decoder createDecoder(byte[] data)
-    {
-        DecoderImpl decoder = new DecoderImpl();
-        AMQPDefinedTypes.registerAllTypes(decoder, new EncoderImpl(decoder));
-        ByteBuffer buffer = ByteBuffer.allocate(data.length);
-        buffer.put(data);
-        buffer.rewind();
-        decoder.setByteBuffer(buffer);
-
-        return decoder;
-    }
-
-    @Test
-    public void testMessage() throws IOException
-    {
-        Message m = decodeMessage("message");
-        Binary b = (Binary) (((AmqpValue) m.getBody()).getValue());
-        String s = createDecoder(b.getArray()).readString();
-        assertEquals("hello", s);
-    }
-
-    @Test
-    public void testPrimitives() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("primitives"));
-        assertEquals(true, d.readBoolean());
-        assertEquals(false, d.readBoolean());
-        assertEquals(d.readUnsignedByte().intValue(), 42);
-        assertEquals(42, d.readUnsignedShort().intValue());
-        assertEquals(-42, d.readShort().intValue());
-        assertEquals(12345, d.readUnsignedInteger().intValue());
-        assertEquals(-12345, d.readInteger().intValue());
-        assertEquals(12345, d.readUnsignedLong().longValue());
-        assertEquals(-12345, d.readLong().longValue());
-        assertEquals(0.125, d.readFloat().floatValue(), 0e-10);
-        assertEquals(0.125, d.readDouble().doubleValue(), 0e-10);
-    }
-
-    @Test
-    public void testStrings() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("strings"));
-        assertEquals(new Binary("abc\0defg".getBytes("UTF-8")), d.readBinary());
-        assertEquals("abcdefg", d.readString());
-        assertEquals(Symbol.valueOf("abcdefg"), d.readSymbol());
-        assertEquals(new Binary(new byte[0]), d.readBinary());
-        assertEquals("", d.readString());
-        assertEquals(Symbol.valueOf(""), d.readSymbol());
-    }
-
-    @Test
-    public void testDescribed() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("described"));
-        DescribedType dt = (DescribedType) (d.readObject());
-        assertEquals(Symbol.valueOf("foo-descriptor"), dt.getDescriptor());
-        assertEquals("foo-value", dt.getDescribed());
-
-        dt = (DescribedType) (d.readObject());
-        assertEquals(12, dt.getDescriptor());
-        assertEquals(13, dt.getDescribed());
-    }
-
-    @Test
-    public void testDescribedArray() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("described_array"));
-        DescribedType a[] = (DescribedType[]) (d.readArray());
-        for (int i = 0; i < 10; ++i)
-        {
-            assertEquals(Symbol.valueOf("int-array"), a[i].getDescriptor());
-            assertEquals(i, a[i].getDescribed());
-        }
-    }
-
-    @Test
-    public void testArrays() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("arrays"));
-
-        // int array
-        Vector<Integer> ints = new Vector<Integer>();
-        for (int i = 0; i < 100; ++i)
-            ints.add(new Integer(i));
-        assertArrayEquals(ints.toArray(), d.readArray());
-
-        // String array
-        String strings[] =
-        { "a", "b", "c" };
-        assertArrayEquals(strings, d.readArray());
-
-        // Empty array
-        assertArrayEquals(new Integer[0], d.readArray());
-    }
-
-    @Test
-    public void testLists() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("lists"));
-        List<Object> l = new ArrayList<Object>()
-        {
-            {
-                add(new Integer(32));
-                add("foo");
-                add(new Boolean(true));
-            }
-        };
-        assertEquals(l, d.readList());
-        l.clear();
-        assertEquals(l, d.readList());
-    }
-
-    @SuppressWarnings({ "rawtypes", "unchecked" })
-    @Test
-    public void testMaps() throws IOException
-    {
-        Decoder d = createDecoder(getBytes("maps"));
-        Map map = new HashMap()
-        {
-            {
-                put("one", 1);
-                put("two", 2);
-                put("three", 3);
-            }
-        };
-        assertEquals(map, d.readMap());
-
-        map = new HashMap()
-        {
-            {
-                put(1, "one");
-                put(2, "two");
-                put(3, "three");
-            }
-        };
-        assertEquals(map, d.readMap());
-
-        map = new HashMap();
-        assertEquals(map, d.readMap());
-    }
-}

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/JythonTest.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/JythonTest.java b/tests/java/org/apache/qpid/proton/JythonTest.java
deleted file mode 100644
index 23eceab..0000000
--- a/tests/java/org/apache/qpid/proton/JythonTest.java
+++ /dev/null
@@ -1,283 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.proton;
-
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.junit.Test;
-import org.python.core.PyException;
-import org.python.core.PyString;
-import org.python.core.PySystemState;
-import org.python.util.PythonInterpreter;
-
-/**
- * Runs all the python tests, or just those that match the system property {@value #TEST_PATTERN_SYSTEM_PROPERTY}
- * if it exists.
- * Use {@value #TEST_INVOCATIONS_SYSTEM_PROPERTY} to specify the number of repetitions, or use 0
- * for unlimited repetitions.
- */
-public class JythonTest
-{
-    public interface PathBuilder {
-        public PathBuilder append(String path);
-    }
-    private static final Logger LOGGER = Logger.getLogger(JythonTest.class.getName());
-
-    /* System properties expected to be defined in test/pom.xml */
-    private static final String PROTON_JYTHON_BINDING = "protonJythonBinding";
-    private static final String PROTON_JYTHON_SHIM = "protonJythonShim";
-    private static final String PROTON_JYTHON_TEST_ROOT = "protonJythonTestRoot";
-    private static final String PROTON_JYTHON_TEST_SCRIPT = "protonJythonTestScript";
-    private static final String PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY = "protonJythonTestXmlOutputDirectory";
-    private static final String PROTON_JYTHON_IGNORE_FILE = "protonJythonIgnoreFile";
-
-    /** Name of the junit style xml report to be written by the python test script */
-    private static final String XML_REPORT_NAME = "TEST-jython-test-results.xml";
-
-    public static final String TEST_PATTERN_SYSTEM_PROPERTY = "proton.pythontest.pattern";
-    public static final String IGNORE_FILE_SYSTEM_PROPERTY = "proton.pythontest.ignore_file";
-
-    /** The number of times to run the test, or forever if zero */
-    public static final String TEST_INVOCATIONS_SYSTEM_PROPERTY = "proton.pythontest.invocations";
-
-    public static final String ALWAYS_COLORIZE_SYSTEM_PROPERTY = "proton.pythontest.always_colorize";
-
-    @Test
-    public void test() throws Exception
-    {
-        String testScript = getJythonTestScript();
-        String testRoot = getJythonTestRoot();
-        String xmlReportFile = getOptionalXmlReportFilename();
-        String ignoreFile = getOptionalIgnoreFile();
-
-        final PythonInterpreter interp = createInterpreterWithArgs(xmlReportFile, ignoreFile);
-        PathBuilder pathBuilder = new PathBuilder() {
-            @Override
-            public PathBuilder append(String path) {
-                interp.getSystemState().path.insert(0, new PyString(path));
-                return this;
-            }
-        };
-        extendPath(pathBuilder);
-
-        LOGGER.info("About to call Jython test script: '" + testScript
-                + "' with '" + testRoot + "' added to Jython path");
-
-        int maxInvocations = Integer.getInteger(TEST_INVOCATIONS_SYSTEM_PROPERTY, 1);
-        assertTrue("Number of invocations should be non-negative", maxInvocations >= 0);
-        boolean loopForever = maxInvocations == 0;
-        if(maxInvocations > 1)
-        {
-            LOGGER.info("Will invoke Python test " + maxInvocations + " times");
-        }
-        if(loopForever)
-        {
-            LOGGER.info("Will repeatedly invoke Python test forever");
-        }
-        int invocations = 1;
-        while(loopForever || invocations++ <= maxInvocations)
-        {
-            runTestOnce(testScript, interp, invocations);
-        }
-    }
-
-    protected void extendPath(PathBuilder pathBuilder) throws Exception {
-        String binding = getJythonBinding();
-        String shim = getJythonShim();
-        String testRoot = getJythonTestRoot();
-        pathBuilder.append(binding).append(shim).append(testRoot);
-
-    }
-
-    private void runTestOnce(String testScript, PythonInterpreter interp, int invocationsSoFar)
-    {
-        try
-        {
-            interp.execfile(testScript);
-        }
-        catch (PyException e)
-        {
-            if( e.type.toString().equals("<type 'exceptions.SystemExit'>") && e.value.toString().equals("0") )
-            {
-                // Build succeeded.
-            }
-            else
-            {
-                if (LOGGER.isLoggable(Level.FINE))
-                {
-                    LOGGER.log(Level.FINE, "Jython interpreter failed. Test failures?", e);
-                }
-
-                // This unusual code is necessary because PyException toString() contains the useful Python traceback
-                // and getMessage() is usually null
-                fail("Caught PyException on invocation number " + invocationsSoFar + ": " + e.toString() + " with message: " + e.getMessage());
-            }
-        }
-    }
-
-    private PythonInterpreter createInterpreterWithArgs(String xmlReportFile, String ignoreFile)
-    {
-        PySystemState systemState = new PySystemState();
-
-        if (xmlReportFile != null)
-        {
-            systemState.argv.append(new PyString("--xml"));
-            systemState.argv.append(new PyString(xmlReportFile));
-        }
-
-        if(ignoreFile == null)
-        {
-            ignoreFile = System.getProperty(IGNORE_FILE_SYSTEM_PROPERTY);
-        }
-
-        if(ignoreFile != null)
-        {
-            systemState.argv.append(new PyString("-I"));
-            systemState.argv.append(new PyString(ignoreFile));
-        }
-
-        String testPattern = System.getProperty(TEST_PATTERN_SYSTEM_PROPERTY);
-        if(testPattern != null)
-        {
-            systemState.argv.append(new PyString(testPattern));
-        }
-
-        if(Boolean.getBoolean(ALWAYS_COLORIZE_SYSTEM_PROPERTY))
-        {
-            systemState.argv.append(new PyString("--always-colorize"));
-        }
-
-        PythonInterpreter interp = new PythonInterpreter(null, systemState);
-        return interp;
-    }
-
-    private String getJythonTestScript() throws FileNotFoundException
-    {
-        String testScriptString = getNonNullSystemProperty(PROTON_JYTHON_TEST_SCRIPT, "System property '%s' must provide the location of the python test script");
-        File testScript = new File(testScriptString);
-        if (!testScript.canRead())
-        {
-            throw new FileNotFoundException("Can't read python test script " + testScript);
-        }
-        return testScript.getAbsolutePath();
-    }
-
-    private String getJythonBinding() throws FileNotFoundException
-    {
-        String str = getNonNullSystemProperty(PROTON_JYTHON_BINDING, "System property '%s' must provide the location of the proton python binding");
-        File file = new File(str);
-        if (!file.isDirectory())
-        {
-            throw new FileNotFoundException("Binding location '" + file + "' should be a directory.");
-        }
-        return file.getAbsolutePath();
-    }
-
-    private String getJythonShim() throws FileNotFoundException
-    {
-        String str = getNonNullSystemProperty(PROTON_JYTHON_SHIM, "System property '%s' must provide the location of the proton jython shim");
-        File file = new File(str);
-        if (!file.isDirectory())
-        {
-            throw new FileNotFoundException("Shim location '" + file + "' should be a directory.");
-        }
-        return file.getAbsolutePath();
-    }
-
-
-    private String getJythonTestRoot() throws FileNotFoundException
-    {
-        String testRootString = getNonNullSystemProperty(PROTON_JYTHON_TEST_ROOT, "System property '%s' must provide the location of the python test root");
-        File testRoot = new File(testRootString);
-        if (!testRoot.isDirectory())
-        {
-            throw new FileNotFoundException("Test root '" + testRoot + "' should be a directory.");
-        }
-        return testRoot.getAbsolutePath();
-    }
-
-    private String getOptionalIgnoreFile()
-    {
-        String ignoreFile = System.getProperty(PROTON_JYTHON_IGNORE_FILE);
-
-        if(ignoreFile != null)
-        {
-            File f = new File(ignoreFile);
-            if(f.exists() && f.canRead())
-            {
-                return ignoreFile;
-            }
-            else
-            {
-                LOGGER.info(PROTON_JYTHON_IGNORE_FILE + " system property set to " + ignoreFile + " but this cannot be read.");
-            }
-        }
-        return null;
-        
-    }
-
-    private String getOptionalXmlReportFilename()
-    {
-        String xmlOutputDirString = System.getProperty(PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY);
-        if (xmlOutputDirString == null)
-        {
-            LOGGER.info(PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY + " system property not set; xml output will not be written");
-        }
-
-        File xmlOutputDir = new File(xmlOutputDirString);
-        createXmlOutputDirectoryIfNecessary(xmlOutputDirString, xmlOutputDir);
-        return new File(xmlOutputDir, XML_REPORT_NAME).getAbsolutePath();
-    }
-
-    private void createXmlOutputDirectoryIfNecessary(String xmlOutputDirString, File xmlOutputDir)
-    {
-        if (!xmlOutputDir.isDirectory())
-        {
-            boolean success = xmlOutputDir.mkdirs();
-            if (!success)
-            {
-                LOGGER.warning("Failed to create directory " + xmlOutputDir + " Thread name :" + Thread.currentThread().getName());
-            }
-
-            if (!xmlOutputDir.isDirectory())
-            {
-                throw new RuntimeException("Failed to create one or more directories with path " + xmlOutputDirString);
-            }
-        }
-    }
-
-    protected String getNonNullSystemProperty(String systemProperty, String messageWithStringFormatToken)
-    {
-        String testScriptString = System.getProperty(systemProperty);
-        if (testScriptString == null)
-        {
-            String message = messageWithStringFormatToken;
-            throw new IllegalStateException(String.format(message, systemProperty));
-        }
-        return testScriptString;
-    }
-}

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/ProtonJInterop.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/ProtonJInterop.java b/tests/java/org/apache/qpid/proton/ProtonJInterop.java
deleted file mode 100644
index 58a9c31..0000000
--- a/tests/java/org/apache/qpid/proton/ProtonJInterop.java
+++ /dev/null
@@ -1,205 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you 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.proton;
-
-import java.io.IOException;
-import java.nio.BufferOverflowException;
-
-import org.apache.qpid.proton.amqp.messaging.AmqpValue;
-import org.apache.qpid.proton.amqp.transport.ErrorCondition;
-import org.apache.qpid.proton.engine.BaseHandler;
-import org.apache.qpid.proton.engine.Connection;
-import org.apache.qpid.proton.engine.Delivery;
-import org.apache.qpid.proton.engine.EndpointState;
-import org.apache.qpid.proton.engine.Event;
-import org.apache.qpid.proton.engine.Receiver;
-import org.apache.qpid.proton.engine.Sender;
-import org.apache.qpid.proton.engine.Session;
-import org.apache.qpid.proton.message.Message;
-import org.apache.qpid.proton.reactor.Acceptor;
-import org.apache.qpid.proton.reactor.FlowController;
-import org.apache.qpid.proton.reactor.Handshaker;
-import org.apache.qpid.proton.reactor.Reactor;
-
-public class ProtonJInterop {
-
-    private static class SendHandler extends BaseHandler {
-
-        private int numMsgs;
-        private int count = 0;
-        private boolean result = false;
-
-        private SendHandler(int numMsgs) {
-            this.numMsgs = numMsgs;
-            add(new Handshaker());
-        }
-
-        @Override
-        public void onConnectionInit(Event event) {
-            Connection conn = event.getConnection();
-            Session ssn = conn.session();
-            Sender snd = ssn.sender("sender");
-            conn.open();
-            ssn.open();
-            snd.open();
-        }
-
-        @Override
-        public void onLinkFlow(Event event) {
-            Sender snd = (Sender)event.getLink();
-            if (snd.getCredit() > 0 && snd.getLocalState() != EndpointState.CLOSED) {
-                Message message = Proton.message();
-                ++count;
-                message.setBody(new AmqpValue("message-"+count));
-                byte[] msgData = new byte[1024];
-                int length;
-                while(true) {
-                    try {
-                        length = message.encode(msgData, 0, msgData.length);
-                        break;
-                    } catch(BufferOverflowException e) {
-                        msgData = new byte[msgData.length * 2];
-                    }
-                }
-                byte[] tag = String.valueOf(count).getBytes();
-                Delivery dlv = snd.delivery(tag);
-                snd.send(msgData, 0, length);
-                dlv.settle();
-                snd.advance();
-                if (count == numMsgs) {
-                    snd.close();
-                    snd.getSession().close();
-                    snd.getSession().getConnection().close();
-                    result = true;
-                }
-            }
-        }
-
-        @Override
-        public void onTransportError(Event event) {
-            result = false;
-            ErrorCondition condition = event.getTransport().getCondition();
-            if (condition != null) {
-                System.err.println("Error: " + condition.getDescription());
-            } else {
-                System.err.println("Error (no description returned).");
-            }
-        }
-    }
-
-    private static class Send extends BaseHandler {
-        private final SendHandler sendHandler;
-        private final String host;
-        private final int port;
-
-        private Send(String host, int port, int numMsgs) {
-            this.host = host;
-            this.port = port;
-            sendHandler = new SendHandler(numMsgs);
-        }
-
-        @Override
-        public void onReactorInit(Event event) {
-            Reactor r = event.getReactor();
-            r.connectionToHost(host, port, sendHandler);
-        }
-
-        public boolean getResult() {
-            return sendHandler.result;
-        }
-    }
-
-    private static class Recv extends BaseHandler {
-        private final int port;
-        private final int numMsgs;
-        private int count = 0;
-        private Acceptor acceptor = null;
-
-        private Recv(int port, int numMsgs) {
-            this.port = port;
-            this.numMsgs = numMsgs;
-            add(new Handshaker());
-            add(new FlowController());
-        }
-
-        @Override
-        public void onReactorInit(Event event) {
-            try {
-                acceptor = event.getReactor().acceptor("localhost", port);
-            } catch(IOException ioException) {
-                throw new RuntimeException(ioException);
-            }
-        }
-
-        @Override
-        public void onDelivery(Event event) {
-            Receiver recv = (Receiver)event.getLink();
-            Delivery delivery = recv.current();
-            if (delivery.isReadable() && !delivery.isPartial()) {
-                int size = delivery.pending();
-                byte[] buffer = new byte[size];
-                int read = recv.recv(buffer, 0, buffer.length);
-                recv.advance();
-
-                Message msg = Proton.message();
-                msg.decode(buffer, 0, read);
-
-                ++count;
-                String msgBody = ((AmqpValue)msg.getBody()).getValue().toString();
-                String expected = "message-" + count;
-                if (!expected.equals(msgBody)) {
-                    throw new RuntimeException("Received message body '" + msgBody + "', expected: '" + expected + "'");
-                }
-
-                if (count == numMsgs) {
-                    recv.close();
-                    recv.getSession().close();
-                    recv.getSession().getConnection().close();
-                    acceptor.close();
-                }
-            }
-        }
-    }
-
-    public static void main(String[] args) throws IOException {
-        try {
-            int port = Integer.valueOf(args[1]);
-            int numMsgs = Integer.valueOf(args[2]);
-            boolean result = false;
-
-            if ("send".equalsIgnoreCase(args[0])) {
-                Send send = new Send("localhost", port, numMsgs);
-                Reactor r = Proton.reactor(send);
-                r.run();
-                result = send.getResult();
-            } else {
-                Reactor r = Proton.reactor(new Recv(port, numMsgs));
-                r.run();
-                result = true;
-            }
-            System.exit(result ? 0 : 1);
-        } catch(Throwable t) {
-            t.printStackTrace();
-            System.exit(1);
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/pythonTests.ignore
----------------------------------------------------------------------
diff --git a/tests/java/pythonTests.ignore b/tests/java/pythonTests.ignore
deleted file mode 100644
index 7911176..0000000
--- a/tests/java/pythonTests.ignore
+++ /dev/null
@@ -1,4 +0,0 @@
-proton_tests.reactor_interop.*
-proton_tests.soak.*
-proton_tests.ssl.SslTest.test_defaults_messenger_app
-proton_tests.ssl.SslTest.test_server_authentication_messenger_app

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/ccodec.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/ccodec.py b/tests/java/shim/ccodec.py
deleted file mode 100644
index 0aa9499..0000000
--- a/tests/java/shim/ccodec.py
+++ /dev/null
@@ -1,356 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp import Symbol, UnsignedByte, UnsignedInteger, \
-  UnsignedShort, UnsignedLong, Decimal32, Decimal64, Decimal128
-from org.apache.qpid.proton.codec.Data import DataType
-from cerror import *
-
-from java.util import UUID as JUUID, Date as JDate
-from java.nio import ByteBuffer
-from compat import array, zeros
-
-# from proton/codec.h
-PN_NULL = 1
-PN_BOOL = 2
-PN_UBYTE = 3
-PN_BYTE = 4
-PN_USHORT = 5
-PN_SHORT = 6
-PN_UINT = 7
-PN_INT = 8
-PN_CHAR = 9
-PN_ULONG = 10
-PN_LONG = 11
-PN_TIMESTAMP = 12
-PN_FLOAT = 13
-PN_DOUBLE = 14
-PN_DECIMAL32 = 15
-PN_DECIMAL64 = 16
-PN_DECIMAL128 = 17
-PN_UUID = 18
-PN_BINARY = 19
-PN_STRING = 20
-PN_SYMBOL = 21
-PN_DESCRIBED = 22
-PN_ARRAY = 23
-PN_LIST = 24
-PN_MAP = 25
-
-DATA_TYPES_J2P = {}
-DATA_TYPES_P2J = {}
-
-def DATA_TYPES(jtype, ptype):
-  DATA_TYPES_J2P[jtype] = ptype
-  DATA_TYPES_P2J[ptype] = jtype
-
-DATA_TYPES(DataType.NULL, PN_NULL)
-DATA_TYPES(DataType.BOOL, PN_BOOL)
-DATA_TYPES(DataType.BYTE, PN_BYTE)
-DATA_TYPES(DataType.UBYTE, PN_UBYTE)
-DATA_TYPES(DataType.USHORT, PN_USHORT)
-DATA_TYPES(DataType.UINT, PN_UINT)
-DATA_TYPES(DataType.ULONG, PN_ULONG)
-DATA_TYPES(DataType.SHORT, PN_SHORT)
-DATA_TYPES(DataType.INT, PN_INT)
-DATA_TYPES(DataType.LONG, PN_LONG)
-DATA_TYPES(DataType.CHAR, PN_CHAR)
-DATA_TYPES(DataType.TIMESTAMP, PN_TIMESTAMP)
-DATA_TYPES(DataType.FLOAT, PN_FLOAT)
-DATA_TYPES(DataType.DOUBLE, PN_DOUBLE)
-DATA_TYPES(DataType.DECIMAL32, PN_DECIMAL32)
-DATA_TYPES(DataType.DECIMAL64, PN_DECIMAL64)
-DATA_TYPES(DataType.DECIMAL128, PN_DECIMAL128)
-DATA_TYPES(DataType.BINARY, PN_BINARY)
-DATA_TYPES(DataType.STRING, PN_STRING)
-DATA_TYPES(DataType.SYMBOL, PN_SYMBOL)
-DATA_TYPES(DataType.UUID, PN_UUID)
-DATA_TYPES(DataType.LIST, PN_LIST)
-DATA_TYPES(DataType.MAP, PN_MAP)
-DATA_TYPES(DataType.ARRAY, PN_ARRAY)
-DATA_TYPES(DataType.DESCRIBED, PN_DESCRIBED)
-
-def pn_data(capacity):
-  return Proton.data(capacity)
-
-def pn_data_put_null(data):
-  data.putNull()
-  return 0
-
-def pn_data_put_bool(data, b):
-  data.putBoolean(b)
-  return 0
-
-def pn_data_get_bool(data):
-  return data.getBoolean()
-
-def pn_data_get_byte(data):
-  return data.getByte()
-
-def pn_data_put_byte(data, u):
-  data.putByte(u)
-  return 0
-
-def pn_data_get_ubyte(data):
-  return data.getUnsignedByte().longValue()
-
-def pn_data_put_ubyte(data, u):
-  data.putUnsignedByte(UnsignedByte.valueOf(u))
-  return 0
-
-def pn_data_get_ushort(data):
-  return data.getUnsignedShort().longValue()
-
-def pn_data_put_ushort(data, u):
-  data.putUnsignedShort(UnsignedShort.valueOf(u))
-  return 0
-
-def pn_data_get_uint(data):
-  return data.getUnsignedInteger().longValue()
-
-def pn_data_put_uint(data, u):
-  data.putUnsignedInteger(UnsignedInteger.valueOf(u))
-  return 0
-
-def pn_data_put_ulong(data, u):
-  data.putUnsignedLong(UnsignedLong.valueOf(u))
-  return 0
-
-BITS_64 = 2**64 - 1;
-
-def pn_data_get_ulong(data):
-  value =  data.getUnsignedLong().longValue()
-  if value < 0:
-    return value & BITS_64;
-  return value
-
-def pn_data_get_short(data):
-  return data.getShort()
-
-def pn_data_put_short(data, s):
-  data.putShort(s)
-  return 0
-
-def pn_data_put_int(data, i):
-  data.putInt(i)
-  return 0
-
-def pn_data_get_int(data):
-  return data.getInt()
-
-def pn_data_put_long(data, l):
-  data.putLong(l)
-  return 0
-
-def pn_data_get_long(data):
-  return data.getLong()
-
-def pn_data_put_char(data, c):
-  data.putChar(c)
-  return 0
-
-def pn_data_get_char(data):
-  return data.getChar()
-
-def pn_data_put_timestamp(data, t):
-  data.putTimestamp(JDate(t))
-  return 0
-
-def pn_data_get_timestamp(data):
-  return data.getTimestamp().getTime()
-
-def pn_data_put_float(data, f):
-  data.putFloat(f)
-  return 0
-
-def pn_data_get_float(data):
-  return data.getFloat()
-
-def pn_data_put_double(data, d):
-  data.putDouble(d)
-  return 0
-
-def pn_data_get_double(data):
-  return data.getDouble()
-
-def pn_data_put_decimal32(data, d):
-  data.putDecimal32(Decimal32(d))
-  return 0
-
-def pn_data_get_decimal32(data):
-  return data.getDecimal32().getBits()
-
-def pn_data_put_decimal64(data, d):
-  data.putDecimal64(Decimal64(d))
-  return 0
-
-def pn_data_get_decimal64(data):
-  return data.getDecimal64().getBits()
-
-def pn_data_put_decimal128(data, d):
-  data.putDecimal128(Decimal128(array(d, 'b')))
-  return 0
-
-def pn_data_get_decimal128(data):
-  return data.getDecimal128().asBytes().tostring()
-
-def pn_data_put_binary(data, b):
-  data.putBinary(array(b, 'b'))
-  return 0
-
-def pn_data_get_binary(data):
-  return data.getBinary().getArray().tostring()
-
-def pn_data_put_string(data, s):
-  data.putString(s)
-  return 0
-
-def pn_data_get_string(data):
-  return data.getString()
-
-def pn_data_put_symbol(data, s):
-  data.putSymbol(Symbol.valueOf(s))
-  return 0
-
-def pn_data_get_symbol(data):
-  return data.getSymbol().toString()
-
-def pn_data_put_uuid(data, u):
-  bb = ByteBuffer.wrap(array(u, 'b'))
-  first = bb.getLong()
-  second = bb.getLong()
-  data.putUUID(JUUID(first, second))
-  return 0
-
-def pn_data_get_uuid(data):
-  u = data.getUUID()
-  ba = zeros(16, 'b')
-  bb = ByteBuffer.wrap(ba)
-  bb.putLong(u.getMostSignificantBits())
-  bb.putLong(u.getLeastSignificantBits())
-  return ba.tostring()
-
-def pn_data_put_list(data):
-  data.putList()
-  return 0
-
-def pn_data_get_list(data):
-  return data.getList()
-
-def pn_data_put_map(data):
-  data.putMap()
-  return 0
-
-def pn_data_put_array(data, described, type):
-  data.putArray(described, DATA_TYPES_P2J[type])
-  return 0
-
-def pn_data_get_array(data):
-  return data.getArray()
-
-def pn_data_is_array_described(data):
-  return data.isArrayDescribed()
-
-def pn_data_get_array_type(data):
-  return DATA_TYPES_J2P[data.getArrayType()]
-
-def pn_data_put_described(data):
-  data.putDescribed()
-  return 0
-
-def pn_data_rewind(data):
-  data.rewind()
-
-def pn_data_next(data):
-  t = data.next()
-  return t != None
-
-def pn_data_enter(data):
-  return data.enter()
-
-def pn_data_exit(data):
-  return data.exit()
-
-def pn_data_type(data):
-  t = data.type()
-  if t is None:
-    return -1
-  else:
-    return DATA_TYPES_J2P[t]
-
-def pn_data_encode(data, size):
-  enc = data.encode().getArray().tostring()
-  if len(enc) > size:
-    return PN_OVERFLOW, None
-  else:
-    return len(enc), enc
-
-def pn_data_encoded_size(data):
-  return data.encodedSize()
-
-def pn_data_decode(data, encoded):
-  return data.decode(ByteBuffer.wrap(array(encoded, 'b')))
-
-def pn_data_narrow(data):
-  data.narrow()
-
-def pn_data_widen(data):
-  data.widen()
-
-def pn_data_copy(data, src):
-  data.copy(src)
-
-def pn_data_format(data, n):
-  return 0, data.format()
-
-def pn_data_clear(data):
-  data.clear()
-
-def pn_data_free(data):
-  pass
-
-def dat2obj(dat):
-  dat.rewind()
-  if dat.next():
-    return dat.getObject()
-  else:
-    return None
-
-def obj2dat(obj, dat=None):
-  if dat is None:
-    dat = pn_data(0)
-  else:
-    dat.clear()
-  if obj:
-    dat.putObject(obj)
-  dat.rewind()
-  return dat
-
-def array2dat(ary, atype, dat=None):
-  if dat is None:
-    dat = pn_data(0)
-  else:
-    dat.clear()
-  if ary:
-    pn_data_put_array(dat, False, atype)
-    pn_data_enter(dat)
-    for o in ary:
-      dat.putObject(o)
-  dat.rewind()
-  return dat

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cengine.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cengine.py b/tests/java/shim/cengine.py
deleted file mode 100644
index 141c482..0000000
--- a/tests/java/shim/cengine.py
+++ /dev/null
@@ -1,1139 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp import Symbol
-from org.apache.qpid.proton.amqp.messaging import Source, Target, \
-  TerminusDurability, TerminusExpiryPolicy, Received, Accepted, \
-  Rejected, Released, Modified
-from org.apache.qpid.proton.amqp.transaction import Coordinator
-from org.apache.qpid.proton.amqp.transport import ErrorCondition, \
-  SenderSettleMode, ReceiverSettleMode
-from org.apache.qpid.proton.engine import EndpointState, Sender, \
-  Receiver, Transport as _Transport, TransportException, EventType
-
-from java.util import EnumSet
-from compat import array, zeros
-
-from cerror import *
-from ccodec import *
-
-# from proton/engine.h
-PN_LOCAL_UNINIT = 1
-PN_LOCAL_ACTIVE = 2
-PN_LOCAL_CLOSED = 4
-PN_REMOTE_UNINIT = 8
-PN_REMOTE_ACTIVE = 16
-PN_REMOTE_CLOSED = 32
-
-PN_SND_UNSETTLED = 0
-PN_SND_SETTLED = 1
-PN_SND_MIXED = 2
-
-PN_RCV_FIRST = 0
-PN_RCV_SECOND = 1
-
-PN_UNSPECIFIED = 0
-PN_SOURCE = 1
-PN_TARGET = 2
-PN_COORDINATOR = 3
-
-PN_NONDURABLE = 0
-PN_CONFIGURATION = 1
-PN_DELIVERIES = 2
-
-PN_EXPIRE_WITH_LINK = 0
-PN_EXPIRE_WITH_SESSION = 1
-PN_EXPIRE_WITH_CONNECTION = 2
-PN_EXPIRE_NEVER = 3
-
-PN_DIST_MODE_UNSPECIFIED = 0
-PN_DIST_MODE_COPY = 1
-PN_DIST_MODE_MOVE = 2
-
-PN_RECEIVED = (0x0000000000000023)
-PN_ACCEPTED = (0x0000000000000024)
-PN_REJECTED = (0x0000000000000025)
-PN_RELEASED = (0x0000000000000026)
-PN_MODIFIED = (0x0000000000000027)
-
-PN_TRACE_OFF = _Transport.TRACE_OFF
-PN_TRACE_RAW = _Transport.TRACE_RAW
-PN_TRACE_FRM = _Transport.TRACE_FRM
-PN_TRACE_DRV = _Transport.TRACE_DRV
-
-def wrap(obj, wrapper):
-  if obj:
-    ctx = obj.getContext()
-    if not ctx:
-      ctx = wrapper(obj)
-      obj.setContext(ctx)
-    return ctx
-
-class pn_condition:
-
-  def __init__(self):
-    self.name = None
-    self.description = None
-    self.info = pn_data(0)
-
-  def decode(self, impl):
-    if impl is None:
-      self.name = None
-      self.description = None
-      self.info.clear()
-    else:
-      cond = impl.getCondition()
-      if cond is None:
-        self.name = None
-      else:
-        self.name = cond.toString()
-      self.description = impl.getDescription()
-      obj2dat(impl.getInfo(), self.info)
-
-  def encode(self):
-    if self.name is None:
-      return None
-    else:
-      impl = ErrorCondition()
-      impl.setCondition(Symbol.valueOf(self.name))
-      impl.setDescription(self.description)
-      impl.setInfo(dat2obj(self.info))
-      return impl
-
-def pn_condition_is_set(cond):
-  return bool(cond.name)
-
-def pn_condition_get_name(cond):
-  return cond.name
-
-def pn_condition_set_name(cond, name):
-  cond.name = name
-
-def pn_condition_get_description(cond):
-  return cond.description
-
-def pn_condition_set_description(cond, description):
-  cond.description = description
-
-def pn_condition_clear(cond):
-  cond.name = None
-  cond.description = None
-  cond.info.clear()
-
-def pn_condition_info(cond):
-  return cond.info
-
-class endpoint_wrapper:
-
-  def __init__(self, impl):
-    self.impl = impl
-    self.condition = pn_condition()
-    self.remote_condition = pn_condition()
-
-  def on_close(self):
-    cond = self.condition.encode()
-    if cond:
-      self.impl.setCondition(cond)
-
-def remote_condition(self):
-  self.remote_condition.decode(self.impl.getRemoteCondition())
-  return self.remote_condition
-
-class pn_connection_wrapper(endpoint_wrapper):
-
-  def __init__(self, impl):
-    endpoint_wrapper.__init__(self, impl)
-    self.properties = pn_data(0)
-    self.offered_capabilities = pn_data(0)
-    self.desired_capabilities = pn_data(0)
-
-def pn_connection():
-  return wrap(Proton.connection(), pn_connection_wrapper)
-
-def set2mask(local, remote):
-  mask = 0
-  if local.contains(EndpointState.UNINITIALIZED):
-    mask |= PN_LOCAL_UNINIT
-  if local.contains(EndpointState.ACTIVE):
-    mask |= PN_LOCAL_ACTIVE
-  if local.contains(EndpointState.CLOSED):
-    mask |= PN_LOCAL_CLOSED
-  if remote.contains(EndpointState.UNINITIALIZED):
-    mask |= PN_REMOTE_UNINIT
-  if remote.contains(EndpointState.ACTIVE):
-    mask |= PN_REMOTE_ACTIVE
-  if remote.contains(EndpointState.CLOSED):
-    mask |= PN_REMOTE_CLOSED
-  return mask
-
-def endpoint_state(impl):
-  return set2mask(EnumSet.of(impl.getLocalState()),
-                  EnumSet.of(impl.getRemoteState()))
-
-def pn_connection_state(conn):
-  return endpoint_state(conn.impl)
-
-def pn_connection_condition(conn):
-  return conn.condition
-
-def pn_connection_remote_condition(conn):
-  return remote_condition(conn)
-
-def pn_connection_properties(conn):
-  return conn.properties
-
-def pn_connection_remote_properties(conn):
-  return obj2dat(conn.impl.getRemoteProperties())
-
-def pn_connection_offered_capabilities(conn):
-  return conn.offered_capabilities
-
-def pn_connection_remote_offered_capabilities(conn):
-  return array2dat(conn.impl.getRemoteOfferedCapabilities(), PN_SYMBOL)
-
-def pn_connection_desired_capabilities(conn):
-  return conn.desired_capabilities
-
-def pn_connection_remote_desired_capabilities(conn):
-  return array2dat(conn.impl.getRemoteDesiredCapabilities(), PN_SYMBOL)
-
-def pn_connection_attachments(conn):
-  return conn.impl.attachments()
-
-def pn_connection_set_container(conn, name):
-  conn.impl.setContainer(name)
-
-def pn_connection_get_container(conn):
-  return conn.impl.getContainer()
-
-def pn_connection_remote_container(conn):
-  return conn.impl.getRemoteContainer()
-
-def pn_connection_get_hostname(conn):
-  return conn.impl.getHostname()
-
-def pn_connection_set_hostname(conn, name):
-  conn.impl.setHostname(name)
-
-def pn_connection_remote_hostname(conn):
-  return conn.impl.getRemoteHostname()
-
-def pn_connection_open(conn):
-  props = dat2obj(conn.properties)
-  offered = dat2obj(conn.offered_capabilities)
-  desired = dat2obj(conn.desired_capabilities)
-  if props:
-    conn.impl.setProperties(props)
-  if offered:
-    conn.impl.setOfferedCapabilities(array(list(offered), Symbol))
-  if desired:
-    conn.impl.setDesiredCapabilities(array(list(desired), Symbol))
-  conn.impl.open()
-
-def pn_connection_close(conn):
-  conn.on_close()
-  conn.impl.close()
-
-def pn_connection_release(conn):
-  conn.impl.free()
-
-def pn_connection_transport(conn):
-  return wrap(conn.impl.getTransport(), pn_transport_wrapper)
-
-class pn_session_wrapper(endpoint_wrapper):
-  pass
-
-def pn_session(conn):
-  return wrap(conn.impl.session(), pn_session_wrapper)
-
-def pn_session_attachments(ssn):
-  return ssn.impl.attachments()
-
-def pn_session_state(ssn):
-  return endpoint_state(ssn.impl)
-
-def pn_session_get_incoming_capacity(ssn):
-  return ssn.impl.getIncomingCapacity()
-
-def pn_session_set_incoming_capacity(ssn, capacity):
-  ssn.impl.setIncomingCapacity(capacity)
-
-def pn_session_incoming_bytes(ssn):
-  return ssn.impl.getIncomingBytes()
-
-def pn_session_outgoing_bytes(ssn):
-  return ssn.impl.getOutgoingBytes()
-
-def pn_session_get_outgoing_window(ssn):
-  return ssn.impl.getOutgoingWindow()
-
-def pn_session_set_outgoing_window(ssn, window):
-  ssn.impl.setOutgoingWindow(window)
-
-def pn_session_condition(ssn):
-  return ssn.condition
-
-def pn_session_remote_condition(ssn):
-  return remote_condition(ssn)
-
-def pn_session_open(ssn):
-  ssn.impl.open()
-
-def pn_session_close(ssn):
-  ssn.on_close()
-  ssn.impl.close()
-
-def mask2set(mask):
-  local = []
-  remote = []
-  if PN_LOCAL_UNINIT & mask:
-    local.append(EndpointState.UNINITIALIZED)
-  if PN_LOCAL_ACTIVE & mask:
-    local.append(EndpointState.ACTIVE)
-  if PN_LOCAL_CLOSED & mask:
-    local.append(EndpointState.CLOSED)
-  if PN_REMOTE_UNINIT & mask:
-    remote.append(EndpointState.UNINITIALIZED)
-  if PN_REMOTE_ACTIVE & mask:
-    remote.append(EndpointState.ACTIVE)
-  if PN_REMOTE_CLOSED & mask:
-    remote.append(EndpointState.CLOSED)
-
-  if local:
-    local = EnumSet.of(*local)
-  else:
-    local = None
-  if remote:
-    remote = EnumSet.of(*remote)
-  else:
-    remote = None
-
-  return local, remote
-
-def pn_session_head(conn, mask):
-  local, remote = mask2set(mask)
-  return wrap(conn.impl.sessionHead(local, remote), pn_session_wrapper)
-
-def pn_session_connection(ssn):
-  return wrap(ssn.impl.getConnection(), pn_connection_wrapper)
-
-def pn_sender(ssn, name):
-  return wrap(ssn.impl.sender(name), pn_link_wrapper)
-
-def pn_receiver(ssn, name):
-  return wrap(ssn.impl.receiver(name), pn_link_wrapper)
-
-def pn_session_free(ssn):
-  ssn.impl.free()
-
-TERMINUS_TYPES_J2P = {
-  Source: PN_SOURCE,
-  Target: PN_TARGET,
-  Coordinator: PN_COORDINATOR,
-  None.__class__: PN_UNSPECIFIED
-}
-
-TERMINUS_TYPES_P2J = {
-  PN_SOURCE: Source,
-  PN_TARGET: Target,
-  PN_COORDINATOR: Coordinator,
-  PN_UNSPECIFIED: lambda: None
-}
-
-DURABILITY_P2J = {
-  PN_NONDURABLE: TerminusDurability.NONE,
-  PN_CONFIGURATION: TerminusDurability.CONFIGURATION,
-  PN_DELIVERIES: TerminusDurability.UNSETTLED_STATE
-}
-
-DURABILITY_J2P = {
-  TerminusDurability.NONE: PN_NONDURABLE,
-  TerminusDurability.CONFIGURATION: PN_CONFIGURATION,
-  TerminusDurability.UNSETTLED_STATE: PN_DELIVERIES
-}
-
-EXPIRY_POLICY_P2J = {
-  PN_EXPIRE_WITH_LINK: TerminusExpiryPolicy.LINK_DETACH,
-  PN_EXPIRE_WITH_SESSION: TerminusExpiryPolicy.SESSION_END,
-  PN_EXPIRE_WITH_CONNECTION: TerminusExpiryPolicy.CONNECTION_CLOSE,
-  PN_EXPIRE_NEVER: TerminusExpiryPolicy.NEVER
-}
-
-EXPIRY_POLICY_J2P = {
-  TerminusExpiryPolicy.LINK_DETACH: PN_EXPIRE_WITH_LINK,
-  TerminusExpiryPolicy.SESSION_END: PN_EXPIRE_WITH_SESSION,
-  TerminusExpiryPolicy.CONNECTION_CLOSE: PN_EXPIRE_WITH_CONNECTION,
-  TerminusExpiryPolicy.NEVER: PN_EXPIRE_NEVER
-}
-
-DISTRIBUTION_MODE_P2J = {
-  PN_DIST_MODE_UNSPECIFIED: None,
-  PN_DIST_MODE_COPY: Symbol.valueOf("copy"),
-  PN_DIST_MODE_MOVE: Symbol.valueOf("move")
-}
-
-DISTRIBUTION_MODE_J2P = {
-  None: PN_DIST_MODE_UNSPECIFIED,
-  Symbol.valueOf("copy"): PN_DIST_MODE_COPY,
-  Symbol.valueOf("move"): PN_DIST_MODE_MOVE
-}
-
-class pn_terminus:
-
-  def __init__(self, type):
-    self.type = type
-    self.address = None
-    self.durability = PN_NONDURABLE
-    self.expiry_policy = PN_EXPIRE_WITH_SESSION
-    self.distribution_mode = PN_DIST_MODE_UNSPECIFIED
-    self.timeout = 0
-    self.dynamic = False
-    self.properties = pn_data(0)
-    self.capabilities = pn_data(0)
-    self.outcomes = pn_data(0)
-    self.filter = pn_data(0)
-
-  def copy(self, src):
-    self.type = src.type
-    self.address = src.address
-    self.durability = src.durability
-    self.expiry_policy = src.expiry_policy
-    self.timeout = src.timeout
-    self.dynamic = src.dynamic
-    self.properties = src.properties
-    self.capabilities = src.capabilities
-    self.outcomes = src.outcomes
-    self.filter = src.filter
-
-  def decode(self, impl):
-    if impl is not None:
-      self.type = TERMINUS_TYPES_J2P[impl.__class__]
-      if self.type in (PN_SOURCE, PN_TARGET):
-        self.address = impl.getAddress()
-        self.durability = DURABILITY_J2P[impl.getDurable()]
-        self.expiry_policy = EXPIRY_POLICY_J2P[impl.getExpiryPolicy()]
-        self.timeout = impl.getTimeout().longValue()
-        self.dynamic = impl.getDynamic()
-        obj2dat(impl.getDynamicNodeProperties(), self.properties)
-        array2dat(impl.getCapabilities(), PN_SYMBOL, self.capabilities)
-        if self.type == PN_SOURCE:
-          self.distribution_mode = DISTRIBUTION_MODE_J2P[impl.getDistributionMode()]
-          array2dat(impl.getOutcomes(), PN_SYMBOL, self.outcomes)
-          obj2dat(impl.getFilter(), self.filter)
-
-  def encode(self):
-    impl = TERMINUS_TYPES_P2J[self.type]()
-    if self.type in (PN_SOURCE, PN_TARGET):
-      impl.setAddress(self.address)
-      impl.setDurable(DURABILITY_P2J[self.durability])
-      impl.setExpiryPolicy(EXPIRY_POLICY_P2J[self.expiry_policy])
-      impl.setTimeout(UnsignedInteger.valueOf(self.timeout))
-      impl.setDynamic(self.dynamic)
-      props = dat2obj(self.properties)
-      caps = dat2obj(self.capabilities)
-      if props: impl.setDynamicNodeProperties(props)
-      if caps:
-        impl.setCapabilities(*array(list(caps), Symbol))
-      if self.type == PN_SOURCE:
-        impl.setDistributionMode(DISTRIBUTION_MODE_P2J[self.distribution_mode])
-        outcomes = dat2obj(self.outcomes)
-        filter = dat2obj(self.filter)
-        if outcomes: impl.setOutcomes(outcomes)
-        if filter: impl.setFilter(filter)
-    return impl
-
-def pn_terminus_get_type(terminus):
-  return terminus.type
-
-def pn_terminus_set_type(terminus, type):
-  terminus.type = type
-  return 0
-
-def pn_terminus_get_address(terminus):
-  return terminus.address
-
-def pn_terminus_set_address(terminus, address):
-  terminus.address = address
-  return 0
-
-def pn_terminus_get_durability(terminus):
-  return terminus.durability
-
-def pn_terminus_get_expiry_policy(terminus):
-  return terminus.expiry_policy
-
-def pn_terminus_set_timeout(terminus, timeout):
-  terminus.timeout = timeout
-  return 0
-
-def pn_terminus_get_timeout(terminus):
-  return terminus.timeout
-
-def pn_terminus_get_distribution_mode(terminus):
-  return terminus.distribution_mode
-
-def pn_terminus_set_distribution_mode(terminus, mode):
-  terminus.distribution_mode = mode
-  return 0
-
-def pn_terminus_is_dynamic(terminus):
-  return terminus.dynamic
-
-def pn_terminus_set_dynamic(terminus, dynamic):
-  terminus.dynamic = dynamic
-  return 0
-
-def pn_terminus_properties(terminus):
-  return terminus.properties
-
-def pn_terminus_capabilities(terminus):
-  return terminus.capabilities
-
-def pn_terminus_outcomes(terminus):
-  return terminus.outcomes
-
-def pn_terminus_filter(terminus):
-  return terminus.filter
-
-def pn_terminus_copy(terminus, src):
-  terminus.copy(src)
-  return 0
-
-class pn_link_wrapper(endpoint_wrapper):
-
-  def __init__(self, impl):
-    endpoint_wrapper.__init__(self, impl)
-    self.source = pn_terminus(PN_SOURCE)
-    self.remote_source = pn_terminus(PN_UNSPECIFIED)
-    self.target = pn_terminus(PN_TARGET)
-    self.remote_target = pn_terminus(PN_UNSPECIFIED)
-
-  def on_open(self):
-    self.impl.setSource(self.source.encode())
-    self.impl.setTarget(self.target.encode())
-
-def pn_link_attachments(link):
-  return link.impl.attachments()
-
-def pn_link_source(link):
-  link.source.decode(link.impl.getSource())
-  return link.source
-
-def pn_link_remote_source(link):
-  link.remote_source.decode(link.impl.getRemoteSource())
-  return link.remote_source
-
-def pn_link_target(link):
-  link.target.decode(link.impl.getTarget())
-  return link.target
-
-def pn_link_remote_target(link):
-  link.remote_target.decode(link.impl.getRemoteTarget())
-  return link.remote_target
-
-def pn_link_condition(link):
-  return link.condition
-
-def pn_link_remote_condition(link):
-  return remote_condition(link)
-
-SND_SETTLE_MODE_P2J = {
-  PN_SND_UNSETTLED: SenderSettleMode.UNSETTLED,
-  PN_SND_SETTLED: SenderSettleMode.SETTLED,
-  PN_SND_MIXED: SenderSettleMode.MIXED,
-  None: None
-}
-
-SND_SETTLE_MODE_J2P = {
-  SenderSettleMode.UNSETTLED: PN_SND_UNSETTLED,
-  SenderSettleMode.SETTLED: PN_SND_SETTLED,
-  SenderSettleMode.MIXED: PN_SND_MIXED,
-  None: None
-}
-
-def pn_link_set_snd_settle_mode(link, mode):
-  link.impl.setSenderSettleMode(SND_SETTLE_MODE_P2J[mode])
-
-def pn_link_snd_settle_mode(link):
-  return SND_SETTLE_MODE_J2P[link.impl.getSenderSettleMode()]
-
-def pn_link_remote_snd_settle_mode(link):
-  return SND_SETTLE_MODE_J2P[link.impl.getRemoteSenderSettleMode()]
-
-RCV_SETTLE_MODE_P2J = {
-  PN_RCV_FIRST: ReceiverSettleMode.FIRST,
-  PN_RCV_SECOND: ReceiverSettleMode.SECOND,
-  None: None
-}
-
-RCV_SETTLE_MODE_J2P = {
-  ReceiverSettleMode.FIRST: PN_RCV_FIRST,
-  ReceiverSettleMode.SECOND: PN_RCV_SECOND,
-  None: None
-}
-
-def pn_link_set_rcv_settle_mode(link, mode):
-  link.impl.setReceiverSettleMode(RCV_SETTLE_MODE_P2J[mode])
-
-def pn_link_rcv_settle_mode(link):
-  return RCV_SETTLE_MODE_J2P[link.impl.getReceiverSettleMode()]
-
-def pn_link_remote_rcv_settle_mode(link):
-  return RCV_SETTLE_MODE_J2P[link.impl.getRemoteReceiverSettleMode()]
-
-def pn_link_is_sender(link):
-  return isinstance(link.impl, Sender)
-
-def pn_link_is_receiver(link):
-  return isinstance(link.impl, Receiver)
-
-def pn_link_head(conn, mask):
-  local, remote = mask2set(mask)
-  return wrap(conn.impl.linkHead(local, remote), pn_link_wrapper)
-
-def pn_link_next(link, mask):
-  local, remote = mask2set(mask)
-  return wrap(link.impl.next(local, remote), pn_link_wrapper)
-
-def pn_link_session(link):
-  return wrap(link.impl.getSession(), pn_session_wrapper)
-
-def pn_link_state(link):
-  return endpoint_state(link.impl)
-
-def pn_link_name(link):
-  return link.impl.getName()
-
-def pn_link_open(link):
-  link.on_open()
-  link.impl.open()
-
-def pn_link_close(link):
-  link.on_close()
-  link.impl.close()
-
-def pn_link_detach(link):
-  link.on_close()
-  link.impl.detach()
-
-def pn_link_flow(link, n):
-  link.impl.flow(n)
-
-def pn_link_drain(link, n):
-  link.impl.drain(n)
-
-def pn_link_drained(link):
-  return link.impl.drained()
-
-def pn_link_draining(link):
-  return link.impl.draining()
-
-def pn_link_credit(link):
-  return link.impl.getCredit()
-
-def pn_link_queued(link):
-  return link.impl.getQueued()
-
-def pn_link_get_drain(link):
-  return link.impl.getDrain();
-
-def pn_link_set_drain(link, drain):
-  return link.impl.setDrain(drain);
-
-def pn_link_unsettled(link):
-  return link.impl.getUnsettled()
-
-def pn_link_send(link, bytes):
-  return link.impl.send(array(bytes, 'b'), 0, len(bytes))
-
-def pn_link_recv(link, limit):
-  ary = zeros(limit, 'b')
-  n = link.impl.recv(ary, 0, limit)
-  if n >= 0:
-    bytes = ary[:n].tostring()
-  else:
-    bytes = None
-  return n, bytes
-
-def pn_link_advance(link):
-  return link.impl.advance()
-
-def pn_link_current(link):
-  return wrap(link.impl.current(), pn_delivery_wrapper)
-
-def pn_link_free(link):
-  link.impl.free()
-
-def pn_work_head(conn):
-  return wrap(conn.impl.getWorkHead(), pn_delivery_wrapper)
-
-def pn_work_next(dlv):
-  return wrap(dlv.impl.getWorkNext(), pn_delivery_wrapper)
-
-DELIVERY_STATES = {
-  Received: PN_RECEIVED,
-  Accepted: PN_ACCEPTED,
-  Rejected: PN_REJECTED,
-  Released: PN_RELEASED,
-  Modified: PN_MODIFIED,
-  None.__class__: 0
-  }
-
-DISPOSITIONS = {
-  PN_RECEIVED: Received,
-  PN_ACCEPTED: Accepted,
-  PN_REJECTED: Rejected,
-  PN_RELEASED: Released,
-  PN_MODIFIED: Modified,
-  0: lambda: None
-}
-
-class pn_disposition:
-
-  def __init__(self):
-    self.type = 0
-    self.data = pn_data(0)
-    self.failed = False
-    self.undeliverable = False
-    self.annotations = pn_data(0)
-    self.condition = pn_condition()
-    self.section_number = 0
-    self.section_offset = 0
-
-  def decode(self, impl):
-    self.type = DELIVERY_STATES[impl.__class__]
-
-    if self.type == PN_REJECTED:
-      self.condition.decode(impl.getError())
-    else:
-      pn_condition_clear(self.condition)
-
-    if self.type == PN_MODIFIED:
-      self.failed = impl.getDeliveryFailed()
-      self.undeliverable = impl.getUndeliverableHere()
-      obj2dat(impl.getMessageAnnotations(), self.annotations)
-    else:
-      self.failed = False
-      self.undeliverable = False
-      pn_data_clear(self.annotations)
-
-    if self.type == PN_RECEIVED:
-      self.section_number = impl.getSectionNumber().longValue()
-      self.section_offset = impl.getSectionOffset().longValue()
-    else:
-      self.section_number = 0
-      self.section_offset = 0
-
-    self.data.clear()
-    if impl:
-      # XXX
-      #self.data.putObject(impl)
-      pass
-    self.data.rewind()
-
-  def encode(self):
-    if self.type not in DISPOSITIONS:
-      raise Skipped()
-    impl = DISPOSITIONS[self.type]()
-
-    if impl is None:
-      return impl
-
-    if self.type == PN_REJECTED:
-      impl.setError(self.condition.encode())
-
-    if self.type == PN_MODIFIED:
-      impl.setDeliveryFailed(self.failed)
-      impl.setUndeliverableHere(self.undeliverable)
-      ann = dat2obj(self.annotations)
-      if ann: impl.setMessageAnnotations(ann)
-
-    if self.type == PN_RECEIVED:
-      if self.section_number:
-        impl.setSectionNumber(UnsignedInteger.valueOf(self.section_number))
-      if self.section_offset:
-        impl.setSectionOffset(UnsignedLong.valueOf(self.section_offset))
-
-    return impl
-
-def pn_disposition_type(dsp):
-  return dsp.type
-
-def pn_disposition_is_failed(dsp):
-  return dsp.failed
-
-def pn_disposition_set_failed(dsp, failed):
-  dsp.failed = failed
-
-def pn_disposition_is_undeliverable(dsp):
-  return dsp.undeliverable
-
-def pn_disposition_set_undeliverable(dsp, undeliverable):
-  dsp.undeliverable = undeliverable
-
-def pn_disposition_data(dsp):
-  return dsp.data
-
-def pn_disposition_annotations(dsp):
-  return dsp.annotations
-
-def pn_disposition_condition(dsp):
-  return dsp.condition
-
-def pn_disposition_get_section_number(dsp):
-  return dsp.section_number
-
-def pn_disposition_set_section_number(dsp, number):
-  dsp.section_number = number
-
-def pn_disposition_get_section_offset(dsp):
-  return dsp.section_offset
-
-def pn_disposition_set_section_offset(dsp, offset):
-  dsp.section_offset = offset
-
-class pn_delivery_wrapper:
-
-  def __init__(self, impl):
-    self.impl = impl
-    self.local = pn_disposition()
-    self.remote = pn_disposition()
-
-def pn_delivery(link, tag):
-  return wrap(link.impl.delivery(array(tag, 'b')), pn_delivery_wrapper)
-
-def pn_delivery_tag(dlv):
-  return dlv.impl.getTag().tostring()
-
-def pn_delivery_attachments(dlv):
-  return dlv.impl.attachments()
-
-def pn_delivery_partial(dlv):
-  return dlv.impl.isPartial()
-
-def pn_delivery_pending(dlv):
-  return dlv.impl.pending()
-
-def pn_delivery_writable(dlv):
-  return dlv.impl.isWritable()
-
-def pn_delivery_readable(dlv):
-  return dlv.impl.isReadable()
-
-def pn_delivery_updated(dlv):
-  return dlv.impl.isUpdated()
-
-def pn_delivery_settled(dlv):
-  return dlv.impl.remotelySettled()
-
-def pn_delivery_local(dlv):
-  dlv.local.decode(dlv.impl.getLocalState())
-  return dlv.local
-
-def pn_delivery_local_state(dlv):
-  dlv.local.decode(dlv.impl.getLocalState())
-  return dlv.local.type
-
-def pn_delivery_remote(dlv):
-  dlv.remote.decode(dlv.impl.getRemoteState())
-  return dlv.remote
-
-def pn_delivery_remote_state(dlv):
-  dlv.remote.decode(dlv.impl.getRemoteState())
-  return dlv.remote.type
-
-def pn_delivery_update(dlv, state):
-  dlv.local.type = state
-  dlv.impl.disposition(dlv.local.encode())
-
-def pn_delivery_link(dlv):
-  return wrap(dlv.impl.getLink(), pn_link_wrapper)
-
-def pn_delivery_settle(dlv):
-  dlv.impl.settle()
-
-class pn_transport_wrapper:
-  def __init__(self, impl):
-    self.impl = impl
-    self.server = False
-    self.condition = pn_condition()
-
-def pn_transport():
-  return wrap(Proton.transport(), pn_transport_wrapper)
-
-def pn_transport_get_pytracer(trans):
-  raise Skipped()
-
-def pn_transport_attachments(trans):
-  return trans.impl.attachments()
-
-def pn_transport_set_server(trans):
-  trans.server = True;
-
-def pn_transport_get_max_frame(trans):
-  return trans.impl.getMaxFrameSize()
-
-def pn_transport_set_max_frame(trans, value):
-  trans.impl.setMaxFrameSize(value)
-
-def pn_transport_get_remote_max_frame(trans):
-  return trans.impl.getRemoteMaxFrameSize()
-
-def pn_transport_set_idle_timeout(trans, value):
-  trans.impl.setIdleTimeout(value);
-
-def pn_transport_get_idle_timeout(trans):
-  return trans.impl.getIdleTimeout()
-
-def pn_transport_get_remote_idle_timeout(trans):
-  return trans.impl.getRemoteIdleTimeout()
-
-def pn_transport_get_frames_input(trans):
-  return trans.impl.getFramesInput()
-
-def pn_transport_get_frames_output(trans):
-  return trans.impl.getFramesOutput()
-
-def pn_transport_set_channel_max(trans, n):
-  trans.impl.setChannelMax(n)
-
-def pn_transport_get_channel_max(trans):
-  return trans.impl.getChannelMax()
-
-def pn_transport_remote_channel_max(trans):
-  return trans.impl.getRemoteChannelMax()
-
-def pn_transport_tick(trans, now):
-  return trans.impl.tick(now);
-
-def pn_transport_bind(trans, conn):
-  trans.impl.bind(conn.impl)
-  return 0
-
-def pn_transport_unbind(trans):
-  trans.impl.unbind()
-  return 0
-
-def pn_transport_set_pytracer(trans, tracer):
-  import warnings
-  warnings.warn("TODO pn_transport_set_tracer", stacklevel=2)
-
-def pn_transport_trace(trans, n):
-  trans.impl.trace(n)
-
-def pn_transport_pending(trans):
-  return trans.impl.pending()
-
-def pn_transport_peek(trans, size):
-  size = min(trans.impl.pending(), size)
-  ba = zeros(size, 'b')
-  if size:
-    bb = trans.impl.head()
-    bb.get(ba)
-    bb.position(0)
-  return 0, ba.tostring()
-
-def pn_transport_pop(trans, size):
-  trans.impl.pop(size)
-
-def pn_transport_capacity(trans):
-  return trans.impl.capacity()
-
-def pn_transport_push(trans, input):
-  result = 0
-  while input:
-    cap = pn_transport_capacity(trans)
-    if cap < 0:
-      return cap
-    elif len(input) > cap:
-      trimmed = input[:cap]
-    else:
-      trimmed = input
-
-    bb = trans.impl.tail()
-    bb.put(array(trimmed, 'b'))
-    trans.impl.process()
-    input = input[cap:]
-    result += len(trimmed)
-  return result
-
-def pn_transport_close_head(trans):
-  trans.impl.close_head()
-  return 0
-
-def pn_transport_close_tail(trans):
-  trans.impl.close_tail()
-  return 0
-
-def pn_transport_closed(trans):
-  return trans.impl.isClosed()
-
-def pn_transport_condition(trans):
-  trans.condition.decode(trans.impl.getCondition())
-  return trans.condition
-
-from org.apache.qpid.proton.engine import Event
-
-PN_REACTOR_INIT = Event.Type.REACTOR_INIT
-PN_REACTOR_QUIESCED = Event.Type.REACTOR_QUIESCED
-PN_REACTOR_FINAL = Event.Type.REACTOR_FINAL
-
-PN_TIMER_TASK = Event.Type.TIMER_TASK
-
-PN_CONNECTION_INIT = Event.Type.CONNECTION_INIT
-PN_CONNECTION_BOUND = Event.Type.CONNECTION_BOUND
-PN_CONNECTION_UNBOUND = Event.Type.CONNECTION_UNBOUND
-PN_CONNECTION_LOCAL_OPEN = Event.Type.CONNECTION_LOCAL_OPEN
-PN_CONNECTION_REMOTE_OPEN = Event.Type.CONNECTION_REMOTE_OPEN
-PN_CONNECTION_LOCAL_CLOSE = Event.Type.CONNECTION_LOCAL_CLOSE
-PN_CONNECTION_REMOTE_CLOSE = Event.Type.CONNECTION_REMOTE_CLOSE
-PN_CONNECTION_FINAL = Event.Type.CONNECTION_FINAL
-PN_SESSION_INIT = Event.Type.SESSION_INIT
-PN_SESSION_LOCAL_OPEN = Event.Type.SESSION_LOCAL_OPEN
-PN_SESSION_REMOTE_OPEN = Event.Type.SESSION_REMOTE_OPEN
-PN_SESSION_LOCAL_CLOSE = Event.Type.SESSION_LOCAL_CLOSE
-PN_SESSION_REMOTE_CLOSE = Event.Type.SESSION_REMOTE_CLOSE
-PN_SESSION_FINAL = Event.Type.SESSION_FINAL
-PN_LINK_INIT = Event.Type.LINK_INIT
-PN_LINK_LOCAL_OPEN = Event.Type.LINK_LOCAL_OPEN
-PN_LINK_REMOTE_OPEN = Event.Type.LINK_REMOTE_OPEN
-PN_LINK_LOCAL_CLOSE = Event.Type.LINK_LOCAL_CLOSE
-PN_LINK_REMOTE_CLOSE = Event.Type.LINK_REMOTE_CLOSE
-PN_LINK_LOCAL_DETACH = Event.Type.LINK_LOCAL_DETACH
-PN_LINK_REMOTE_DETACH = Event.Type.LINK_REMOTE_DETACH
-PN_LINK_FLOW = Event.Type.LINK_FLOW
-PN_LINK_FINAL = Event.Type.LINK_FINAL
-PN_DELIVERY = Event.Type.DELIVERY
-PN_TRANSPORT = Event.Type.TRANSPORT
-PN_TRANSPORT_ERROR = Event.Type.TRANSPORT_ERROR
-PN_TRANSPORT_HEAD_CLOSED = Event.Type.TRANSPORT_HEAD_CLOSED
-PN_TRANSPORT_TAIL_CLOSED = Event.Type.TRANSPORT_TAIL_CLOSED
-PN_TRANSPORT_CLOSED = Event.Type.TRANSPORT_CLOSED
-PN_SELECTABLE_INIT = Event.Type.SELECTABLE_INIT
-PN_SELECTABLE_UPDATED = Event.Type.SELECTABLE_UPDATED
-PN_SELECTABLE_READABLE = Event.Type.SELECTABLE_READABLE
-PN_SELECTABLE_WRITABLE = Event.Type.SELECTABLE_WRITABLE
-PN_SELECTABLE_EXPIRED = Event.Type.SELECTABLE_EXPIRED
-PN_SELECTABLE_ERROR = Event.Type.SELECTABLE_ERROR
-PN_SELECTABLE_FINAL = Event.Type.SELECTABLE_FINAL
-
-def pn_collector():
-  return Proton.collector()
-
-def pn_connection_collect(conn, coll):
-  conn.impl.collect(coll)
-
-class pn_event:
-
-  def __init__(self, impl):
-    self.impl = impl
-
-  def copy(self):
-    return pn_event(self.impl.copy())
-
-def pn_collector_peek(coll):
-  ev = coll.peek()
-  if ev:
-    return pn_event(ev.copy())
-  else:
-    return None
-
-def pn_collector_pop(coll):
-  coll.pop()
-
-def pn_collector_free(coll):
-  pass
-
-def pn_event_reactor(event):
-  return event.impl.getReactor()
-
-def pn_event_connection(event):
-  return wrap(event.impl.getConnection(), pn_connection_wrapper)
-
-def pn_event_session(event):
-  return wrap(event.impl.getSession(), pn_session_wrapper)
-
-def pn_event_link(event):
-  return wrap(event.impl.getLink(), pn_link_wrapper)
-
-def pn_event_delivery(event):
-  return wrap(event.impl.getDelivery(), pn_delivery_wrapper)
-
-def pn_event_transport(event):
-  return wrap(event.impl.getTransport(), pn_transport_wrapper)
-
-from org.apache.qpid.proton.engine.impl import ConnectionImpl, SessionImpl, \
-  SenderImpl, ReceiverImpl, DeliveryImpl, TransportImpl
-from org.apache.qpid.proton.reactor.impl import TaskImpl, SelectableImpl
-
-J2C = {
-  ConnectionImpl: "pn_connection",
-  SessionImpl: "pn_session",
-  SenderImpl: "pn_link",
-  ReceiverImpl: "pn_link",
-  DeliveryImpl: "pn_delivery",
-  TransportImpl: "pn_transport",
-  TaskImpl: "pn_task",
-  SelectableImpl: "pn_selectable"
-}
-
-wrappers = {
-  "pn_connection": lambda x: wrap(x, pn_connection_wrapper),
-  "pn_session": lambda x: wrap(x, pn_session_wrapper),
-  "pn_link": lambda x: wrap(x, pn_link_wrapper),
-  "pn_delivery": lambda x: wrap(x, pn_delivery_wrapper),
-  "pn_transport": lambda x: wrap(x, pn_transport_wrapper),
-  "pn_task": lambda x: x,
-  "pn_selectable": lambda x: x,
-  "pn_void": lambda x: x
-}
-
-def pn_event_class(event):
-  ctx = event.impl.getContext()
-  return J2C.get(ctx.getClass(), "pn_void")
-
-def pn_event_context(event):
-  return wrappers[pn_event_class(event)](event.impl.getContext())
-
-def pn_event_type(event):
-  return event.impl.getEventType()
-
-def pn_event_root(event):
-  return event.impl.getRootHandler()
-
-def pn_event_type_name(etype):
-  return str(etype)
-
-def pn_event_category(event):
-  return event.impl.getCategory()
-
-def pn_event_attachments(event):
-  return event.impl.attachments()
-
-def pn_event_copy(event):
-  return event.copy()
-
-class TypeExtender:
-  def __init__(self, number):
-    pass
-  def next(self):
-    class CustomEvent(EventType):
-      def isValid(self):
-        return True
-    return CustomEvent()

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cerror.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cerror.py b/tests/java/shim/cerror.py
deleted file mode 100644
index c87681c..0000000
--- a/tests/java/shim/cerror.py
+++ /dev/null
@@ -1,48 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-
-# from proton/error.h
-PN_EOS = -1
-PN_ERR = -2
-PN_OVERFLOW = -3
-PN_UNDERFLOW = -4
-PN_STATE_ERR = -5
-PN_ARG_ERR = -6
-PN_TIMEOUT =-7
-PN_INTR = -8
-PN_INPROGRESS =-9
-
-class pn_error:
-
-  def __init__(self, code, text):
-    self.code = code
-    self.text = text
-
-  def set(self, code, text):
-    self.code = code
-    self.text = text
-    return self.code
-
-def pn_error_code(err):
-  return err.code
-
-def pn_error_text(err):
-  return err.text
-
-from unittest import SkipTest as Skipped

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/chandlers.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/chandlers.py b/tests/java/shim/chandlers.py
deleted file mode 100644
index 272990f..0000000
--- a/tests/java/shim/chandlers.py
+++ /dev/null
@@ -1,55 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-
-import sys
-from cerror import Skipped
-from org.apache.qpid.proton.reactor import FlowController, Handshaker
-from org.apache.qpid.proton.engine import BaseHandler, HandlerException
-
-# from proton/handlers.h
-def pn_flowcontroller(window):
-    return FlowController(window)
-
-def pn_handshaker():
-    return Handshaker()
-
-def pn_iohandler():
-    raise Skipped()
-
-from cengine import pn_event, pn_event_type
-
-class pn_pyhandler(BaseHandler):
-
-    def __init__(self, pyobj):
-        self.pyobj = pyobj
-
-    def onUnhandled(self, event):
-        ev = pn_event(event)
-        try:
-            self.pyobj.dispatch(ev, pn_event_type(ev))
-        except HandlerException:
-            ex = sys.exc_info();
-            cause = ex[1].cause
-            if hasattr(cause, "value"):
-                cause = cause.value
-            t = type(cause)
-            self.pyobj.exception(t, cause, ex[2])
-        except:
-            ex = sys.exc_info()
-            self.pyobj.exception(*ex)

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cmessage.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cmessage.py b/tests/java/shim/cmessage.py
deleted file mode 100644
index d406bea..0000000
--- a/tests/java/shim/cmessage.py
+++ /dev/null
@@ -1,250 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp.messaging import AmqpValue, AmqpSequence, \
-  Data as DataSection, ApplicationProperties, MessageAnnotations, DeliveryAnnotations
-
-from ccodec import *
-from cerror import *
-from org.apache.qpid.proton.amqp import Binary
-
-# from proton/message.h
-PN_DATA = 0
-PN_TEXT = 1
-PN_AMQP = 2
-PN_JSON = 3
-
-PN_DEFAULT_PRIORITY = 4
-
-class pn_message_wrapper:
-
-  def __init__(self):
-    self.inferred = False
-    self.impl = Proton.message()
-    self.id = pn_data(0)
-    self.correlation_id = pn_data(0)
-    self.instructions = pn_data(0)
-    self.annotations = pn_data(0)
-    self.properties = pn_data(0)
-    self.body = pn_data(0)
-
-  def decode(self, impl):
-    self.impl = impl
-    self.post_decode()
-
-  def post_decode(self):
-    obj2dat(self.impl.getMessageId(), self.id)
-    self.id.next()
-    obj2dat(self.impl.getCorrelationId(), self.correlation_id)
-    self.correlation_id.next()
-    def peel(x):
-       if x is not None:
-         return x.getValue()
-       return None
-    obj2dat(peel(self.impl.getDeliveryAnnotations()), self.instructions)
-    obj2dat(peel(self.impl.getMessageAnnotations()), self.annotations)
-    obj2dat(peel(self.impl.getApplicationProperties()), self.properties)
-    bod = self.impl.getBody()
-    if bod is not None: bod = bod.getValue()
-    obj2dat(bod, self.body)
-
-  def pre_encode(self):
-    self.impl.setMessageId(dat2obj(self.id))
-    self.impl.setCorrelationId(dat2obj(self.correlation_id))
-    def wrap(x, wrapper):
-      if x is not None:
-        return wrapper(x)
-      return None
-    self.impl.setDeliveryAnnotations(wrap(dat2obj(self.instructions), DeliveryAnnotations))
-    self.impl.setMessageAnnotations(wrap(dat2obj(self.annotations), MessageAnnotations))
-    self.impl.setApplicationProperties(wrap(dat2obj(self.properties), ApplicationProperties))
-    bod = dat2obj(self.body)
-    if self.inferred:
-      if isinstance(bod, bytes):
-        bod = DataSection(Binary(array(bod, 'b')))
-      elif isinstance(bod, list):
-        bod = AmqpSequence(bod)
-      else:
-        bod = AmqpValue(bod)
-    else:
-      bod = AmqpValue(bod)
-    self.impl.setBody(bod)
-
-  def __repr__(self):
-    return self.impl.toString()
-
-def pn_message():
-  return pn_message_wrapper()
-
-def pn_message_id(msg):
-  return msg.id
-
-def pn_message_correlation_id(msg):
-  return msg.correlation_id
-
-def pn_message_get_address(msg):
-  return msg.impl.getAddress()
-
-def pn_message_set_address(msg, address):
-  msg.impl.setAddress(address)
-  return 0
-
-def pn_message_get_reply_to(msg):
-  return msg.impl.getReplyTo()
-
-def pn_message_set_reply_to(msg, address):
-  msg.impl.setReplyTo(address)
-  return 0
-
-def pn_message_get_reply_to_group_id(msg):
-  return msg.impl.getReplyToGroupId()
-
-def pn_message_set_reply_to_group_id(msg, id):
-  msg.impl.setReplyToGroupId(id)
-  return 0
-
-def pn_message_get_group_sequence(msg):
-  return msg.impl.getGroupSequence()
-
-def pn_message_set_group_sequence(msg, seq):
-  msg.impl.setGroupSequence(seq)
-  return 0
-
-def pn_message_get_group_id(msg):
-  return msg.impl.getGroupId()
-
-def pn_message_set_group_id(msg, id):
-  msg.impl.setGroupId(id)
-  return 0
-
-def pn_message_is_first_acquirer(msg):
-  return msg.impl.isFirstAcquirer()
-
-def pn_message_set_first_acquirer(msg, b):
-  msg.impl.setFirstAcquirer(b)
-  return 0
-
-def pn_message_is_durable(msg):
-  return msg.impl.isDurable()
-
-def pn_message_set_durable(msg, b):
-  msg.impl.setDurable(b)
-  return 0
-
-def pn_message_get_delivery_count(msg):
-  return msg.impl.getDeliveryCount()
-
-def pn_message_set_delivery_count(msg, c):
-  msg.impl.setDeliveryCount(c)
-  return 0
-
-def pn_message_get_creation_time(msg):
-  return msg.impl.getCreationTime()
-
-def pn_message_set_creation_time(msg, t):
-  msg.impl.setCreationTime(t)
-  return 0
-
-def pn_message_get_expiry_time(msg):
-  return msg.impl.getExpiryTime()
-
-def pn_message_set_expiry_time(msg, t):
-  msg.impl.setExpiryTime(t)
-  return 0
-
-def pn_message_get_content_type(msg):
-  return msg.impl.getContentType()
-
-def pn_message_set_content_type(msg, ct):
-  msg.impl.setContentType(ct)
-  return 0
-
-def pn_message_get_content_encoding(msg):
-  return msg.impl.getContentEncoding()
-
-def pn_message_set_content_encoding(msg, ct):
-  msg.impl.setContentEncoding(ct)
-  return 0
-
-def pn_message_get_subject(msg):
-  return msg.impl.getSubject()
-
-def pn_message_set_subject(msg, value):
-  msg.impl.setSubject(value)
-  return 0
-
-def pn_message_get_priority(msg):
-  return msg.impl.getPriority()
-
-def pn_message_set_priority(msg, p):
-  msg.impl.setPriority(p)
-  return 0
-
-def pn_message_get_ttl(msg):
-  return msg.impl.getTtl()
-
-def pn_message_set_ttl(msg, ttl):
-  msg.impl.setTtl(ttl)
-  return 0
-
-def pn_message_get_user_id(msg):
-  uid = msg.impl.getUserId()
-  if uid is None:
-    return ""
-  else:
-    return uid.tostring()
-
-def pn_message_set_user_id(msg, uid):
-  msg.impl.setUserId(uid)
-  return 0
-
-def pn_message_instructions(msg):
-  return msg.instructions
-
-def pn_message_annotations(msg):
-  return msg.annotations
-
-def pn_message_properties(msg):
-  return msg.properties
-
-def pn_message_body(msg):
-  return msg.body
-
-def pn_message_decode(msg, data):
-  n = msg.impl.decode(array(data, 'b'), 0, len(data))
-  msg.post_decode()
-  return n
-
-from java.nio import BufferOverflowException
-
-def pn_message_encode(msg, size):
-  msg.pre_encode()
-  ba = zeros(size, 'b')
-  # XXX: shouldn't have to use the try/catch
-  try:
-    n = msg.impl.encode(ba, 0, size)
-    if n >= 0:
-      return n, ba[:n].tostring()
-    else:
-      return n
-  except BufferOverflowException, e:
-    return PN_OVERFLOW, None
-
-def pn_message_clear(msg):
-  msg.impl.clear()

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cmessenger.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cmessenger.py b/tests/java/shim/cmessenger.py
deleted file mode 100644
index 249e0dc..0000000
--- a/tests/java/shim/cmessenger.py
+++ /dev/null
@@ -1,225 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.messenger import Messenger, Status
-from org.apache.qpid.proton import InterruptException, TimeoutException
-
-from cerror import *
-
-# from proton/messenger.h
-PN_STATUS_UNKNOWN = 0
-PN_STATUS_PENDING = 1
-PN_STATUS_ACCEPTED = 2
-PN_STATUS_REJECTED = 3
-PN_STATUS_RELEASED = 4
-PN_STATUS_MODIFIED = 5
-PN_STATUS_ABORTED = 6
-PN_STATUS_SETTLED = 7
-
-PN_CUMULATIVE = 1
-
-class pn_messenger_wrapper:
-
-  def __init__(self, impl):
-    self.impl = impl
-    self.error = pn_error(0, None)
-
-def pn_messenger(name):
-  if name is None:
-    return pn_messenger_wrapper(Proton.messenger())
-  else:
-    return pn_messenger_wrapper(Proton.messenger(name))
-
-def pn_messenger_error(m):
-  return m.error
-
-def pn_messenger_set_timeout(m, t):
-  m.impl.setTimeout(t)
-  return 0
-
-def pn_messenger_set_blocking(m, b):
-  m.impl.setBlocking(b)
-  return 0
-
-def pn_messenger_set_certificate(m, c):
-  m.impl.setCertificate(c)
-  return 0
-
-def pn_messenger_set_private_key(m, p):
-  m.impl.setPrivateKey(p)
-  return 0
-
-def pn_messenger_set_password(m, p):
-  m.impl.setPassword(p)
-  return 0
-
-def pn_messenger_set_trusted_certificates(m, t):
-  m.impl.setTrustedCertificates(t)
-  return 0
-
-def pn_messenger_set_incoming_window(m, w):
-  m.impl.setIncomingWindow(w)
-  return 0
-
-def pn_messenger_set_outgoing_window(m, w):
-  m.impl.setOutgoingWindow(w)
-  return 0
-
-def pn_messenger_start(m):
-  m.impl.start()
-  return 0
-
-# XXX: ???
-def pn_messenger_work(m, t):
-  try:
-    if m.impl.work(t):
-      return 1
-    else:
-      return PN_TIMEOUT
-  except InterruptException, e:
-    return PN_INTR
-
-class pn_subscription:
-
-  def __init__(self):
-    pass
-
-def pn_messenger_subscribe(m, source):
-  m.impl.subscribe(source)
-  return pn_subscription()
-
-def pn_messenger_route(m, pattern, address):
-  m.impl.route(pattern, address)
-  return 0
-
-def pn_messenger_rewrite(m, pattern, address):
-  m.impl.rewrite(pattern, address)
-  return 0
-
-def pn_messenger_interrupt(m):
-  m.impl.interrupt()
-  return 0
-
-def pn_messenger_buffered(m, t):
-  raise Skipped()
-
-from org.apache.qpid.proton.engine import TransportException
-
-def pn_messenger_stop(m):
-  m.impl.stop()
-  return 0
-
-def pn_messenger_stopped(m):
-  return m.impl.stopped()
-
-def pn_messenger_put(m, msg):
-  msg.pre_encode()
-  m.impl.put(msg.impl)
-  return 0
-
-def pn_messenger_outgoing_tracker(m):
-  return m.impl.outgoingTracker()
-
-def pn_messenger_send(m, n):
-  try:
-    m.impl.send(n)
-    return 0
-  except InterruptException, e:
-    return PN_INTR
-  except TimeoutException, e:
-    return PN_TIMEOUT
-
-def pn_messenger_recv(m, n):
-  try:
-    m.impl.recv(n)
-    return 0
-  except InterruptException, e:
-    return PN_INTR
-  except TimeoutException, e:
-    return PN_TIMEOUT
-
-def pn_messenger_receiving(m):
-  return m.impl.receiving()
-
-def pn_messenger_incoming(m):
-  return m.impl.incoming()
-
-def pn_messenger_outgoing(m):
-  return m.impl.outgoing()
-
-def pn_messenger_get(m, msg):
-  mimpl = m.impl.get()
-  if msg:
-    msg.decode(mimpl)
-  return 0
-
-def pn_messenger_incoming_tracker(m):
-  return m.impl.incomingTracker()
-
-def pn_messenger_accept(m, tracker, flags):
-  if flags:
-    m.impl.accept(tracker, Messenger.CUMULATIVE)
-  else:
-    m.impl.accept(tracker, 0)
-  return 0
-
-def pn_messenger_reject(m, tracker, flags):
-  if flags:
-    m.impl.reject(tracker, Messenger.CUMULATIVE)
-  else:
-    m.impl.reject(tracker, 0)
-  return 0
-
-def pn_messenger_settle(m, tracker, flags):
-  if flags:
-    m.impl.settle(tracker, Messenger.CUMULATIVE)
-  else:
-    m.impl.settle(tracker, 0)
-  return 0
-
-STATUS_P2J = {
-  PN_STATUS_UNKNOWN: Status.UNKNOWN,
-  PN_STATUS_PENDING: Status.PENDING,
-  PN_STATUS_ACCEPTED: Status.ACCEPTED,
-  PN_STATUS_REJECTED: Status.REJECTED,
-  PN_STATUS_RELEASED: Status.RELEASED,
-  PN_STATUS_MODIFIED: Status.MODIFIED,
-  PN_STATUS_ABORTED: Status.ABORTED,
-  PN_STATUS_SETTLED: Status.SETTLED
-}
-
-STATUS_J2P = {
-  Status.UNKNOWN: PN_STATUS_UNKNOWN,
-  Status.PENDING: PN_STATUS_PENDING,
-  Status.ACCEPTED: PN_STATUS_ACCEPTED,
-  Status.REJECTED: PN_STATUS_REJECTED,
-  Status.RELEASED: PN_STATUS_RELEASED,
-  Status.MODIFIED: PN_STATUS_MODIFIED,
-  Status.ABORTED: PN_STATUS_ABORTED,
-  Status.SETTLED: PN_STATUS_SETTLED
-}
-
-def pn_messenger_status(m, tracker):
-  return STATUS_J2P[m.impl.getStatus(tracker)]
-
-def pn_messenger_set_passive(m, passive):
-  raise Skipped()
-
-def pn_messenger_selectable(m):
-  raise Skipped()

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cobject.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cobject.py b/tests/java/shim/cobject.py
deleted file mode 100644
index 33ab438..0000000
--- a/tests/java/shim/cobject.py
+++ /dev/null
@@ -1,91 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-
-def pn_class_name(cls):
-  return cls
-
-def pn_void2py(obj):
-  return obj
-
-def pn_py2void(obj):
-    return obj
-
-def pn_cast_pn_connection(obj):
-    return obj
-
-def pn_cast_pn_session(obj):
-    return obj
-
-def pn_cast_pn_link(obj):
-    return obj
-
-def pn_cast_pn_delivery(obj):
-    return obj
-
-def pn_cast_pn_transport(obj):
-    return obj
-
-def pn_cast_pn_reactor(obj):
-    return obj
-
-def pn_cast_pn_task(obj):
-    return obj
-
-def pn_cast_pn_selectable(obj):
-    return obj
-
-PN_PYREF = None
-
-def pn_record_def(record, key, clazz):
-  pass
-
-from java.lang import Object
-
-def pn_record_get(record, key):
-  return record.get(key, Object)
-
-def pn_record_set(record, key, value):
-  record.set(key, Object, value)
-
-def pn_incref(obj):
-  pass
-
-def pn_decref(obj):
-  pass
-
-def pn_free(obj):
-  pass
-
-from java.lang import StringBuilder
-
-def pn_string(st):
-  sb = StringBuilder()
-  if st:
-    sb.append(st)
-  return sb
-
-def pn_string_get(sb):
-  return sb.toString()
-
-def pn_inspect(obj, st):
-  if obj is None:
-    st.append("null")
-  else:
-    st.append(repr(obj))
-  return 0

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/compat.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/compat.py b/tests/java/shim/compat.py
deleted file mode 100644
index 7bff3ba..0000000
--- a/tests/java/shim/compat.py
+++ /dev/null
@@ -1,26 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-import sys
-from jarray import zeros, array as _array
-
-if (sys.version_info[0] == 2 and sys.version_info[1] == 5):
-    array = _array
-else:
-    def array(obj, code):
-        return obj

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cproton.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cproton.py b/tests/java/shim/cproton.py
deleted file mode 100644
index d5ed574..0000000
--- a/tests/java/shim/cproton.py
+++ /dev/null
@@ -1,42 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you 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.
-#
-
-"""
-The cproton module defines a java implementation of the C interface as
-exposed to python via swig. This allows tests defined in python to run
-against both the C and Java protocol implementations.
-"""
-
-# @todo(kgiusti) dynamically set these via filters in the pom.xml file
-PN_VERSION_MAJOR = 0
-PN_VERSION_MINOR = 0
-PN_VERSION_POINT = 0
-
-from ctypes import *
-from cobject import *
-from cerror import *
-from ccodec import *
-from cengine import *
-from csasl import *
-from cssl import *
-from cmessenger import *
-from cmessage import *
-from curl import *
-from creactor import *
-from chandlers import *


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message