QPID-4396 : [Java AMQP 1.0] move examples into sub-module

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1402462 13f79535-47bb-0310-9956-ffa450edef68

18 files changed, 65 insertions, 410 deletions

diff --git a/java/amqp-1-0-client-jms/build.xml b/java/amqp-1-0-client-jms/build.xml
index cfc6e0babe..d501be1d8d 100644
--- a/java/amqp-1-0-client-jms/build.xml
+++ b/java/amqp-1-0-client-jms/build.xml
@@ -24,6 +24,9 @@
   <property name="module.depends" value="amqp-1-0-common amqp-1-0-client"/>
   <property name="module.genpom.args" value="-Sgeronimo-jms_1.1_spec=provided"/>
 
+  <property name="example.src.dir" value="${project.root}/amqp-1-0-client-jms/example/src/main/java" />
+  <property name="example.jar.file" value="${build.lib}/qpid-amqp-1-0-client-jms-example-${project.version}.jar" />
+
 
   <target name="release-bin-copy-readme">
       <copy todir="${module.release}" overwrite="true" failonerror="true">
diff --git a/java/amqp-1-0-client-jms/example/build.xml b/java/amqp-1-0-client-jms/example/build.xml
new file mode 100644
index 0000000000..cb9ab0994c
--- /dev/null
+++ b/java/amqp-1-0-client-jms/example/build.xml
@@ -0,0 +1,28 @@
+<!--
+ -
+ - 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.
+ -
+ -->
+<project name="AMQ 1.0 JMS Client Example" default="build">
+
+  <property name="module.depends" value="amqp-1-0-client-jms amqp-1-0-client amqp-1-0-common"/>
+  <property name="module.test.depends" value=""/>
+
+  <import file="../../module.xml"/>
+
+</project>
diff --git a/java/amqp-1-0-client/build.xml b/java/amqp-1-0-client/build.xml
index 031809a380..cd7654ed15 100644
--- a/java/amqp-1-0-client/build.xml
+++ b/java/amqp-1-0-client/build.xml
@@ -23,6 +23,9 @@
   <property name="module.genpom" value="true"/>
   <property name="module.depends" value="amqp-1-0-common"/>
 
+  <property name="example.src.dir" value="${project.root}/amqp-1-0-client/example/src/main/java" />
+  <property name="example.jar.file" value="${build.lib}/qpid-amqp-1-0-client-example-${project.version}.jar" />
+
 
   <import file="../module.xml"/>
 
diff --git a/java/amqp-1-0-client/example/build.xml b/java/amqp-1-0-client/example/build.xml
new file mode 100644
index 0000000000..89bba729dd
--- /dev/null
+++ b/java/amqp-1-0-client/example/build.xml
@@ -0,0 +1,28 @@
+<!--
+ -
+ - 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.
+ -
+ -->
+<project name="AMQ 1.0 Client Example" default="build">
+
+  <property name="module.depends" value="amqp-1-0-client amqp-1-0-common"/>
+  <property name="module.test.depends" value=""/>
+
+  <import file="../../module.xml"/>
+
+</project>
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Command.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Command.java
index 3bb26744c4..3bb26744c4 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Command.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Command.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Demo.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Demo.java
index b58ce6bfe5..b58ce6bfe5 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Demo.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Demo.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Dump.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Dump.java
index 65d27b21f8..65d27b21f8 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Dump.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Dump.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Filereceiver.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Filereceiver.java
index 4d98655ad2..4d98655ad2 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Filereceiver.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Filereceiver.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Filesender.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Filesender.java
index 46e6ba537f..46e6ba537f 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Filesender.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Filesender.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receive.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Receive.java
index 0da9dc3fb7..0da9dc3fb7 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receive.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Receive.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Request.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Request.java
index 6e1d15376c..6e1d15376c 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Request.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Request.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Respond.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Respond.java
index 8d9de4893f..8d9de4893f 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Respond.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Respond.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Send.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Send.java
index 6f6575e083..6f6575e083 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Send.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Send.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Util.java b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Util.java
index 6fe2a6d510..6fe2a6d510 100644
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Util.java
+++ b/java/amqp-1-0-client/example/src/main/java/org/apache/qpid/amqp_1_0/client/Util.java
diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/ReadBytes.java b/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/ReadBytes.java
deleted file mode 100644
index 07ae54b54f..0000000000
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/ReadBytes.java
+++ /dev/null
@@ -1,77 +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.amqp_1_0.client;

