diff options
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java | 22 |
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) |