summaryrefslogtreecommitdiff
path: root/client/test/src/org/apache/qpid/framing/FieldTableTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'client/test/src/org/apache/qpid/framing/FieldTableTest.java')
-rw-r--r--client/test/src/org/apache/qpid/framing/FieldTableTest.java162
1 files changed, 0 insertions, 162 deletions
diff --git a/client/test/src/org/apache/qpid/framing/FieldTableTest.java b/client/test/src/org/apache/qpid/framing/FieldTableTest.java
deleted file mode 100644
index a75fff68e1..0000000000
--- a/client/test/src/org/apache/qpid/framing/FieldTableTest.java
+++ /dev/null
@@ -1,162 +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.framing;
-
-import junit.framework.JUnit4TestAdapter;
-import org.apache.mina.common.ByteBuffer;
-import static org.junit.Assert.assertEquals;
-import org.junit.Test;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.Reader;
-import java.util.Enumeration;
-import java.util.Properties;
-
-public class FieldTableTest
-{
- @Test
- public void dataDump() throws IOException, AMQFrameDecodingException
- {
- byte[] data = readBase64("content.txt");
- System.out.println("Got " + data.length + " bytes of data");
- for (int i = 0; i < 100; i++)
- {
- System.out.print((char) data[i]);
- }
- System.out.println();
- int size = 4194304;
- ByteBuffer buffer = ByteBuffer.allocate(data.length);
- buffer.put(data);
- buffer.flip();
- FieldTable table = new FieldTable(buffer, size);
- }
-
- /*
- @Test
- public void case1() throws AMQFrameDecodingException, IOException
- {
- testEncoding(load("FieldTableTest.properties"));
- }
-
- @Test
- public void case2() throws AMQFrameDecodingException, IOException
- {
- testEncoding(load("FieldTableTest2.properties"));
- }
- */
- void testEncoding(FieldTable table) throws AMQFrameDecodingException
- {
- assertEquivalent(table, encodeThenDecode(table));
- }
-
- public void assertEquivalent(FieldTable table1, FieldTable table2)
- {
- for (Object o : table1.keySet())
- {
- String key = (String) o;
- assertEquals("Values for " + key + " did not match", table1.get(key), table2.get(key));
- //System.out.println("Values for " + key + " matched (" + table1.get(key) + ")");
- }
- }
-
- FieldTable encodeThenDecode(FieldTable table) throws AMQFrameDecodingException
- {
- ContentHeaderBody header = new ContentHeaderBody();
- header.classId = 6;
- BasicContentHeaderProperties properties = new BasicContentHeaderProperties();
- header.properties = properties;
-
- properties.setHeaders(table);
- int size = header.getSize();
-
- //encode
- ByteBuffer buffer = ByteBuffer.allocate(size);
- header.writePayload(buffer);
-
- //decode
- buffer.flip();
-
- header = new ContentHeaderBody();
- header.populateFromBuffer(buffer, size);
-
- return ((BasicContentHeaderProperties) header.properties).getHeaders();
- }
-
- byte[] readBase64(String name) throws IOException
- {
- String content = read(new InputStreamReader(getClass().getResourceAsStream(name)));
-
- return org.apache.commons.codec.binary.Base64.decodeBase64(content.getBytes());
- }
-
- FieldTable load(String name) throws IOException
- {
- return populate(new FieldTable(), read(name));
- }
-
- Properties read(String name) throws IOException
- {
- Properties p = new Properties();
- p.load(getClass().getResourceAsStream(name));
- return p;
- }
-
- FieldTable populate(FieldTable table, Properties properties)
- {
- for (Enumeration i = properties.propertyNames(); i.hasMoreElements();)
- {
- String key = (String) i.nextElement();
- String value = properties.getProperty(key);
- try{
- int ival = Integer.parseInt(value);
- table.put(key, (long) ival);
- }
- catch(NumberFormatException e)
- {
- table.put(key, value);
- }
- }
- return table;
- }
-
- static String read(Reader in) throws IOException
- {
- return read(in instanceof BufferedReader ? (BufferedReader) in : new BufferedReader(in));
- }
-
- static String read(BufferedReader in) throws IOException
- {
- StringBuffer buffer = new StringBuffer();
- String line = in.readLine();
- while (line != null){
- buffer.append(line).append(" ");
- line = in.readLine();
- }
- return buffer.toString();
- }
-
- public static junit.framework.Test suite()
- {
- return new JUnit4TestAdapter(FieldTableTest.class);
- }
-}