-

-import org.apache.qpid.amqp_1_0.codec.ValueHandler;

-import org.apache.qpid.amqp_1_0.type.AmqpErrorException;

-import org.apache.qpid.amqp_1_0.type.codec.AMQPDescribedTypeRegistry;

-import java.io.FileInputStream;

-import java.io.IOException;

-import java.io.InputStream;

-import java.nio.ByteBuffer;

-

-public class ReadBytes

-{

-

-    public static void main(String[] args) throws IOException, AmqpErrorException

-    {

-

-        if(args.length == 0)

-        {

-            readBytes(System.in);

-        }

-        else

-        {

-            for(String fileName : args)

-            {

-                System.out.println("=========================== " + fileName + " ===========================");

-                final FileInputStream fis = new FileInputStream(fileName);

-                readBytes(fis);

-                fis.close();

-            }

-        }

-

-    }

-

-    private static void readBytes(final InputStream inputStream) throws IOException, AmqpErrorException

-    {

-        byte[] bytes = new byte[4096];

-

-        ValueHandler valueHandler = new ValueHandler(AMQPDescribedTypeRegistry.newInstance());

-

-        int count;

-

-        while((count = inputStream.read(bytes))!=-1)

-        {

-            ByteBuffer buf = ByteBuffer.wrap(bytes);

-            buf.limit(count);

-            while(buf.hasRemaining())

-            {

-

-                    final Object value = valueHandler.parse(buf);

-                    System.out.print((value == null ? "" : value.getClass().getName() + ":") +value +"\n");

-

-            }

-        }

-

-    }

-

-

-}

diff --git a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/SendBytes.java b/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/SendBytes.java
deleted file mode 100644
index 6f97ecd810..0000000000
--- a/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/SendBytes.java
+++ /dev/null
@@ -1,331 +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.amqp_1_0.client;

-

-import org.apache.qpid.amqp_1_0.codec.FrameWriter;

-import org.apache.qpid.amqp_1_0.codec.ValueWriter;

-import org.apache.qpid.amqp_1_0.framing.AMQFrame;

-import org.apache.qpid.amqp_1_0.type.Binary;

-import org.apache.qpid.amqp_1_0.type.FrameBody;

-import org.apache.qpid.amqp_1_0.type.Section;

-import org.apache.qpid.amqp_1_0.type.Symbol;

-import org.apache.qpid.amqp_1_0.type.UnsignedByte;

-import org.apache.qpid.amqp_1_0.type.UnsignedInteger;

-import org.apache.qpid.amqp_1_0.type.UnsignedLong;

-import org.apache.qpid.amqp_1_0.type.UnsignedShort;

-import org.apache.qpid.amqp_1_0.type.codec.AMQPDescribedTypeRegistry;

-import org.apache.qpid.amqp_1_0.type.messaging.Footer;

-import org.apache.qpid.amqp_1_0.type.messaging.Header;

-import org.apache.qpid.amqp_1_0.type.messaging.Properties;

-import org.apache.qpid.amqp_1_0.type.transport.Flow;

-

-import org.apache.qpid.amqp_1_0.type.transport.Transfer;

-

-import java.io.FileOutputStream;

-import java.io.IOException;

-import java.nio.ByteBuffer;

-import java.text.ParseException;

-import java.text.SimpleDateFormat;

-import java.util.*;

-

-public class SendBytes

-{

-

-    public static void main(String[] args) throws

-                                           Sender.SenderCreationException,

-                                           Sender.SenderClosingException,

-                                           Connection.ConnectionException,

-                                           IOException, ParseException

-    {

-        Transfer xfr = new Transfer();

-        Flow fs = new Flow();

-        fs.setIncomingWindow(UnsignedInteger.valueOf(1024));

-        fs.setDeliveryCount(UnsignedInteger.valueOf(2));

-        fs.setLinkCredit(UnsignedInteger.valueOf(18));

-        fs.setAvailable(UnsignedInteger.valueOf(0));

-        fs.setDrain(false);

-

-        xfr.setHandle(UnsignedInteger.valueOf(0));

-        xfr.setDeliveryTag(new Binary("\"queue\"<-6ec024a7-d98e-4196-9348-15f6026c32ca:0".getBytes()));

-        //xfr.setDeliveryTag(new Binary(new byte[] {0}));

-        xfr.setDeliveryId(UnsignedInteger.valueOf(0));

-        xfr.setSettled(true);

-

-

-        Header h = new Header();

-        Properties p = new Properties();

-        p.setTo("queue");

-        //p.setMessageId(new Binary(UUID.randomUUID().toString().getBytes()));

-

-        Footer f = new Footer(Collections.EMPTY_MAP);

-

-        Section[] sections = new Section[] { h,p,f};

-        //Section[] sections = new Section[] { b };

-        //Section[] sections = { h,p, b};

-/*

-        Fragment[] fragments = new Fragment[5];

-

-        final AMQPDescribedTypeRegistry typeRegistry = AMQPDescribedTypeRegistry.newInstance().registerTransportLayer().registerMessagingLayer();

-

-        SectionEncoderImpl encoder = new SectionEncoderImpl(typeRegistry);

-

-        int num = 0;

-        int i = 0;

-        for(Section s : sections)

-        {

-            Fragment frag = new Fragment();

-

-            frag.setPayload(s.encode(encoder));

-            frag.setFirst(true);

-            frag.setLast(true);

-            frag.setSectionCode(s.getSectionCode());

-            frag.setSectionNumber(UnsignedInteger.valueOf(num++));

-            frag.setSectionOffset(UnsignedLong.valueOf(0L));

-            fragments[i++] =frag;

-        }

-

-        xfr.setFragments(fragments);

-*/

-

-        encodeTypes("xfr",xfr);

-

-        final byte[] result;

-        final Object input = xfr;

-/*

-        result = encode(1024, input);

-

-        boolean ok = true;

-

-        for(int j = 10; ok && j < 400; j++)

-        {

-

-            byte[] result2 = encode(j,input);

-

-            for(int i = 0; i <400; i++)

-            {

-                if(result[i] != result2[i])

-                {

-                    System.out.println("result differs at " + i + " Splitting at " + j+ " [" + result[i] + " - " + result2[i] + "]");

-                    //break;

-                    //ok = false;

-

-                }

-            }

-        }*/

-        //System.out.println(Arrays.equals(result, result2));

-

-        //doEncodes();

-        /*OutputStream out = System.out;

-        if(args.length > 0)

-        {

-            out = new FileOutputStream(args[0]);

-        }

-

-        Transfer xfr = new Transfer();

-        fs.setSessionCredit(UnsignedInteger.valueOf(1024));

-        fs.setTransferCount(UnsignedInteger.valueOf(2));

-        fs.setLinkCredit(UnsignedInteger.valueOf(18));

-        fs.setAvailable(UnsignedInteger.valueOf(0));

-        fs.setDrain(false);

-

-        xfr.setHandle(UnsignedInteger.valueOf(0));

-        //xfr.setDeliveryTag(new Binary("\"queue\"<-6ec024a7-d98e-4196-9348-15f6026c32ca:0".getBytes()));

-        xfr.setDeliveryTag(new Binary(new byte[] {0}));

-        xfr.setTransferId(UnsignedInteger.valueOf(0));

-        xfr.setSettled(true);

-        xfr.setFlowState(fs);

-

-        Header h = new Header();

-        h.setTransmitTime(new Date(System.currentTimeMillis()));

-        Properties p = new Properties();

-        p.setTo(new Address("queue"));

-        //p.setMessageId(new Binary(UUID.randomUUID().toString().getBytes()));

-        AmqpMapSection m = new AmqpMapSection();

-        DataSection b = new DataSection("Hello World!".getBytes());

-

-        Footer f = new Footer();

-

-        Section[] sections = new Section[] { h,p,m,b,f};

-        //Section[] sections = new Section[] { b };

-        //Section[] sections = { h,p, b};

-        List<Fragment> fragments = new ArrayList<Fragment>(5);

-

-        final AMQPDescribedTypeRegistry typeRegistry = AMQPDescribedTypeRegistry.newInstance();

-

-        SectionEncoderImpl encoder = new SectionEncoderImpl(typeRegistry);

-

-        for(Section s : sections)

-        {

-            Fragment frag = new Fragment();

-

-            frag.setPayload(s.encode(encoder));

-            frag.setFirst(true);

-            frag.setLast(true);

-            frag.setFormatCode(s.getSectionCode());

-            frag.setFragmentOffset(null);

-            fragments.add(frag);

-        }

-

-        xfr.setFragments(fragments);

-

-

-        Object[] objectsToWrite = new Object[] { xfr };

-        ByteBuffer buf = ByteBuffer.allocate(4096);

-

-

-        for(Object obj : objectsToWrite)

-        {

-            ValueWriter writer = typeRegistry.getValueWriter(obj);

-

-            int count;

-

-

-            do

-            {

-                count = writer.writeToBuffer(buf);

-                out.write(buf.array(), buf.arrayOffset(), count);

-                buf.clear();

-            } while (!writer.isComplete());

-

-        }

-

-        out.flush();

-        out.close();*/

-

-    }

-

-    public static void doEncodes() throws IOException, ParseException

-    {

-        encodeTypes("boolean",  Boolean.TRUE,  Boolean.FALSE);

-        encodeTypes("ubyte",  UnsignedByte.valueOf((byte)0), UnsignedByte.valueOf((byte)1 ),UnsignedByte.valueOf((byte)3), UnsignedByte.valueOf((byte)42), UnsignedByte.valueOf("255"));

-        encodeTypes("byte",  Byte.valueOf((byte)0), Byte.valueOf( (byte)1), Byte.valueOf((byte) 3), Byte.valueOf((byte) 42), Byte.valueOf((byte) 127), Byte.valueOf((byte) -1), Byte.valueOf((byte) -3), Byte.valueOf((byte) -42), Byte.valueOf( (byte)-128));

-        encodeTypes("ushort",  UnsignedShort.valueOf((short)0), UnsignedShort.valueOf((short)1), UnsignedShort.valueOf((short)3), UnsignedShort.valueOf((short)42), UnsignedShort.valueOf("65535"));

-        encodeTypes("short",  Short.valueOf((short)0), Short.valueOf((short)1), Short.valueOf((short)3), Short.valueOf((short)42), Short.valueOf((short)32767), Short.valueOf((short)-1), Short.valueOf((short)-3), Short.valueOf((short)-42), Short.valueOf((short)-32768));

-        encodeTypes("uint",UnsignedInteger.valueOf(0), UnsignedInteger.valueOf(1), UnsignedInteger.valueOf(3), UnsignedInteger.valueOf(42), UnsignedInteger.valueOf("4294967295"));

-        encodeTypes("int",  0, 1, 3, 42, 2147483647, -1, -3, -42, -2147483648);

-        encodeTypes("ulong", UnsignedLong.valueOf(0), UnsignedLong.valueOf(1), UnsignedLong.valueOf(3), UnsignedLong.valueOf(42), UnsignedLong.valueOf("18446744073709551615"));

-        encodeTypes("long",  0l, 1l, 3l, 42l, 9223372036854775807l, -1l, -3l, -42l, -9223372036854775808l);

-        encodeTypes("float",  3.14159);

-        encodeTypes("double",  Double.valueOf(3.14159265359));

-        encodeTypes("char",  '?');

-

-        SimpleDateFormat df = new SimpleDateFormat("HHa z MMM d yyyy");

-

-        encodeTypes("timestamp",  df.parse("9AM PST Dec 6 2010"),   df.parse("9AM PST Dec 6 1910"));

-        encodeTypes("uuid",  UUID.fromString("f275ea5e-0c57-4ad7-b11a-b20c563d3b71"));

-        encodeTypes("binary",  new Binary( new byte[] {(byte)0xDE, (byte)0xAD, (byte)0xBE, (byte)0xEF}), new Binary(new byte[] { (byte)0xCA,(byte)0xFE, (byte)0xBA, (byte)0xBE}));

-        encodeTypes("string",  "The quick brown fox jumped over the lazy cow.");

-        encodeTypes("symbol",  Symbol.valueOf("connectathon"));

-        encodeTypes("list",  Arrays.asList(new Object[] {Long.valueOf(1), "two", Double.valueOf(3.14159265359), null, Boolean.FALSE}));

-        Map map = new HashMap();

-        map.put("one", Long.valueOf(1));

-        map.put("two", Long.valueOf(2));

-        map.put("pi", Double.valueOf(3.14159265359));

-        map.put("list:", Arrays.asList(new Object[] {Long.valueOf(1), "two", Double.valueOf(3.14159265359), null, Boolean.FALSE}));

-        map.put(null, Boolean.TRUE);

-        encodeTypes("map",  map);

-        encodeTypes("null",  null);

-

-    }

-

-    static void encodeTypes(String name, Object... vals ) throws IOException

-    {

-        FileOutputStream out = new FileOutputStream("/home/rob/"+name+".out");

-        ByteBuffer buf = ByteBuffer.allocate(4096);

-        final AMQPDescribedTypeRegistry typeRegistry = AMQPDescribedTypeRegistry.newInstance();

-

-        if(vals != null)

-        {

-            for(Object obj : vals)

-            {

-                ValueWriter writer = typeRegistry.getValueWriter(obj);

-

-                int count;

-

-

-                do

-                {

-                    count = writer.writeToBuffer(buf);

-                    out.write(buf.array(), buf.arrayOffset(), count);

-                    buf.clear();

-                } while (!writer.isComplete());

-

-            }

-        }

-        else

-        {

-            ValueWriter writer = typeRegistry.getValueWriter(null);

-

-            int count;

-

-

-            do

-            {

-                count = writer.writeToBuffer(buf);

-                out.write(buf.array(), buf.arrayOffset(), count);

-                buf.clear();

-            } while (!writer.isComplete());

-

-        }

-        out.flush();

-        out.close();

-

-    }

-

-    static byte[] encode(int size, Object... vals)

-    {

-        byte[] result = new byte[10000];

-        int pos = 0;

-

-        final AMQPDescribedTypeRegistry typeRegistry = AMQPDescribedTypeRegistry.newInstance();

-        AMQFrame frame = AMQFrame.createAMQFrame((short) 0, (FrameBody) vals[0]);

-        FrameWriter writer =  new FrameWriter(typeRegistry);

-        /*for(Object obj : vals)

-        {

-            final AMQPDescribedTypeRegistry typeRegistry = AMQPDescribedTypeRegistry.newInstance();

-            ValueWriter writer = typeRegistry.getValueWriter(obj);

-*/

-            int count;

-

-            ByteBuffer buf = ByteBuffer.wrap(result, pos, size);

-

-            do

-            {

-

-                writer.writeToBuffer(buf);

-                pos = buf.position();

-                buf = ByteBuffer.wrap(result, pos, size);

-                if(!writer.isComplete())

-                {

-                    count = 3;

-                }

-

-            } while (!writer.isComplete());

-/*

-

-        }

-*/

-

-        return result;

-

-    }

-

-

-}

diff --git a/java/build.deps b/java/build.deps
index 3f8387e36d..4775fcbf33 100644
--- a/java/build.deps
+++ b/java/build.deps
@@ -68,7 +68,8 @@ commons-configuration.libs = ${commons-beanutils-core} ${commons-digester} \
 common.libs=${slf4j-api}
 client.libs=${geronimo-jms}
 amqp-1-0-common.libs=
-amqp-1-0-client.libs=${commons-cli}
+amqp-1-0-client.libs=
+amqp-1-0-client-example.libs=${commons-cli}
 amqp-1-0-client-jms.libs=${geronimo-jms}
 tools.libs=${commons-configuration.libs} ${log4j}
 broker.libs=${commons-cli} ${commons-logging} ${log4j} ${slf4j-log4j} \
diff --git a/java/build.xml b/java/build.xml
index 7f51cb64c0..110d91852d 100644
--- a/java/build.xml
+++ b/java/build.xml
@@ -32,7 +32,7 @@
   </condition>
 
   <property name="modules.core"       value="common management/common amqp-1-0-common broker client amqp-1-0-client amqp-1-0-client-jms tools"/>
-  <property name="modules.examples"   value="client/example management/example"/>
+  <property name="modules.examples"   value="client/example management/example amqp-1-0-client/example amqp-1-0-client-jms/example"/>
   <property name="modules.tests"      value="systests perftests"/>
   <property name="modules.plugin"     value="${broker-plugins} ${client-plugins}"/>
   <property name="modules.jca"        value="jca"/>