diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2012-09-28 17:28:00 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2012-09-28 17:28:00 +0000 |
| commit | 6b72b73914da12f5773735b300e85a9c2a1aaa20 (patch) | |
| tree | ea5cf4bb4b375fbd25e1f88d44ed17163435553f /java/client/src/main | |
| parent | 74b3e384c7d901ba13dce4c81f7032f262806f8d (diff) | |
| download | qpid-python-6b72b73914da12f5773735b300e85a9c2a1aaa20.tar.gz | |
QPID-3906 Fixed an error with the default. Added unit tests for testing
StreamMessage encoding defaults.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1391567 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/main')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 2aef0625bf..49964639e4 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -402,7 +402,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic MessageFactoryRegistry messageFactoryRegistry, int defaultPrefetchHighMark, int defaultPrefetchLowMark) { _useAMQPEncodedMapMessage = con == null ? true : !con.isUseLegacyMapMessageFormat(); - _useAMQPEncodedStreamMessage = con == null ? true : !con.isUseLegacyStreamMessageFormat(); + _useAMQPEncodedStreamMessage = con == null ? false : !con.isUseLegacyStreamMessageFormat(); _strictAMQP = Boolean.parseBoolean(System.getProperties().getProperty(STRICT_AMQP, STRICT_AMQP_DEFAULT)); _strictAMQPFATAL = Boolean.parseBoolean(System.getProperties().getProperty(STRICT_AMQP_FATAL, STRICT_AMQP_FATAL_DEFAULT)); @@ -1367,7 +1367,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic public StreamMessage createStreamMessage() throws JMSException { checkNotClosed(); - if (_useAMQPEncodedMapMessage) + if (_useAMQPEncodedStreamMessage) { AMQPEncodedListMessage msg = new AMQPEncodedListMessage(getMessageDelegateFactory()); msg.setAMQSession(this); |