From 913489deb2ee9dbf44455de5f407ddaf4bd8c540 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 19 Sep 2006 22:06:50 +0000 Subject: Import of qpid from etp: URL: https://etp.108.redhat.com/svn/etp/trunk/blaze Repository Root: https://etp.108.redhat.com/svn/etp Repository UUID: 06e15bec-b515-0410-bef0-cc27a458cf48 Revision: 608 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@447994 13f79535-47bb-0310-9956-ffa450edef68 --- java/common/bin/qpid-run | 176 +++++ java/common/build-module.xml | 129 ++++ java/common/build-old.xml | 98 +++ java/common/etc/qpid-run.conf | 22 + java/common/etc/qpid-run.conf.dev | 23 + java/common/lib/commons-cli/commons-cli-1.0.jar | Bin 0 -> 30117 bytes .../commons-collections-3.1.jar | Bin 0 -> 559366 bytes .../commons-configuration-1.2.jar | Bin 0 -> 163822 bytes java/common/lib/commons-lang/commons-lang-2.1.jar | Bin 0 -> 207723 bytes .../lib/commons-logging/commons-logging-api.jar | Bin 0 -> 26202 bytes .../common/lib/commons-logging/commons-logging.jar | Bin 0 -> 38015 bytes java/common/lib/junit/junit-4.0.jar | Bin 0 -> 105601 bytes java/common/lib/junit/junit.jar | Bin 0 -> 121070 bytes java/common/lib/logging-log4j/log4j-1.2.13.jar | Bin 0 -> 358180 bytes java/common/lib/mina/mina-core-0.9.5-SNAPSHOT.jar | Bin 0 -> 348936 bytes .../lib/mina/mina-filter-ssl-0.9.5-SNAPSHOT.jar | Bin 0 -> 18413 bytes java/common/lib/saxon/saxon8.jar | Bin 0 -> 3118502 bytes java/common/lib/slf4j/slf4j-simple.jar | Bin 0 -> 12243 bytes java/common/readme.txt | 4 + java/common/resources/ProtocolVersionList.java | 37 + java/common/resources/cluster.asl | 56 ++ .../common/resources/org/apache/qpid/ssl/qpid.cert | Bin 0 -> 756 bytes java/common/resources/registry.template | 22 + .../org/apache/qpid/AMQChannelClosedException.java | 31 + .../src/org/apache/qpid/AMQChannelException.java | 46 ++ .../apache/qpid/AMQConnectionClosedException.java | 31 + .../org/apache/qpid/AMQConnectionException.java | 27 + .../org/apache/qpid/AMQDisconnectedException.java | 31 + java/common/src/org/apache/qpid/AMQException.java | 74 ++ .../org/apache/qpid/AMQUndeliveredException.java | 41 ++ .../apache/qpid/AMQUnresolvedAddressException.java | 26 + java/common/src/org/apache/qpid/bio/Reader.java | 98 +++ java/common/src/org/apache/qpid/bio/Sequence.java | 29 + .../org/apache/qpid/bio/SimpleSocketChannel.java | 82 +++ .../src/org/apache/qpid/bio/SocketAcceptor.java | 277 ++++++++ .../src/org/apache/qpid/bio/SocketConnector.java | 150 ++++ .../src/org/apache/qpid/bio/SocketFilterChain.java | 62 ++ .../src/org/apache/qpid/bio/SocketSessionImpl.java | 421 +++++++++++ .../src/org/apache/qpid/codec/AMQCodecFactory.java | 50 ++ .../src/org/apache/qpid/codec/AMQDecoder.java | 96 +++ .../src/org/apache/qpid/codec/AMQEncoder.java | 38 + .../org/apache/qpid/configuration/Configured.java | 41 ++ .../qpid/configuration/PropertyException.java | 62 ++ .../apache/qpid/configuration/PropertyUtils.java | 153 ++++ .../org/apache/qpid/exchange/ExchangeDefaults.java | 33 + .../src/org/apache/qpid/framing/AMQBody.java | 35 + .../src/org/apache/qpid/framing/AMQDataBlock.java | 40 ++ .../apache/qpid/framing/AMQDataBlockDecoder.java | 113 +++ .../apache/qpid/framing/AMQDataBlockEncoder.java | 62 ++ .../src/org/apache/qpid/framing/AMQFrame.java | 73 ++ .../qpid/framing/AMQFrameDecodingException.java | 45 ++ .../src/org/apache/qpid/framing/AMQMethodBody.java | 87 +++ .../apache/qpid/framing/AMQMethodBodyFactory.java | 43 ++ .../qpid/framing/AMQProtocolClassException.java | 26 + .../qpid/framing/AMQProtocolHeaderException.java | 28 + .../qpid/framing/AMQProtocolInstanceException.java | 26 + .../qpid/framing/AMQProtocolVersionException.java | 30 + .../qpid/framing/BasicContentHeaderProperties.java | 592 ++++++++++++++++ .../src/org/apache/qpid/framing/BodyFactory.java | 28 + .../apache/qpid/framing/CompositeAMQDataBlock.java | 100 +++ .../src/org/apache/qpid/framing/ContentBody.java | 64 ++ .../apache/qpid/framing/ContentBodyFactory.java | 44 ++ .../org/apache/qpid/framing/ContentHeaderBody.java | 112 +++ .../qpid/framing/ContentHeaderBodyFactory.java | 47 ++ .../qpid/framing/ContentHeaderProperties.java | 55 ++ .../framing/ContentHeaderPropertiesFactory.java | 51 ++ .../apache/qpid/framing/EncodableAMQDataBlock.java | 32 + .../src/org/apache/qpid/framing/EncodingUtils.java | 519 ++++++++++++++ .../src/org/apache/qpid/framing/FieldTable.java | 319 +++++++++ .../qpid/framing/FieldTableKeyEnumeration.java | 44 ++ .../src/org/apache/qpid/framing/HeartbeatBody.java | 54 ++ .../apache/qpid/framing/HeartbeatBodyFactory.java | 28 + .../apache/qpid/framing/ProtocolInitiation.java | 176 +++++ .../src/org/apache/qpid/nio/SocketAcceptor.java | 31 + .../apache/qpid/nio/SocketAcceptorDelegate.java | 602 ++++++++++++++++ .../src/org/apache/qpid/nio/SocketConnector.java | 32 + .../apache/qpid/nio/SocketConnectorDelegate.java | 402 +++++++++++ .../src/org/apache/qpid/nio/SocketFilterChain.java | 48 ++ .../src/org/apache/qpid/nio/SocketIoProcessor.java | 770 +++++++++++++++++++++ .../src/org/apache/qpid/nio/SocketSessionImpl.java | 404 +++++++++++ java/common/src/org/apache/qpid/pool/Event.java | 111 +++ java/common/src/org/apache/qpid/pool/Job.java | 110 +++ .../src/org/apache/qpid/pool/PoolingFilter.java | 183 +++++ .../org/apache/qpid/pool/ReadWriteThreadModel.java | 37 + .../pool/ReferenceCountingExecutorService.java | 95 +++ .../src/org/apache/qpid/protocol/AMQConstant.java | 105 +++ .../apache/qpid/ssl/BogusSSLContextFactory.java | 156 +++++ .../apache/qpid/ssl/BogusTrustManagerFactory.java | 79 +++ .../apache/qpid/ssl/SSLServerSocketFactory.java | 105 +++ .../src/org/apache/qpid/ssl/SSLSocketFactory.java | 135 ++++ .../src/org/apache/qpid/url/AMQBindingURL.java | 260 +++++++ .../common/src/org/apache/qpid/url/BindingURL.java | 65 ++ java/common/src/org/apache/qpid/url/URLHelper.java | 173 +++++ .../org/apache/qpid/url/URLSyntaxException.java | 94 +++ java/common/stylesheets/framing.xsl | 61 ++ java/common/stylesheets/java.xsl | 247 +++++++ java/common/stylesheets/prepare1.xsl | 111 +++ java/common/stylesheets/prepare2.xsl | 66 ++ java/common/stylesheets/prepare3.xsl | 62 ++ java/common/stylesheets/readme.txt | 52 ++ java/common/stylesheets/registry.xsl | 29 + java/common/stylesheets/utils.xsl | 201 ++++++ 102 files changed, 10165 insertions(+) create mode 100644 java/common/bin/qpid-run create mode 100644 java/common/build-module.xml create mode 100644 java/common/build-old.xml create mode 100644 java/common/etc/qpid-run.conf create mode 100644 java/common/etc/qpid-run.conf.dev create mode 100644 java/common/lib/commons-cli/commons-cli-1.0.jar create mode 100644 java/common/lib/commons-collections/commons-collections-3.1.jar create mode 100644 java/common/lib/commons-configuration/commons-configuration-1.2.jar create mode 100644 java/common/lib/commons-lang/commons-lang-2.1.jar create mode 100644 java/common/lib/commons-logging/commons-logging-api.jar create mode 100644 java/common/lib/commons-logging/commons-logging.jar create mode 100644 java/common/lib/junit/junit-4.0.jar create mode 100644 java/common/lib/junit/junit.jar create mode 100644 java/common/lib/logging-log4j/log4j-1.2.13.jar create mode 100644 java/common/lib/mina/mina-core-0.9.5-SNAPSHOT.jar create mode 100644 java/common/lib/mina/mina-filter-ssl-0.9.5-SNAPSHOT.jar create mode 100644 java/common/lib/saxon/saxon8.jar create mode 100644 java/common/lib/slf4j/slf4j-simple.jar create mode 100644 java/common/readme.txt create mode 100644 java/common/resources/ProtocolVersionList.java create mode 100644 java/common/resources/cluster.asl create mode 100644 java/common/resources/org/apache/qpid/ssl/qpid.cert create mode 100644 java/common/resources/registry.template create mode 100644 java/common/src/org/apache/qpid/AMQChannelClosedException.java create mode 100644 java/common/src/org/apache/qpid/AMQChannelException.java create mode 100644 java/common/src/org/apache/qpid/AMQConnectionClosedException.java create mode 100644 java/common/src/org/apache/qpid/AMQConnectionException.java create mode 100644 java/common/src/org/apache/qpid/AMQDisconnectedException.java create mode 100644 java/common/src/org/apache/qpid/AMQException.java create mode 100644 java/common/src/org/apache/qpid/AMQUndeliveredException.java create mode 100644 java/common/src/org/apache/qpid/AMQUnresolvedAddressException.java create mode 100644 java/common/src/org/apache/qpid/bio/Reader.java create mode 100644 java/common/src/org/apache/qpid/bio/Sequence.java create mode 100644 java/common/src/org/apache/qpid/bio/SimpleSocketChannel.java create mode 100644 java/common/src/org/apache/qpid/bio/SocketAcceptor.java create mode 100644 java/common/src/org/apache/qpid/bio/SocketConnector.java create mode 100644 java/common/src/org/apache/qpid/bio/SocketFilterChain.java create mode 100644 java/common/src/org/apache/qpid/bio/SocketSessionImpl.java create mode 100644 java/common/src/org/apache/qpid/codec/AMQCodecFactory.java create mode 100644 java/common/src/org/apache/qpid/codec/AMQDecoder.java create mode 100644 java/common/src/org/apache/qpid/codec/AMQEncoder.java create mode 100644 java/common/src/org/apache/qpid/configuration/Configured.java create mode 100644 java/common/src/org/apache/qpid/configuration/PropertyException.java create mode 100644 java/common/src/org/apache/qpid/configuration/PropertyUtils.java create mode 100644 java/common/src/org/apache/qpid/exchange/ExchangeDefaults.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQBody.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQDataBlock.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQDataBlockDecoder.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQDataBlockEncoder.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQFrame.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQFrameDecodingException.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQMethodBody.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQMethodBodyFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQProtocolClassException.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQProtocolHeaderException.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQProtocolInstanceException.java create mode 100644 java/common/src/org/apache/qpid/framing/AMQProtocolVersionException.java create mode 100644 java/common/src/org/apache/qpid/framing/BasicContentHeaderProperties.java create mode 100644 java/common/src/org/apache/qpid/framing/BodyFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/CompositeAMQDataBlock.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentBody.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentBodyFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentHeaderBody.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentHeaderBodyFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentHeaderProperties.java create mode 100644 java/common/src/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/EncodableAMQDataBlock.java create mode 100644 java/common/src/org/apache/qpid/framing/EncodingUtils.java create mode 100644 java/common/src/org/apache/qpid/framing/FieldTable.java create mode 100644 java/common/src/org/apache/qpid/framing/FieldTableKeyEnumeration.java create mode 100644 java/common/src/org/apache/qpid/framing/HeartbeatBody.java create mode 100644 java/common/src/org/apache/qpid/framing/HeartbeatBodyFactory.java create mode 100644 java/common/src/org/apache/qpid/framing/ProtocolInitiation.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketAcceptor.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketAcceptorDelegate.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketConnector.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketConnectorDelegate.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketFilterChain.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketIoProcessor.java create mode 100644 java/common/src/org/apache/qpid/nio/SocketSessionImpl.java create mode 100644 java/common/src/org/apache/qpid/pool/Event.java create mode 100644 java/common/src/org/apache/qpid/pool/Job.java create mode 100644 java/common/src/org/apache/qpid/pool/PoolingFilter.java create mode 100644 java/common/src/org/apache/qpid/pool/ReadWriteThreadModel.java create mode 100644 java/common/src/org/apache/qpid/pool/ReferenceCountingExecutorService.java create mode 100644 java/common/src/org/apache/qpid/protocol/AMQConstant.java create mode 100644 java/common/src/org/apache/qpid/ssl/BogusSSLContextFactory.java create mode 100644 java/common/src/org/apache/qpid/ssl/BogusTrustManagerFactory.java create mode 100644 java/common/src/org/apache/qpid/ssl/SSLServerSocketFactory.java create mode 100644 java/common/src/org/apache/qpid/ssl/SSLSocketFactory.java create mode 100644 java/common/src/org/apache/qpid/url/AMQBindingURL.java create mode 100644 java/common/src/org/apache/qpid/url/BindingURL.java create mode 100644 java/common/src/org/apache/qpid/url/URLHelper.java create mode 100644 java/common/src/org/apache/qpid/url/URLSyntaxException.java create mode 100644 java/common/stylesheets/framing.xsl create mode 100644 java/common/stylesheets/java.xsl create mode 100644 java/common/stylesheets/prepare1.xsl create mode 100644 java/common/stylesheets/prepare2.xsl create mode 100644 java/common/stylesheets/prepare3.xsl create mode 100644 java/common/stylesheets/readme.txt create mode 100644 java/common/stylesheets/registry.xsl create mode 100644 java/common/stylesheets/utils.xsl (limited to 'java/common') diff --git a/java/common/bin/qpid-run b/java/common/bin/qpid-run new file mode 100644 index 0000000000..ef2348d45e --- /dev/null +++ b/java/common/bin/qpid-run @@ -0,0 +1,176 @@ +#!/bin/bash +# +# 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. +# + +die() { + if [[ $1 = -usage ]]; then + shift + usage=true + else + usage=false + fi + echo "$@" + $usage && echo + $usage && usage + exit 1 +} + +if [ -z "$QPID_HOME" ]; then + die "QPID_HOME must be set" +fi + +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: