From 8b445c94a9be057d1a45668a1bf0a282fafab954 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Wed, 18 Oct 2006 18:13:01 +0000 Subject: Initial checkin of code generator (Java only at this stage) which allows for the simultaneous support of multiple AMQP versions. This is a temporary location, for comment and evaluation purposes only. This generator is NOT integrated with the rest of the QPID project; it is intended for stand-alone use only for now. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@465322 13f79535-47bb-0310-9956-ffa450edef68 --- .../templ.java/PropertyContentHeaderClass.tmpl | 204 +++++++++++++++++++++ 1 file changed, 204 insertions(+) create mode 100644 qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl (limited to 'qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl') diff --git a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl new file mode 100644 index 0000000000..bae99a4187 --- /dev/null +++ b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl @@ -0,0 +1,204 @@ +&{${CLASS}PropertyContentHeader.java} +/* + * + * Copyright (c) 2006 The Apache Software Foundation + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +/* + * This file is auto-generated by ${GENERATOR} - do not modify. + * Supported AMQP versions: +%{VLIST} * ${major}-${minor} + */ + +package org.apache.qpid.framing; + +import org.apache.log4j.Logger; +import org.apache.mina.common.ByteBuffer; + +class ${CLASS}ContentHeaderProperties implements ContentHeaderProperties +{ + private static final Logger logger = Logger.getLogger(BasicContentHeaderProperties.class); + + /** + * We store the encoded form when we decode the content header so that if we need to + * write it out without modifying it we can do so without incurring the expense of + * reencoding it. + */ + private byte[] encodedBuffer; + + /** + * Flag indicating whether the entire content header has been decoded yet. + */ + private boolean decodedFlag = true; + + /** + * We have some optimisations for partial decoding for maximum performance. The + * headers are used in the broker for routing in some cases so we can decode that + * separately. + */ + private boolean decodedHeadersFlag = true; + + /** + * We have some optimisations for partial decoding for maximum performance. The + * content type is used by all clients to determine the message type. + */ + private boolean decodedContentTypeFlag = true; + + /** + * AMQP major and minor version of this instance. + */ + private byte major; + private byte minor; + + /** + * Property flags. + */ + ${pch_property_flags_declare} + + // Header fields from specification +%{FLIST} ${field_declaration} + + /** + * Constructor + */ + public ${CLASS}ContentHeaderProperties(byte major, byte minor) + { + this.major = major; + this.minor = minor; + + // Although one flag is initialized per property, the flags are used + // in ordinal order of the AMQP version represented by this instance, + // thus the number of flags actually used may be less than the total + // number defined. + ${pch_property_flags_initializer} + } + + public int getPropertyListSize() + { + if (encodedBuffer != null) + { + return encodedBuffer.length; + } + else + { + int size = 0; +%{FLIST} ${pch_field_list_size} + return size; + } + } + + private void clearEncodedForm() + { + if (!decodedFlag && encodedBuffer != null) + { + //decode(); + } + encodedBuffer = null; + } + + public void setPropertyFlags(int[] compactPropertyFlags) + throws AMQProtocolVersionException + { + clearEncodedForm(); +${pch_compact_property_flags_check} +%{FLIST} ${pch_set_compact_property_flags} + } + + public int[] getPropertyFlags() + { + int[] compactPropertyFlags = new int[] { 0 }; +${pch_compact_property_flags_initializer} +%{FLIST} ${pch_get_compact_property_flags} + return compactPropertyFlags; + } + + public void writePropertyListPayload(ByteBuffer buffer) + { + if (encodedBuffer != null) + { + buffer.put(encodedBuffer); + } + else + { +%{FLIST} ${pch_field_list_payload} + } + } + + public void populatePropertiesFromBuffer(ByteBuffer buffer, int[] propertyFlags, int size) + throws AMQFrameDecodingException, AMQProtocolVersionException + { + setPropertyFlags(propertyFlags); + + if (logger.isDebugEnabled()) + { + logger.debug("Property flags: " + propertyFlags); + } + decode(buffer); + /*encodedBuffer = new byte[size]; + buffer.get(encodedBuffer, 0, size); + decodedFlag = false; + decodedHeadersFlag = false; + decodedContentTypeFlag = false;*/ + } + + private void decode(ByteBuffer buffer) + { + //ByteBuffer buffer = ByteBuffer.wrap(encodedBuffer); + int pos = buffer.position(); + try + { +%{FLIST} ${pch_field_list_decode} + // This line does nothing, but prevents a compiler error (Exception not thrown) + // if this block is empty. + if (false) throw new AMQFrameDecodingException(""); + } + catch (AMQFrameDecodingException e) + { + throw new RuntimeException("Error in content header data: " + e); + } + + final int endPos = buffer.position(); + buffer.position(pos); + final int len = endPos - pos; + encodedBuffer = new byte[len]; + final int limit = buffer.limit(); + buffer.limit(endPos); + buffer.get(encodedBuffer, 0, len); + buffer.limit(limit); + buffer.position(endPos); + decodedFlag = true; + } + + private void decodeIfNecessary() + { + if (!decodedFlag) + { + //decode(); + } + } + + // Field clear methods + +%{FLIST} ${pch_field_clear_methods} + + // Field get methods + +%{FLIST} ${pch_field_get_methods} + + // Field set methods + +%{FLIST} ${pch_field_set_methods} +} -- cgit v1.2.1 From 5404fc332f791e78fc7a957d393d0b517a807714 Mon Sep 17 00:00:00 2001 From: Stephen Vinoski Date: Fri, 10 Nov 2006 23:18:04 +0000 Subject: update Apache licenses to the current version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@473568 13f79535-47bb-0310-9956-ffa450edef68 --- .../templ.java/PropertyContentHeaderClass.tmpl | 29 ++++++++++++---------- 1 file changed, 16 insertions(+), 13 deletions(-) (limited to 'qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl') diff --git a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl index bae99a4187..6cc2e55a33 100644 --- a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl +++ b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl @@ -1,19 +1,22 @@ &{${CLASS}PropertyContentHeader.java} /* * - * Copyright (c) 2006 The Apache Software Foundation - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. * */ -- cgit v1.2.1 From 78ff340f476f700e3cc3fcfc305cae37db0f42dd Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Fri, 22 Dec 2006 17:43:09 +0000 Subject: Additional changes to support new Java AMQP version code, some C++ tidy-up as well. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@489704 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl') diff --git a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl index 6cc2e55a33..3c147cf6b6 100644 --- a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl +++ b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl @@ -1,4 +1,4 @@ -&{${CLASS}PropertyContentHeader.java} +&{${CLASS}ContentHeaderProperties.java} /* * * Licensed to the Apache Software Foundation (ASF) under one @@ -31,7 +31,7 @@ package org.apache.qpid.framing; import org.apache.log4j.Logger; import org.apache.mina.common.ByteBuffer; -class ${CLASS}ContentHeaderProperties implements ContentHeaderProperties +public class ${CLASS}ContentHeaderProperties implements ContentHeaderProperties { private static final Logger logger = Logger.getLogger(BasicContentHeaderProperties.class); -- cgit v1.2.1 From 3769af8867386add4cbfa191ec45f786e4f84e69 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Fri, 15 Jun 2007 16:37:08 +0000 Subject: Merged revisions 547178 via svnmerge from https://svn.apache.org/repos/asf/incubator/qpid/branches/M2 ........ r547178 | gsim | 2007-06-14 09:51:39 +0100 (Thu, 14 Jun 2007) | 3 lines Converted templates to generate classes using slf4j rather than log4j inline with changes applied in rev 546190. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@547731 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl') diff --git a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl index 3c147cf6b6..ab6406b1fe 100644 --- a/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl +++ b/qpid/gentools/templ.java/PropertyContentHeaderClass.tmpl @@ -28,12 +28,13 @@ package org.apache.qpid.framing; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.apache.mina.common.ByteBuffer; public class ${CLASS}ContentHeaderProperties implements ContentHeaderProperties { - private static final Logger logger = Logger.getLogger(BasicContentHeaderProperties.class); + private static final Logger logger = LoggerFactory.getLogger(BasicContentHeaderProperties.class); /** * We store the encoded form when we decode the content header so that if we need to -- cgit v1.2.1