Initial checkin of AMQP 1-0 Java Prototype work

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/rg-amqp-1-0-sandbox@1157566 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 17 insertions, 14 deletions

diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockStoredMessage.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockStoredMessage.java
index 7dc491de4d..0f812c9c7a 100755
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockStoredMessage.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockStoredMessage.java
@@ -34,7 +34,7 @@ public class MockStoredMessage implements StoredMessage<MessageMetaData>
 {
     private long _messageId;
     private MessageMetaData _metaData;
-    private final ByteBuffer _content;
+    private ByteBuffer _content;
 
 
     public MockStoredMessage(long messageId)
@@ -46,8 +46,6 @@ public class MockStoredMessage implements StoredMessage<MessageMetaData>
     {
         _messageId = messageId;
         _metaData = new MessageMetaData(info, chb, 0);
-        _content = ByteBuffer.allocate(_metaData.getContentSize());
-
     }
 
     public MessageMetaData getMetaData()
@@ -63,6 +61,16 @@ public class MockStoredMessage implements StoredMessage<MessageMetaData>
     public void addContent(int offsetInMessage, ByteBuffer src)
     {
         src = src.duplicate();
+        if(_content == null || offsetInMessage + src.remaining() > _content.capacity())
+        {
+            ByteBuffer newContent = ByteBuffer.allocate(offsetInMessage+src.remaining());
+            if(_content != null)
+            {
+                newContent.duplicate().put(_content.array());
+            }
+            _content = newContent;
+        }
+
         ByteBuffer dst = _content.duplicate();
         dst.position(offsetInMessage);
         dst.put(src);
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java
index 1ec134e90e..1c318aa457 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java
@@ -129,11 +129,6 @@ public class MockSubscription implements Subscription
         return true;
     }
 
-    public void confirmAutoClose()
-    {
-
-    }
-
     public void set(String key, Object value)
     {
     }
@@ -143,11 +138,6 @@ public class MockSubscription implements Subscription
         return null;
     }
 
-    public boolean isAutoClose()
-    {
-        return false;
-    }
-
     public boolean isBrowser()
     {
         return false;
@@ -214,7 +204,7 @@ public class MockSubscription implements Subscription
     }
 
     public void setNoLocal(boolean noLocal)
-    {        
+    {
     }
 
     public void setStateListener(StateListener listener)
@@ -241,4 +231,9 @@ public class MockSubscription implements Subscription
     {
         return false;
     }
+
+    public void queueEmpty() throws AMQException
+    {
+        //TODO
+    }
 }