diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-10 12:44:26 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-10 12:44:26 +0000 |
| commit | 406a37271b1cc743101b3390a0506647a000d2e1 (patch) | |
| tree | 71463a773250d914e95f4730d4409e4a4f6e157a /qpid/java | |
| parent | a3888992865a54a3686c0e59b11a5d37d125bac4 (diff) | |
| download | qpid-python-406a37271b1cc743101b3390a0506647a000d2e1.tar.gz | |
added 0_10 factory
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@574227 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java b/qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java index 02a8544b52..2d71af56c0 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java +++ b/qpid/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) |