added 0_10 factory

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

1 files changed, 21 insertions, 1 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java b/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java
index 02a8544b52..2d71af56c0 100644
--- a/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java
+++ b/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java
@@ -41,7 +41,7 @@ public class MessageFactoryRegistry
      * Construct a new registry with the default message factories registered
      * @return a message factory registry
      */
-    public static MessageFactoryRegistry newDefaultRegistry()
+    public static MessageFactoryRegistry newDefault08Registry()
     {
         MessageFactoryRegistry mf = new MessageFactoryRegistry();
         mf.registerFactory(JMSMapMessage.MIME_TYPE, new JMSMapMessageFactory());
@@ -55,6 +55,26 @@ public class MessageFactoryRegistry
         return mf;
     }
 
+    /**
+     * Construct a new 010 registry with the default message factories registered
+     * @return a message factory registry
+     */
+    public static MessageFactoryRegistry newDefault010Registry()
+    {
+        // TODO use 0.10 classes 
+        MessageFactoryRegistry mf = new MessageFactoryRegistry();
+        mf.registerFactory(JMSMapMessage.MIME_TYPE, new JMSMapMessageFactory());
+        mf.registerFactory("text/plain", new JMSTextMessageFactory());
+        mf.registerFactory("text/xml", new JMSTextMessageFactory());
+        mf.registerFactory(JMSBytesMessage.MIME_TYPE, new JMSBytesMessageFactory());
+        mf.registerFactory(JMSObjectMessage.MIME_TYPE, new JMSObjectMessageFactory());
+        mf.registerFactory(JMSStreamMessage.MIME_TYPE, new JMSStreamMessageFactory());
+        mf.registerFactory(null, new JMSBytesMessageFactory());
+
+        return mf;
+    }
+
+
     public void registerFactory(String mimeType, MessageFactory mf)
     {
         if (mf == null)