From acaf7d59a7c287d0f06a18973b3487a515fa6ff8 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 31 Oct 2007 18:29:09 +0000 Subject: Creating a tag for the latest java RC. This will be promoted as the Final release if the RC is good git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/tags/M2@590781 13f79535-47bb-0310-9956-ffa450edef68 --- Final/java/common/bin/qpid-run | 238 +++++ Final/java/common/etc/qpid-run.conf | 25 + Final/java/common/etc/qpid-run.conf.dev | 26 + Final/java/common/pom.xml | 156 +++ Final/java/common/protocol-version.xml | 60 ++ Final/java/common/readme.txt | 4 + Final/java/common/src/main/java/log4j.properties | 28 + .../org/apache/qpid/AMQChannelClosedException.java | 41 + .../java/org/apache/qpid/AMQChannelException.java | 68 ++ .../apache/qpid/AMQConnectionClosedException.java | 44 + .../org/apache/qpid/AMQConnectionException.java | 73 ++ .../apache/qpid/AMQConnectionFailureException.java | 40 + .../org/apache/qpid/AMQDisconnectedException.java | 39 + .../main/java/org/apache/qpid/AMQException.java | 101 ++ .../apache/qpid/AMQInvalidArgumentException.java | 39 + .../apache/qpid/AMQInvalidRoutingKeyException.java | 39 + .../org/apache/qpid/AMQPInvalidClassException.java | 39 + .../java/org/apache/qpid/AMQTimeoutException.java | 39 + .../org/apache/qpid/AMQUndeliveredException.java | 48 + .../org/apache/qpid/AMQUnknownExchangeType.java | 43 + .../apache/qpid/AMQUnresolvedAddressException.java | 50 + .../org/apache/qpid/codec/AMQCodecFactory.java | 77 ++ .../java/org/apache/qpid/codec/AMQDecoder.java | 163 ++++ .../java/org/apache/qpid/codec/AMQEncoder.java | 66 ++ .../org/apache/qpid/common/AMQPFilterTypes.java | 61 ++ .../org/apache/qpid/common/ClientProperties.java | 37 + .../org/apache/qpid/common/QpidProperties.java | 190 ++++ .../org/apache/qpid/configuration/Configured.java | 44 + .../qpid/configuration/PropertyException.java | 60 ++ .../apache/qpid/configuration/PropertyUtils.java | 164 ++++ .../org/apache/qpid/exchange/ExchangeDefaults.java | 65 ++ .../main/java/org/apache/qpid/framing/AMQBody.java | 39 + .../java/org/apache/qpid/framing/AMQDataBlock.java | 53 + .../apache/qpid/framing/AMQDataBlockDecoder.java | 120 +++ .../apache/qpid/framing/AMQDataBlockEncoder.java | 61 ++ .../java/org/apache/qpid/framing/AMQFrame.java | 75 ++ .../qpid/framing/AMQFrameDecodingException.java | 41 + .../org/apache/qpid/framing/AMQMethodBody.java | 132 +++ .../apache/qpid/framing/AMQMethodBodyFactory.java | 46 + .../qpid/framing/AMQMethodBodyInstanceFactory.java | 31 + .../qpid/framing/AMQProtocolClassException.java | 39 + .../qpid/framing/AMQProtocolHeaderException.java | 41 + .../qpid/framing/AMQProtocolInstanceException.java | 39 + .../qpid/framing/AMQProtocolVersionException.java | 39 + .../org/apache/qpid/framing/AMQShortString.java | 436 +++++++++ .../main/java/org/apache/qpid/framing/AMQType.java | 701 +++++++++++++ .../java/org/apache/qpid/framing/AMQTypeMap.java | 48 + .../org/apache/qpid/framing/AMQTypedValue.java | 80 ++ .../qpid/framing/BasicContentHeaderProperties.java | 799 +++++++++++++++ .../java/org/apache/qpid/framing/BodyFactory.java | 31 + .../framing/CommonContentHeaderProperties.java | 81 ++ .../apache/qpid/framing/CompositeAMQDataBlock.java | 103 ++ .../main/java/org/apache/qpid/framing/Content.java | 26 + .../java/org/apache/qpid/framing/ContentBody.java | 106 ++ .../apache/qpid/framing/ContentBodyFactory.java | 48 + .../org/apache/qpid/framing/ContentHeaderBody.java | 123 +++ .../qpid/framing/ContentHeaderBodyFactory.java | 50 + .../qpid/framing/ContentHeaderProperties.java | 58 ++ .../framing/ContentHeaderPropertiesFactory.java | 57 ++ .../apache/qpid/framing/EncodableAMQDataBlock.java | 35 + .../org/apache/qpid/framing/EncodingUtils.java | 1028 ++++++++++++++++++++ .../java/org/apache/qpid/framing/FieldTable.java | 1017 +++++++++++++++++++ .../org/apache/qpid/framing/FieldTableFactory.java | 38 + .../org/apache/qpid/framing/HeartbeatBody.java | 71 ++ .../apache/qpid/framing/HeartbeatBodyFactory.java | 31 + .../apache/qpid/framing/MethodConverter_8_0.java | 125 +++ .../apache/qpid/framing/ProtocolInitiation.java | 194 ++++ .../qpid/framing/SmallCompositeAMQDataBlock.java | 98 ++ .../qpid/framing/VersionSpecificRegistry.java | 198 ++++ .../abstraction/AbstractMethodConverter.java | 47 + .../qpid/framing/abstraction/ContentChunk.java | 32 + .../framing/abstraction/MessagePublishInfo.java | 36 + .../abstraction/MessagePublishInfoConverter.java | 32 + .../ProtocolVersionMethodConverter.java | 32 + .../src/main/java/org/apache/qpid/pool/Event.java | 155 +++ .../src/main/java/org/apache/qpid/pool/Job.java | 162 +++ .../java/org/apache/qpid/pool/PoolingFilter.java | 471 +++++++++ .../org/apache/qpid/pool/ReadWriteThreadModel.java | 102 ++ .../pool/ReferenceCountingExecutorService.java | 145 +++ .../java/org/apache/qpid/protocol/AMQConstant.java | 227 +++++ .../org/apache/qpid/protocol/AMQMethodEvent.java | 95 ++ .../apache/qpid/protocol/AMQMethodListener.java | 69 ++ .../apache/qpid/protocol/AMQProtocolWriter.java | 43 + .../protocol/AMQVersionAwareProtocolSession.java | 46 + .../apache/qpid/protocol/ProtocolVersionAware.java | 47 + .../org/apache/qpid/ssl/SSLContextFactory.java | 157 +++ .../java/org/apache/qpid/url/AMQBindingURL.java | 294 ++++++ .../main/java/org/apache/qpid/url/BindingURL.java | 56 ++ .../main/java/org/apache/qpid/url/URLHelper.java | 172 ++++ .../org/apache/qpid/url/URLSyntaxException.java | 97 ++ .../org/apache/qpid/util/CommandLineParser.java | 689 +++++++++++++ .../ConcurrentLinkedMessageQueueAtomicSize.java | 250 +++++ .../qpid/util/ConcurrentLinkedQueueAtomicSize.java | 70 ++ .../qpid/util/ConcurrentLinkedQueueNoSize.java | 38 + .../main/java/org/apache/qpid/util/FileUtils.java | 195 ++++ .../java/org/apache/qpid/util/MessageQueue.java | 43 + .../org/apache/qpid/util/PrettyPrintingUtils.java | 75 ++ .../java/org/apache/qpid/util/PropertiesUtils.java | 200 ++++ .../java/org/apache/qpid/util/ReflectionUtils.java | 228 +++++ .../apache/qpid/util/ReflectionUtilsException.java | 44 + .../main/resources/org/apache/qpid/ssl/qpid.cert | Bin 0 -> 756 bytes .../framing/BasicContentHeaderPropertiesTest.java | 188 ++++ .../qpid/framing/PropertyFieldTableTest.java | 906 +++++++++++++++++ .../org/apache/qpid/pool/PoolingFilterTest.java | 111 +++ .../java/org/apache/qpid/session/TestSession.java | 277 ++++++ .../apache/qpid/util/CommandLineParserTest.java | 554 +++++++++++ 106 files changed, 14890 insertions(+) create mode 100644 Final/java/common/bin/qpid-run create mode 100644 Final/java/common/etc/qpid-run.conf create mode 100644 Final/java/common/etc/qpid-run.conf.dev create mode 100644 Final/java/common/pom.xml create mode 100644 Final/java/common/protocol-version.xml create mode 100644 Final/java/common/readme.txt create mode 100644 Final/java/common/src/main/java/log4j.properties create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQChannelClosedException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQChannelException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQConnectionClosedException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQConnectionException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQDisconnectedException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQInvalidArgumentException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQInvalidRoutingKeyException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQPInvalidClassException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQTimeoutException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQUndeliveredException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQUnknownExchangeType.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/AMQUnresolvedAddressException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/codec/AMQCodecFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/codec/AMQDecoder.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/codec/AMQEncoder.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/common/AMQPFilterTypes.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/common/ClientProperties.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/common/QpidProperties.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/configuration/Configured.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/configuration/PropertyException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/configuration/PropertyUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/exchange/ExchangeDefaults.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQBody.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlockDecoder.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlockEncoder.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQFrame.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQFrameDecodingException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQMethodBody.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQMethodBodyFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQMethodBodyInstanceFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQProtocolClassException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQProtocolHeaderException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQProtocolInstanceException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQProtocolVersionException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQType.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQTypeMap.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/AMQTypedValue.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/BodyFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/CommonContentHeaderProperties.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/Content.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentBody.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentBodyFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderBody.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderBodyFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderProperties.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/EncodableAMQDataBlock.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/EncodingUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/FieldTable.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/FieldTableFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/HeartbeatBody.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/HeartbeatBodyFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/MethodConverter_8_0.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/ProtocolInitiation.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/SmallCompositeAMQDataBlock.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/VersionSpecificRegistry.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/abstraction/AbstractMethodConverter.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/abstraction/ContentChunk.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/abstraction/MessagePublishInfo.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/abstraction/MessagePublishInfoConverter.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/framing/abstraction/ProtocolVersionMethodConverter.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/pool/Event.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/pool/Job.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/pool/PoolingFilter.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/pool/ReadWriteThreadModel.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/pool/ReferenceCountingExecutorService.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/AMQConstant.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/AMQMethodEvent.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/AMQMethodListener.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/AMQProtocolWriter.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/AMQVersionAwareProtocolSession.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/protocol/ProtocolVersionAware.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/ssl/SSLContextFactory.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/url/AMQBindingURL.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/url/BindingURL.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/url/URLHelper.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/url/URLSyntaxException.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/CommandLineParser.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedMessageQueueAtomicSize.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/ConcurrentLinkedQueueNoSize.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/FileUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/MessageQueue.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/PrettyPrintingUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/PropertiesUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/ReflectionUtils.java create mode 100644 Final/java/common/src/main/java/org/apache/qpid/util/ReflectionUtilsException.java create mode 100644 Final/java/common/src/main/resources/org/apache/qpid/ssl/qpid.cert create mode 100644 Final/java/common/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java create mode 100644 Final/java/common/src/test/java/org/apache/qpid/framing/PropertyFieldTableTest.java create mode 100644 Final/java/common/src/test/java/org/apache/qpid/pool/PoolingFilterTest.java create mode 100644 Final/java/common/src/test/java/org/apache/qpid/session/TestSession.java create mode 100644 Final/java/common/src/test/java/org/apache/qpid/util/CommandLineParserTest.java (limited to 'Final/java/common') diff --git a/Final/java/common/bin/qpid-run b/Final/java/common/bin/qpid-run new file mode 100644 index 0000000000..c9e37b21a1 --- /dev/null +++ b/Final/java/common/bin/qpid-run @@ -0,0 +1,238 @@ +#!/bin/bash +# +# 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. +# + +# Test if we're running on cygwin. +cygwin=false +if [[ "$(uname -a | fgrep Cygwin)" != "" ]]; then + cygwin=true +fi + +die() { + if [[ $1 = -usage ]]; then + shift + usage=true + else + usage=false + fi + echo "$@" + $usage && echo + $usage && usage + exit 1 +} + +if [ -z $AMQJ_LOGGING_LEVEL ]; then + export AMQJ_LOGGING_LEVEL=info +fi + +if [ -z "$QPID_HOME" ]; then + die "QPID_HOME must be set" +fi + +if [ -z "$QPID_WORK" ]; then + echo Setting QPID_WORK to $HOME as default + QPID_WORK=$HOME +fi + +if $cygwin; then + QPID_HOME=$(cygpath -w $QPID_HOME) + QPID_WORK=$(cygpath -w $QPID_WORK) +fi + +#Set the default system properties that we'll use now that they have +#all been initialised +SYSTEM_PROPS="-Damqj.logging.level=$AMQJ_LOGGING_LEVEL -DQPID_HOME=$QPID_HOME -DQPID_WORK=$QPID_WORK" + +#If logprefix or logsuffix set to use PID make that happen +#Otherwise just pass the value through for these props +#Using X character to avoid probs with empty strings +if [ -n "$QPID_LOG_PREFIX" ]; then + if [ "X$QPID_LOG_PREFIX" = "XPID" ]; then + echo Using pid in qpid log name prefix + LOG_PREFIX=" -Dlogprefix=$$" + else + echo Using qpid logprefix property + LOG_PREFIX=" -Dlogprefix=$QPID_LOG_PREFIX" + fi + SYSTEM_PROPS="${SYSTEM_PROPS} ${LOG_PREFIX}" +fi + +if [ -n "$QPID_LOG_SUFFIX" ]; then + if [ "X$QPID_LOG_SUFFIX" = "XPID" ]; then + echo Using pid in qpid log name suffix + LOG_SUFFIX=" -Dlogsuffix=$$" + else + echo Using qpig logsuffix property + LOG_SUFFIX=" -Dlogsuffix=$QPID_LOG_SUFFIX" + fi + SYSTEM_PROPS="${SYSTEM_PROPS} ${LOG_SUFFIX}" +fi + +echo System Properties set to $SYSTEM_PROPS + +program=$(basename $0) +sourced=${BASH_SOURCE[0]} +if [[ -z ${sourced:-''} ]]; then + sourced=$(which qpid-run) || ${QPID_HOME}/bin/qpid-run +fi + +usage() { + echo Usage: $program ... "[-run: