Repository: qpid-jms Updated Branches: refs/heads/master ee5042c14 -> 803400254
Add configuration value to control AmqpJmsObjectMessage creation using serialized or AMQP types. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/73fb97a8 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/73fb97a8 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/73fb97a8 Branch: refs/heads/master Commit: 73fb97a87ffd9cde8c3cef724a7d91ba4571a93b Parents: ee5042c Author: Timothy Bish <[email protected]> Authored: Wed Oct 8 16:57:17 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Oct 8 16:57:17 2014 -0400 ---------------------------------------------------------------------- .../qpid/jms/provider/amqp/AmqpConnection.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/73fb97a8/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConnection.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConnection.java index 20aab19..e53d5da 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConnection.java @@ -55,6 +55,7 @@ public class AmqpConnection extends AbstractAmqpResource<JmsConnectionInfo, Conn private String tempQueuePrefix; private String tempTopicPrefix; + private boolean objectMessageUsesAmqpTypes = false; private boolean anonymousProducerCache = false; private int anonymousProducerCacheSize = 10; @@ -304,6 +305,24 @@ public class AmqpConnection extends AbstractAmqpResource<JmsConnectionInfo, Conn } /** + * @return true if new ObjectMessage instance should default to using AMQP Typed bodies. + */ + public boolean isObjectMessageUsesAmqpTypes() { + return objectMessageUsesAmqpTypes; + } + + /** + * Configures the body type used in ObjectMessage instances that are sent from + * this connection. + * + * @param objectMessageUsesAmqpTypes + * the objectMessageUsesAmqpTypes value to set. + */ + public void setObjectMessageUsesAmqpTypes(boolean objectMessageUsesAmqpTypes) { + this.objectMessageUsesAmqpTypes = objectMessageUsesAmqpTypes; + } + + /** * @return the AMQP based JmsMessageFactory for this Connection. */ public AmqpJmsMessageFactory getAmqpMessageFactory() { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
