实例介绍
【实例截图】
【核心代码】
.
├── rabbitMQ java Client rabbitMQ java Client_rabbitmq-java-client-2.7.0.rar
└── rabbitmq-java-client-2.7.0
├── LICENSE
├── LICENSE-APACHE2
├── LICENSE-GPL2
├── LICENSE-MPL-RabbitMQ
├── Makefile
├── README
├── README-EXAMPLES
├── README-TESTS
├── build
│ ├── classes
│ │ └── com
│ │ └── rabbitmq
│ │ ├── client
│ │ │ ├── AMQP$Access$Request$Builder.class
│ │ │ ├── AMQP$Access$Request.class
│ │ │ ├── AMQP$Access$RequestOk$Builder.class
│ │ │ ├── AMQP$Access$RequestOk.class
│ │ │ ├── AMQP$Access.class
│ │ │ ├── AMQP$Basic$Ack$Builder.class
│ │ │ ├── AMQP$Basic$Ack.class
│ │ │ ├── AMQP$Basic$Cancel$Builder.class
│ │ │ ├── AMQP$Basic$Cancel.class
│ │ │ ├── AMQP$Basic$CancelOk$Builder.class
│ │ │ ├── AMQP$Basic$CancelOk.class
│ │ │ ├── AMQP$Basic$Consume$Builder.class
│ │ │ ├── AMQP$Basic$Consume.class
│ │ │ ├── AMQP$Basic$ConsumeOk$Builder.class
│ │ │ ├── AMQP$Basic$ConsumeOk.class
│ │ │ ├── AMQP$Basic$Deliver$Builder.class
│ │ │ ├── AMQP$Basic$Deliver.class
│ │ │ ├── AMQP$Basic$Get$Builder.class
│ │ │ ├── AMQP$Basic$Get.class
│ │ │ ├── AMQP$Basic$GetEmpty$Builder.class
│ │ │ ├── AMQP$Basic$GetEmpty.class
│ │ │ ├── AMQP$Basic$GetOk$Builder.class
│ │ │ ├── AMQP$Basic$GetOk.class
│ │ │ ├── AMQP$Basic$Nack$Builder.class
│ │ │ ├── AMQP$Basic$Nack.class
│ │ │ ├── AMQP$Basic$Publish$Builder.class
│ │ │ ├── AMQP$Basic$Publish.class
│ │ │ ├── AMQP$Basic$Qos$Builder.class
│ │ │ ├── AMQP$Basic$Qos.class
│ │ │ ├── AMQP$Basic$QosOk$Builder.class
│ │ │ ├── AMQP$Basic$QosOk.class
│ │ │ ├── AMQP$Basic$Recover$Builder.class
│ │ │ ├── AMQP$Basic$Recover.class
│ │ │ ├── AMQP$Basic$RecoverAsync$Builder.class
│ │ │ ├── AMQP$Basic$RecoverAsync.class
│ │ │ ├── AMQP$Basic$RecoverOk$Builder.class
│ │ │ ├── AMQP$Basic$RecoverOk.class
│ │ │ ├── AMQP$Basic$Reject$Builder.class
│ │ │ ├── AMQP$Basic$Reject.class
│ │ │ ├── AMQP$Basic$Return$Builder.class
│ │ │ ├── AMQP$Basic$Return.class
│ │ │ ├── AMQP$Basic.class
│ │ │ ├── AMQP$BasicProperties$Builder.class
│ │ │ ├── AMQP$BasicProperties.class
│ │ │ ├── AMQP$Channel$Close$Builder.class
│ │ │ ├── AMQP$Channel$Close.class
│ │ │ ├── AMQP$Channel$CloseOk$Builder.class
│ │ │ ├── AMQP$Channel$CloseOk.class
│ │ │ ├── AMQP$Channel$Flow$Builder.class
│ │ │ ├── AMQP$Channel$Flow.class
│ │ │ ├── AMQP$Channel$FlowOk$Builder.class
│ │ │ ├── AMQP$Channel$FlowOk.class
│ │ │ ├── AMQP$Channel$Open$Builder.class
│ │ │ ├── AMQP$Channel$Open.class
│ │ │ ├── AMQP$Channel$OpenOk$Builder.class
│ │ │ ├── AMQP$Channel$OpenOk.class
│ │ │ ├── AMQP$Channel.class
│ │ │ ├── AMQP$Confirm$Select$Builder.class
│ │ │ ├── AMQP$Confirm$Select.class
│ │ │ ├── AMQP$Confirm$SelectOk$Builder.class
│ │ │ ├── AMQP$Confirm$SelectOk.class
│ │ │ ├── AMQP$Confirm.class
│ │ │ ├── AMQP$Connection$Close$Builder.class
│ │ │ ├── AMQP$Connection$Close.class
│ │ │ ├── AMQP$Connection$CloseOk$Builder.class
│ │ │ ├── AMQP$Connection$CloseOk.class
│ │ │ ├── AMQP$Connection$Open$Builder.class
│ │ │ ├── AMQP$Connection$Open.class
│ │ │ ├── AMQP$Connection$OpenOk$Builder.class
│ │ │ ├── AMQP$Connection$OpenOk.class
│ │ │ ├── AMQP$Connection$Secure$Builder.class
│ │ │ ├── AMQP$Connection$Secure.class
│ │ │ ├── AMQP$Connection$SecureOk$Builder.class
│ │ │ ├── AMQP$Connection$SecureOk.class
│ │ │ ├── AMQP$Connection$Start$Builder.class
│ │ │ ├── AMQP$Connection$Start.class
│ │ │ ├── AMQP$Connection$StartOk$Builder.class
│ │ │ ├── AMQP$Connection$StartOk.class
│ │ │ ├── AMQP$Connection$Tune$Builder.class
│ │ │ ├── AMQP$Connection$Tune.class
│ │ │ ├── AMQP$Connection$TuneOk$Builder.class
│ │ │ ├── AMQP$Connection$TuneOk.class
│ │ │ ├── AMQP$Connection.class
│ │ │ ├── AMQP$Exchange$Bind$Builder.class
│ │ │ ├── AMQP$Exchange$Bind.class
│ │ │ ├── AMQP$Exchange$BindOk$Builder.class
│ │ │ ├── AMQP$Exchange$BindOk.class
│ │ │ ├── AMQP$Exchange$Declare$Builder.class
│ │ │ ├── AMQP$Exchange$Declare.class
│ │ │ ├── AMQP$Exchange$DeclareOk$Builder.class
│ │ │ ├── AMQP$Exchange$DeclareOk.class
│ │ │ ├── AMQP$Exchange$Delete$Builder.class
│ │ │ ├── AMQP$Exchange$Delete.class
│ │ │ ├── AMQP$Exchange$DeleteOk$Builder.class
│ │ │ ├── AMQP$Exchange$DeleteOk.class
│ │ │ ├── AMQP$Exchange$Unbind$Builder.class
│ │ │ ├── AMQP$Exchange$Unbind.class
│ │ │ ├── AMQP$Exchange$UnbindOk$Builder.class
│ │ │ ├── AMQP$Exchange$UnbindOk.class
│ │ │ ├── AMQP$Exchange.class
│ │ │ ├── AMQP$PROTOCOL.class
│ │ │ ├── AMQP$Queue$Bind$Builder.class
│ │ │ ├── AMQP$Queue$Bind.class
│ │ │ ├── AMQP$Queue$BindOk$Builder.class
│ │ │ ├── AMQP$Queue$BindOk.class
│ │ │ ├── AMQP$Queue$Declare$Builder.class
│ │ │ ├── AMQP$Queue$Declare.class
│ │ │ ├── AMQP$Queue$DeclareOk$Builder.class
│ │ │ ├── AMQP$Queue$DeclareOk.class
│ │ │ ├── AMQP$Queue$Delete$Builder.class
│ │ │ ├── AMQP$Queue$Delete.class
│ │ │ ├── AMQP$Queue$DeleteOk$Builder.class
│ │ │ ├── AMQP$Queue$DeleteOk.class
│ │ │ ├── AMQP$Queue$Purge$Builder.class
│ │ │ ├── AMQP$Queue$Purge.class
│ │ │ ├── AMQP$Queue$PurgeOk$Builder.class
│ │ │ ├── AMQP$Queue$PurgeOk.class
│ │ │ ├── AMQP$Queue$Unbind$Builder.class
│ │ │ ├── AMQP$Queue$Unbind.class
│ │ │ ├── AMQP$Queue$UnbindOk$Builder.class
│ │ │ ├── AMQP$Queue$UnbindOk.class
│ │ │ ├── AMQP$Queue.class
│ │ │ ├── AMQP$Tx$Commit$Builder.class
│ │ │ ├── AMQP$Tx$Commit.class
│ │ │ ├── AMQP$Tx$CommitOk$Builder.class
│ │ │ ├── AMQP$Tx$CommitOk.class
│ │ │ ├── AMQP$Tx$Rollback$Builder.class
│ │ │ ├── AMQP$Tx$Rollback.class
│ │ │ ├── AMQP$Tx$RollbackOk$Builder.class
│ │ │ ├── AMQP$Tx$RollbackOk.class
│ │ │ ├── AMQP$Tx$Select$Builder.class
│ │ │ ├── AMQP$Tx$Select.class
│ │ │ ├── AMQP$Tx$SelectOk$Builder.class
│ │ │ ├── AMQP$Tx$SelectOk.class
│ │ │ ├── AMQP$Tx.class
│ │ │ ├── AMQP.class
│ │ │ ├── Address.class
│ │ │ ├── AlreadyClosedException.class
│ │ │ ├── BasicProperties.class
│ │ │ ├── Channel.class
│ │ │ ├── Command.class
│ │ │ ├── ConfirmListener.class
│ │ │ ├── Connection.class
│ │ │ ├── ConnectionFactory.class
│ │ │ ├── Consumer.class
│ │ │ ├── ConsumerCancelledException.class
│ │ │ ├── ContentHeader.class
│ │ │ ├── DefaultConsumer.class
│ │ │ ├── DefaultSaslConfig.class
│ │ │ ├── Envelope.class
│ │ │ ├── FlowListener.class
│ │ │ ├── GetResponse.class
│ │ │ ├── JDKSaslConfig$JDKSaslMechanism.class
│ │ │ ├── JDKSaslConfig$UsernamePasswordCallbackHandler.class
│ │ │ ├── JDKSaslConfig.class
│ │ │ ├── LongString.class
│ │ │ ├── MalformedFrameException.class
│ │ │ ├── MapRpcServer.class
│ │ │ ├── MessageProperties.class
│ │ │ ├── Method.class
│ │ │ ├── MissedHeartbeatException.class
│ │ │ ├── NullTrustManager.class
│ │ │ ├── PossibleAuthenticationFailureException.class
│ │ │ ├── ProtocolVersionMismatchException.class
│ │ │ ├── QueueingConsumer$Delivery.class
│ │ │ ├── QueueingConsumer.class
│ │ │ ├── ReturnListener.class
│ │ │ ├── RpcClient$1.class
│ │ │ ├── RpcClient.class
│ │ │ ├── RpcServer.class
│ │ │ ├── SaslConfig.class
│ │ │ ├── SaslMechanism.class
│ │ │ ├── ShutdownListener.class
│ │ │ ├── ShutdownNotifier.class
│ │ │ ├── ShutdownSignalException.class
│ │ │ ├── StringRpcServer.class
│ │ │ ├── UnexpectedFrameError.class
│ │ │ ├── UnexpectedMethodError.class
│ │ │ ├── UnknownClassOrMethodId.class
│ │ │ └── impl
│ │ │ ├── AMQBasicProperties.class
│ │ │ ├── AMQChannel$BlockingRpcContinuation.class
│ │ │ ├── AMQChannel$RpcContinuation.class
│ │ │ ├── AMQChannel$SimpleBlockingRpcContinuation.class
│ │ │ ├── AMQChannel.class
│ │ │ ├── AMQCommand.class
│ │ │ ├── AMQConnection$1.class
│ │ │ ├── AMQConnection$MainLoop.class
│ │ │ ├── AMQConnection$SocketCloseWait.class
│ │ │ ├── AMQConnection.class
│ │ │ ├── AMQContentHeader.class
│ │ │ ├── AMQImpl$Access$Request.class
│ │ │ ├── AMQImpl$Access$RequestOk.class
│ │ │ ├── AMQImpl$Access.class
│ │ │ ├── AMQImpl$Basic$Ack.class
│ │ │ ├── AMQImpl$Basic$Cancel.class
│ │ │ ├── AMQImpl$Basic$CancelOk.class
│ │ │ ├── AMQImpl$Basic$Consume.class
│ │ │ ├── AMQImpl$Basic$ConsumeOk.class
│ │ │ ├── AMQImpl$Basic$Deliver.class
│ │ │ ├── AMQImpl$Basic$Get.class
│ │ │ ├── AMQImpl$Basic$GetEmpty.class
│ │ │ ├── AMQImpl$Basic$GetOk.class
│ │ │ ├── AMQImpl$Basic$Nack.class
│ │ │ ├── AMQImpl$Basic$Publish.class
│ │ │ ├── AMQImpl$Basic$Qos.class
│ │ │ ├── AMQImpl$Basic$QosOk.class
│ │ │ ├── AMQImpl$Basic$Recover.class
│ │ │ ├── AMQImpl$Basic$RecoverAsync.class
│ │ │ ├── AMQImpl$Basic$RecoverOk.class
│ │ │ ├── AMQImpl$Basic$Reject.class
│ │ │ ├── AMQImpl$Basic$Return.class
│ │ │ ├── AMQImpl$Basic.class
│ │ │ ├── AMQImpl$Channel$Close.class
│ │ │ ├── AMQImpl$Channel$CloseOk.class
│ │ │ ├── AMQImpl$Channel$Flow.class
│ │ │ ├── AMQImpl$Channel$FlowOk.class
│ │ │ ├── AMQImpl$Channel$Open.class
│ │ │ ├── AMQImpl$Channel$OpenOk.class
│ │ │ ├── AMQImpl$Channel.class
│ │ │ ├── AMQImpl$Confirm$Select.class
│ │ │ ├── AMQImpl$Confirm$SelectOk.class
│ │ │ ├── AMQImpl$Confirm.class
│ │ │ ├── AMQImpl$Connection$Close.class
│ │ │ ├── AMQImpl$Connection$CloseOk.class
│ │ │ ├── AMQImpl$Connection$Open.class
│ │ │ ├── AMQImpl$Connection$OpenOk.class
│ │ │ ├── AMQImpl$Connection$Secure.class
│ │ │ ├── AMQImpl$Connection$SecureOk.class
│ │ │ ├── AMQImpl$Connection$Start.class
│ │ │ ├── AMQImpl$Connection$StartOk.class
│ │ │ ├── AMQImpl$Connection$Tune.class
│ │ │ ├── AMQImpl$Connection$TuneOk.class
│ │ │ ├── AMQImpl$Connection.class
│ │ │ ├── AMQImpl$DefaultMethodVisitor.class
│ │ │ ├── AMQImpl$Exchange$Bind.class
│ │ │ ├── AMQImpl$Exchange$BindOk.class
│ │ │ ├── AMQImpl$Exchange$Declare.class
│ │ │ ├── AMQImpl$Exchange$DeclareOk.class
│ │ │ ├── AMQImpl$Exchange$Delete.class
│ │ │ ├── AMQImpl$Exchange$DeleteOk.class
│ │ │ ├── AMQImpl$Exchange$Unbind.class
│ │ │ ├── AMQImpl$Exchange$UnbindOk.class
│ │ │ ├── AMQImpl$Exchange.class
│ │ │ ├── AMQImpl$MethodVisitor.class
│ │ │ ├── AMQImpl$Queue$Bind.class
│ │ │ ├── AMQImpl$Queue$BindOk.class
│ │ │ ├── AMQImpl$Queue$Declare.class
│ │ │ ├── AMQImpl$Queue$DeclareOk.class
│ │ │ ├── AMQImpl$Queue$Delete.class
│ │ │ ├── AMQImpl$Queue$DeleteOk.class
│ │ │ ├── AMQImpl$Queue$Purge.class
│ │ │ ├── AMQImpl$Queue$PurgeOk.class
│ │ │ ├── AMQImpl$Queue$Unbind.class
│ │ │ ├── AMQImpl$Queue$UnbindOk.class
│ │ │ ├── AMQImpl$Queue.class
│ │ │ ├── AMQImpl$Tx$Commit.class
│ │ │ ├── AMQImpl$Tx$CommitOk.class
│ │ │ ├── AMQImpl$Tx$Rollback.class
│ │ │ ├── AMQImpl$Tx$RollbackOk.class
│ │ │ ├── AMQImpl$Tx$Select.class
│ │ │ ├── AMQImpl$Tx$SelectOk.class
│ │ │ ├── AMQImpl$Tx.class
│ │ │ ├── AMQImpl.class
│ │ │ ├── CRDemoMechanism$CRDemoSaslConfig.class
│ │ │ ├── CRDemoMechanism.class
│ │ │ ├── ChannelManager$1.class
│ │ │ ├── ChannelManager.class
│ │ │ ├── ChannelN$1.class
│ │ │ ├── ChannelN$2.class
│ │ │ ├── ChannelN.class
│ │ │ ├── ClientVersion.class
│ │ │ ├── CommandAssembler$1.class
│ │ │ ├── CommandAssembler$CAState.class
│ │ │ ├── CommandAssembler.class
│ │ │ ├── ConsumerDispatcher$1.class
│ │ │ ├── ConsumerDispatcher$2.class
│ │ │ ├── ConsumerDispatcher$3.class
│ │ │ ├── ConsumerDispatcher$4.class
│ │ │ ├── ConsumerDispatcher$5.class
│ │ │ ├── ConsumerDispatcher.class
│ │ │ ├── ConsumerWorkService$1.class
│ │ │ ├── ConsumerWorkService$WorkPoolRunnable.class
│ │ │ ├── ConsumerWorkService.class
│ │ │ ├── ContentHeaderPropertyReader.class
│ │ │ ├── ContentHeaderPropertyWriter.class
│ │ │ ├── DefaultExceptionHandler.class
│ │ │ ├── ExceptionHandler.class
│ │ │ ├── ExternalMechanism.class
│ │ │ ├── Frame.class
│ │ │ ├── FrameHandler.class
│ │ │ ├── HeartbeatSender$1.class
│ │ │ ├── HeartbeatSender$HeartbeatRunnable.class
│ │ │ ├── HeartbeatSender.class
│ │ │ ├── LongStringHelper$ByteArrayLongString.class
│ │ │ ├── LongStringHelper.class
│ │ │ ├── Method.class
│ │ │ ├── MethodArgumentReader.class
│ │ │ ├── MethodArgumentWriter.class
│ │ │ ├── PlainMechanism.class
│ │ │ ├── SetQueue.class
│ │ │ ├── ShutdownNotifierComponent.class
│ │ │ ├── SocketFrameHandler.class
│ │ │ ├── TruncatedInputStream.class
│ │ │ ├── UnknownChannelException.class
│ │ │ ├── ValueReader.class
│ │ │ ├── ValueWriter.class
│ │ │ ├── Version.class
│ │ │ └── WorkPool.class
│ │ ├── tools
│ │ │ ├── Tracer$AsyncLogger$AsyncLoggerRunnable.class
│ │ │ ├── Tracer$AsyncLogger$LogCmd.class
│ │ │ ├── Tracer$AsyncLogger$Pr.class
│ │ │ ├── Tracer$AsyncLogger.class
│ │ │ ├── Tracer$DirectionHandler.class
│ │ │ ├── Tracer$Logger.class
│ │ │ ├── Tracer$SafeCounter.class
│ │ │ ├── Tracer.class
│ │ │ ├── json
│ │ │ │ ├── JSONReader.class
│ │ │ │ ├── JSONSerializable.class
│ │ │ │ ├── JSONUtil.class
│ │ │ │ └── JSONWriter.class
│ │ │ └── jsonrpc
│ │ │ ├── JsonRpcClient.class
│ │ │ ├── JsonRpcException.class
│ │ │ ├── JsonRpcServer.class
│ │ │ ├── ParameterDescription.class
│ │ │ ├── ProcedureDescription.class
│ │ │ └── ServiceDescription.class
│ │ └── utility
│ │ ├── BlockingCell.class
│ │ ├── BlockingValueOrException.class
│ │ ├── IntAllocator.class
│ │ ├── SensibleClone.class
│ │ ├── SingleShotLinearTimer$TimerThread.class
│ │ ├── SingleShotLinearTimer.class
│ │ ├── Utility$ThrowableCreatedElsewhere.class
│ │ ├── Utility.class
│ │ └── ValueOrException.class
│ ├── doc
│ │ └── api
│ └── gensrc
│ └── com
│ └── rabbitmq
│ └── client
│ ├── AMQP.java
│ └── impl
│ ├── AMQImpl.java
│ └── ClientVersion.java
├── build.properties
├── build.xml
├── bundlor
│ ├── dist
│ │ ├── com.springsource.bundlor-1.0.0.RELEASE.jar
│ │ ├── com.springsource.bundlor.ant-1.0.0.RELEASE.jar
│ │ ├── com.springsource.bundlor.blint-1.0.0.RELEASE.jar
│ │ └── com.springsource.bundlor.commandline-1.0.0.RELEASE.jar
│ └── lib
│ ├── com.springsource.org.apache.commons.cli-1.2.0.jar
│ ├── com.springsource.org.objectweb.asm-3.1.0.jar
│ ├── com.springsource.org.objectweb.asm.commons-3.1.0.jar
│ ├── com.springsource.org.objectweb.asm.tree-3.1.0.jar
│ ├── com.springsource.util.common-2.0.0.RELEASE.jar
│ ├── com.springsource.util.math-2.0.0.RELEASE.jar
│ ├── com.springsource.util.osgi-2.0.0.RELEASE.jar
│ ├── com.springsource.util.parser.manifest-2.0.0.RELEASE.jar
│ └── org.osgi.core-4.1.0.jar
├── bundlorTemplate.mf
├── bundlorTestTemplate.mf
├── codegen
│ ├── LICENSE
│ ├── LICENSE-MPL-RabbitMQ
│ ├── Makefile
│ ├── README.extensions.md
│ ├── amqp-rabbitmq-0.8.json
│ ├── amqp-rabbitmq-0.9.1.json
│ ├── amqp_codegen.py
│ ├── demo_extension.json
│ └── license_info
├── codegen.py
├── config.properties
├── doc
│ └── channels
│ ├── channels.pdf
│ ├── channels.tex
│ ├── whiteboard.JPG
│ ├── worktransition.graffle
│ ├── worktransition.pdf
│ └── zed-cm.sty
├── lib
│ ├── commons-cli-1.1.jar
│ ├── commons-io-1.2.jar
│ └── junit.jar
├── nexus-upload.sh
├── pom.xml
├── scripts
│ ├── runjava.bat
│ ├── runjava.sh
│ ├── runperftest.sh
│ └── stresspersister.sh
├── src
│ └── com
│ └── rabbitmq
│ ├── client
│ │ ├── Address.java
│ │ ├── AlreadyClosedException.java
│ │ ├── BasicProperties.java
│ │ ├── Channel.java
│ │ ├── Command.java
│ │ ├── ConfirmListener.java
│ │ ├── Connection.java
│ │ ├── ConnectionFactory.java
│ │ ├── Consumer.java
│ │ ├── ConsumerCancelledException.java
│ │ ├── ContentHeader.java
│ │ ├── DefaultConsumer.java
│ │ ├── DefaultSaslConfig.java
│ │ ├── Envelope.java
│ │ ├── FlowListener.java
│ │ ├── GetResponse.java
│ │ ├── JDKSaslConfig.java
│ │ ├── LongString.java
│ │ ├── MalformedFrameException.java
│ │ ├── MapRpcServer.java
│ │ ├── MessageProperties.java
│ │ ├── Method.java
│ │ ├── MissedHeartbeatException.java
│ │ ├── NullTrustManager.java
│ │ ├── PossibleAuthenticationFailureException.java
│ │ ├── ProtocolVersionMismatchException.java
│ │ ├── QueueingConsumer.java
│ │ ├── ReturnListener.java
│ │ ├── RpcClient.java
│ │ ├── RpcServer.java
│ │ ├── SaslConfig.java
│ │ ├── SaslMechanism.java
│ │ ├── ShutdownListener.java
│ │ ├── ShutdownNotifier.java
│ │ ├── ShutdownSignalException.java
│ │ ├── StringRpcServer.java
│ │ ├── UnexpectedFrameError.java
│ │ ├── UnexpectedMethodError.java
│ │ ├── UnknownClassOrMethodId.java
│ │ ├── impl
│ │ │ ├── AMQBasicProperties.java
│ │ │ ├── AMQChannel.java
│ │ │ ├── AMQCommand.java
│ │ │ ├── AMQConnection.java
│ │ │ ├── AMQContentHeader.java
│ │ │ ├── CRDemoMechanism.java
│ │ │ ├── ChannelManager.java
│ │ │ ├── ChannelN.java
│ │ │ ├── ClientVersion.java.in
│ │ │ ├── CommandAssembler.java
│ │ │ ├── ConsumerDispatcher.java
│ │ │ ├── ConsumerWorkService.java
│ │ │ ├── ContentHeaderPropertyReader.java
│ │ │ ├── ContentHeaderPropertyWriter.java
│ │ │ ├── DefaultExceptionHandler.java
│ │ │ ├── ExceptionHandler.java
│ │ │ ├── ExternalMechanism.java
│ │ │ ├── Frame.java
│ │ │ ├── FrameHandler.java
│ │ │ ├── HeartbeatSender.java
│ │ │ ├── LongStringHelper.java
│ │ │ ├── Method.java
│ │ │ ├── MethodArgumentReader.java
│ │ │ ├── MethodArgumentWriter.java
│ │ │ ├── PlainMechanism.java
│ │ │ ├── SetQueue.java
│ │ │ ├── ShutdownNotifierComponent.java
│ │ │ ├── SocketFrameHandler.java
│ │ │ ├── TruncatedInputStream.java
│ │ │ ├── UnknownChannelException.java
│ │ │ ├── ValueReader.java
│ │ │ ├── ValueWriter.java
│ │ │ ├── Version.java
│ │ │ ├── WorkPool.java
│ │ │ └── package.html
│ │ └── package.html
│ ├── tools
│ │ ├── Tracer.java
│ │ ├── json
│ │ │ ├── JSONReader.java
│ │ │ ├── JSONSerializable.java
│ │ │ ├── JSONUtil.java
│ │ │ ├── JSONWriter.java
│ │ │ └── package.html
│ │ ├── jsonrpc
│ │ │ ├── JsonRpcClient.java
│ │ │ ├── JsonRpcException.java
│ │ │ ├── JsonRpcServer.java
│ │ │ ├── ParameterDescription.java
│ │ │ ├── ProcedureDescription.java
│ │ │ ├── ServiceDescription.java
│ │ │ └── package.html
│ │ └── package.html
│ └── utility
│ ├── BlockingCell.java
│ ├── BlockingValueOrException.java
│ ├── IntAllocator.java
│ ├── SensibleClone.java
│ ├── SingleShotLinearTimer.java
│ ├── Utility.java
│ ├── ValueOrException.java
│ └── package.html
├── target
│ ├── amqp-client-VERSION.jar
│ ├── classes
│ │ └── com
│ │ └── rabbitmq
│ │ ├── client
│ │ │ ├── AMQP$Access$Request$Builder.class
│ │ │ ├── AMQP$Access$Request.class
│ │ │ ├── AMQP$Access$RequestOk$Builder.class
│ │ │ ├── AMQP$Access$RequestOk.class
│ │ │ ├── AMQP$Access.class
│ │ │ ├── AMQP$Basic$Ack$Builder.class
│ │ │ ├── AMQP$Basic$Ack.class
│ │ │ ├── AMQP$Basic$Cancel$Builder.class
│ │ │ ├── AMQP$Basic$Cancel.class
│ │ │ ├── AMQP$Basic$CancelOk$Builder.class
│ │ │ ├── AMQP$Basic$CancelOk.class
│ │ │ ├── AMQP$Basic$Consume$Builder.class
│ │ │ ├── AMQP$Basic$Consume.class
│ │ │ ├── AMQP$Basic$ConsumeOk$Builder.class
│ │ │ ├── AMQP$Basic$ConsumeOk.class
│ │ │ ├── AMQP$Basic$Deliver$Builder.class
│ │ │ ├── AMQP$Basic$Deliver.class
│ │ │ ├── AMQP$Basic$Get$Builder.class
│ │ │ ├── AMQP$Basic$Get.class
│ │ │ ├── AMQP$Basic$GetEmpty$Builder.class
│ │ │ ├── AMQP$Basic$GetEmpty.class
│ │ │ ├── AMQP$Basic$GetOk$Builder.class
│ │ │ ├── AMQP$Basic$GetOk.class
│ │ │ ├── AMQP$Basic$Nack$Builder.class
│ │ │ ├── AMQP$Basic$Nack.class
│ │ │ ├── AMQP$Basic$Publish$Builder.class
│ │ │ ├── AMQP$Basic$Publish.class
│ │ │ ├── AMQP$Basic$Qos$Builder.class
│ │ │ ├── AMQP$Basic$Qos.class
│ │ │ ├── AMQP$Basic$QosOk$Builder.class
│ │ │ ├── AMQP$Basic$QosOk.class
│ │ │ ├── AMQP$Basic$Recover$Builder.class
│ │ │ ├── AMQP$Basic$Recover.class
│ │ │ ├── AMQP$Basic$RecoverAsync$Builder.class
│ │ │ ├── AMQP$Basic$RecoverAsync.class
│ │ │ ├── AMQP$Basic$RecoverOk$Builder.class
│ │ │ ├── AMQP$Basic$RecoverOk.class
│ │ │ ├── AMQP$Basic$Reject$Builder.class
│ │ │ ├── AMQP$Basic$Reject.class
│ │ │ ├── AMQP$Basic$Return$Builder.class
│ │ │ ├── AMQP$Basic$Return.class
│ │ │ ├── AMQP$Basic.class
│ │ │ ├── AMQP$BasicProperties$Builder.class
│ │ │ ├── AMQP$BasicProperties.class
│ │ │ ├── AMQP$Channel$Close$Builder.class
│ │ │ ├── AMQP$Channel$Close.class
│ │ │ ├── AMQP$Channel$CloseOk$Builder.class
│ │ │ ├── AMQP$Channel$CloseOk.class
│ │ │ ├── AMQP$Channel$Flow$Builder.class
│ │ │ ├── AMQP$Channel$Flow.class
│ │ │ ├── AMQP$Channel$FlowOk$Builder.class
│ │ │ ├── AMQP$Channel$FlowOk.class
│ │ │ ├── AMQP$Channel$Open$Builder.class
│ │ │ ├── AMQP$Channel$Open.class
│ │ │ ├── AMQP$Channel$OpenOk$Builder.class
│ │ │ ├── AMQP$Channel$OpenOk.class
│ │ │ ├── AMQP$Channel.class
│ │ │ ├── AMQP$Confirm$Select$Builder.class
│ │ │ ├── AMQP$Confirm$Select.class
│ │ │ ├── AMQP$Confirm$SelectOk$Builder.class
│ │ │ ├── AMQP$Confirm$SelectOk.class
│ │ │ ├── AMQP$Confirm.class
│ │ │ ├── AMQP$Connection$Close$Builder.class
│ │ │ ├── AMQP$Connection$Close.class
│ │ │ ├── AMQP$Connection$CloseOk$Builder.class
│ │ │ ├── AMQP$Connection$CloseOk.class
│ │ │ ├── AMQP$Connection$Open$Builder.class
│ │ │ ├── AMQP$Connection$Open.class
│ │ │ ├── AMQP$Connection$OpenOk$Builder.class
│ │ │ ├── AMQP$Connection$OpenOk.class
│ │ │ ├── AMQP$Connection$Secure$Builder.class
│ │ │ ├── AMQP$Connection$Secure.class
│ │ │ ├── AMQP$Connection$SecureOk$Builder.class
│ │ │ ├── AMQP$Connection$SecureOk.class
│ │ │ ├── AMQP$Connection$Start$Builder.class
│ │ │ ├── AMQP$Connection$Start.class
│ │ │ ├── AMQP$Connection$StartOk$Builder.class
│ │ │ ├── AMQP$Connection$StartOk.class
│ │ │ ├── AMQP$Connection$Tune$Builder.class
│ │ │ ├── AMQP$Connection$Tune.class
│ │ │ ├── AMQP$Connection$TuneOk$Builder.class
│ │ │ ├── AMQP$Connection$TuneOk.class
│ │ │ ├── AMQP$Connection.class
│ │ │ ├── AMQP$Exchange$Bind$Builder.class
│ │ │ ├── AMQP$Exchange$Bind.class
│ │ │ ├── AMQP$Exchange$BindOk$Builder.class
│ │ │ ├── AMQP$Exchange$BindOk.class
│ │ │ ├── AMQP$Exchange$Declare$Builder.class
│ │ │ ├── AMQP$Exchange$Declare.class
│ │ │ ├── AMQP$Exchange$DeclareOk$Builder.class
│ │ │ ├── AMQP$Exchange$DeclareOk.class
│ │ │ ├── AMQP$Exchange$Delete$Builder.class
│ │ │ ├── AMQP$Exchange$Delete.class
│ │ │ ├── AMQP$Exchange$DeleteOk$Builder.class
│ │ │ ├── AMQP$Exchange$DeleteOk.class
│ │ │ ├── AMQP$Exchange$Unbind$Builder.class
│ │ │ ├── AMQP$Exchange$Unbind.class
│ │ │ ├── AMQP$Exchange$UnbindOk$Builder.class
│ │ │ ├── AMQP$Exchange$UnbindOk.class
│ │ │ ├── AMQP$Exchange.class
│ │ │ ├── AMQP$PROTOCOL.class
│ │ │ ├── AMQP$Queue$Bind$Builder.class
│ │ │ ├── AMQP$Queue$Bind.class
│ │ │ ├── AMQP$Queue$BindOk$Builder.class
│ │ │ ├── AMQP$Queue$BindOk.class
│ │ │ ├── AMQP$Queue$Declare$Builder.class
│ │ │ ├── AMQP$Queue$Declare.class
│ │ │ ├── AMQP$Queue$DeclareOk$Builder.class
│ │ │ ├── AMQP$Queue$DeclareOk.class
│ │ │ ├── AMQP$Queue$Delete$Builder.class
│ │ │ ├── AMQP$Queue$Delete.class
│ │ │ ├── AMQP$Queue$DeleteOk$Builder.class
│ │ │ ├── AMQP$Queue$DeleteOk.class
│ │ │ ├── AMQP$Queue$Purge$Builder.class
│ │ │ ├── AMQP$Queue$Purge.class
│ │ │ ├── AMQP$Queue$PurgeOk$Builder.class
│ │ │ ├── AMQP$Queue$PurgeOk.class
│ │ │ ├── AMQP$Queue$Unbind$Builder.class
│ │ │ ├── AMQP$Queue$Unbind.class
│ │ │ ├── AMQP$Queue$UnbindOk$Builder.class
│ │ │ ├── AMQP$Queue$UnbindOk.class
│ │ │ ├── AMQP$Queue.class
│ │ │ ├── AMQP$Tx$Commit$Builder.class
│ │ │ ├── AMQP$Tx$Commit.class
│ │ │ ├── AMQP$Tx$CommitOk$Builder.class
│ │ │ ├── AMQP$Tx$CommitOk.class
│ │ │ ├── AMQP$Tx$Rollback$Builder.class
│ │ │ ├── AMQP$Tx$Rollback.class
│ │ │ ├── AMQP$Tx$RollbackOk$Builder.class
│ │ │ ├── AMQP$Tx$RollbackOk.class
│ │ │ ├── AMQP$Tx$Select$Builder.class
│ │ │ ├── AMQP$Tx$Select.class
│ │ │ ├── AMQP$Tx$SelectOk$Builder.class
│ │ │ ├── AMQP$Tx$SelectOk.class
│ │ │ ├── AMQP$Tx.class
│ │ │ ├── AMQP.class
│ │ │ ├── Address.class
│ │ │ ├── AlreadyClosedException.class
│ │ │ ├── BasicProperties.class
│ │ │ ├── Channel.class
│ │ │ ├── Command.class
│ │ │ ├── ConfirmListener.class
│ │ │ ├── Connection.class
│ │ │ ├── ConnectionFactory.class
│ │ │ ├── Consumer.class
│ │ │ ├── ConsumerCancelledException.class
│ │ │ ├── ContentHeader.class
│ │ │ ├── DefaultConsumer.class
│ │ │ ├── DefaultSaslConfig.class
│ │ │ ├── Envelope.class
│ │ │ ├── FlowListener.class
│ │ │ ├── GetResponse.class
│ │ │ ├── JDKSaslConfig$JDKSaslMechanism.class
│ │ │ ├── JDKSaslConfig$UsernamePasswordCallbackHandler.class
│ │ │ ├── JDKSaslConfig.class
│ │ │ ├── LongString.class
│ │ │ ├── MalformedFrameException.class
│ │ │ ├── MapRpcServer.class
│ │ │ ├── MessageProperties.class
│ │ │ ├── Method.class
│ │ │ ├── MissedHeartbeatException.class
│ │ │ ├── NullTrustManager.class
│ │ │ ├── PossibleAuthenticationFailureException.class
│ │ │ ├── ProtocolVersionMismatchException.class
│ │ │ ├── QueueingConsumer$Delivery.class
│ │ │ ├── QueueingConsumer.class
│ │ │ ├── ReturnListener.class
│ │ │ ├── RpcClient$1.class
│ │ │ ├── RpcClient.class
│ │ │ ├── RpcServer.class
│ │ │ ├── SaslConfig.class
│ │ │ ├── SaslMechanism.class
│ │ │ ├── ShutdownListener.class
│ │ │ ├── ShutdownNotifier.class
│ │ │ ├── ShutdownSignalException.class
│ │ │ ├── StringRpcServer.class
│ │ │ ├── UnexpectedFrameError.class
│ │ │ ├── UnexpectedMethodError.class
│ │ │ ├── UnknownClassOrMethodId.class
│ │ │ ├── impl
│ │ │ │ ├── AMQBasicProperties.class
│ │ │ │ ├── AMQChannel$BlockingRpcContinuation.class
│ │ │ │ ├── AMQChannel$RpcContinuation.class
│ │ │ │ ├── AMQChannel$SimpleBlockingRpcContinuation.class
│ │ │ │ ├── AMQChannel.class
│ │ │ │ ├── AMQCommand.class
│ │ │ │ ├── AMQConnection$1.class
│ │ │ │ ├── AMQConnection$MainLoop.class
│ │ │ │ ├── AMQConnection$SocketCloseWait.class
│ │ │ │ ├── AMQConnection.class
│ │ │ │ ├── AMQContentHeader.class
│ │ │ │ ├── AMQImpl$Access$Request.class
│ │ │ │ ├── AMQImpl$Access$RequestOk.class
│ │ │ │ ├── AMQImpl$Access.class
│ │ │ │ ├── AMQImpl$Basic$Ack.class
│ │ │ │ ├── AMQImpl$Basic$Cancel.class
│ │ │ │ ├── AMQImpl$Basic$CancelOk.class
│ │ │ │ ├── AMQImpl$Basic$Consume.class
│ │ │ │ ├── AMQImpl$Basic$ConsumeOk.class
│ │ │ │ ├── AMQImpl$Basic$Deliver.class
│ │ │ │ ├── AMQImpl$Basic$Get.class
│ │ │ │ ├── AMQImpl$Basic$GetEmpty.class
│ │ │ │ ├── AMQImpl$Basic$GetOk.class
│ │ │ │ ├── AMQImpl$Basic$Nack.class
│ │ │ │ ├── AMQImpl$Basic$Publish.class
│ │ │ │ ├── AMQImpl$Basic$Qos.class
│ │ │ │ ├── AMQImpl$Basic$QosOk.class
│ │ │ │ ├── AMQImpl$Basic$Recover.class
│ │ │ │ ├── AMQImpl$Basic$RecoverAsync.class
│ │ │ │ ├── AMQImpl$Basic$RecoverOk.class
│ │ │ │ ├── AMQImpl$Basic$Reject.class
│ │ │ │ ├── AMQImpl$Basic$Return.class
│ │ │ │ ├── AMQImpl$Basic.class
│ │ │ │ ├── AMQImpl$Channel$Close.class
│ │ │ │ ├── AMQImpl$Channel$CloseOk.class
│ │ │ │ ├── AMQImpl$Channel$Flow.class
│ │ │ │ ├── AMQImpl$Channel$FlowOk.class
│ │ │ │ ├── AMQImpl$Channel$Open.class
│ │ │ │ ├── AMQImpl$Channel$OpenOk.class
│ │ │ │ ├── AMQImpl$Channel.class
│ │ │ │ ├── AMQImpl$Confirm$Select.class
│ │ │ │ ├── AMQImpl$Confirm$SelectOk.class
│ │ │ │ ├── AMQImpl$Confirm.class
│ │ │ │ ├── AMQImpl$Connection$Close.class
│ │ │ │ ├── AMQImpl$Connection$CloseOk.class
│ │ │ │ ├── AMQImpl$Connection$Open.class
│ │ │ │ ├── AMQImpl$Connection$OpenOk.class
│ │ │ │ ├── AMQImpl$Connection$Secure.class
│ │ │ │ ├── AMQImpl$Connection$SecureOk.class
│ │ │ │ ├── AMQImpl$Connection$Start.class
│ │ │ │ ├── AMQImpl$Connection$StartOk.class
│ │ │ │ ├── AMQImpl$Connection$Tune.class
│ │ │ │ ├── AMQImpl$Connection$TuneOk.class
│ │ │ │ ├── AMQImpl$Connection.class
│ │ │ │ ├── AMQImpl$DefaultMethodVisitor.class
│ │ │ │ ├── AMQImpl$Exchange$Bind.class
│ │ │ │ ├── AMQImpl$Exchange$BindOk.class
│ │ │ │ ├── AMQImpl$Exchange$Declare.class
│ │ │ │ ├── AMQImpl$Exchange$DeclareOk.class
│ │ │ │ ├── AMQImpl$Exchange$Delete.class
│ │ │ │ ├── AMQImpl$Exchange$DeleteOk.class
│ │ │ │ ├── AMQImpl$Exchange$Unbind.class
│ │ │ │ ├── AMQImpl$Exchange$UnbindOk.class
│ │ │ │ ├── AMQImpl$Exchange.class
│ │ │ │ ├── AMQImpl$MethodVisitor.class
│ │ │ │ ├── AMQImpl$Queue$Bind.class
│ │ │ │ ├── AMQImpl$Queue$BindOk.class
│ │ │ │ ├── AMQImpl$Queue$Declare.class
│ │ │ │ ├── AMQImpl$Queue$DeclareOk.class
│ │ │ │ ├── AMQImpl$Queue$Delete.class
│ │ │ │ ├── AMQImpl$Queue$DeleteOk.class
│ │ │ │ ├── AMQImpl$Queue$Purge.class
│ │ │ │ ├── AMQImpl$Queue$PurgeOk.class
│ │ │ │ ├── AMQImpl$Queue$Unbind.class
│ │ │ │ ├── AMQImpl$Queue$UnbindOk.class
│ │ │ │ ├── AMQImpl$Queue.class
│ │ │ │ ├── AMQImpl$Tx$Commit.class
│ │ │ │ ├── AMQImpl$Tx$CommitOk.class
│ │ │ │ ├── AMQImpl$Tx$Rollback.class
│ │ │ │ ├── AMQImpl$Tx$RollbackOk.class
│ │ │ │ ├── AMQImpl$Tx$Select.class
│ │ │ │ ├── AMQImpl$Tx$SelectOk.class
│ │ │ │ ├── AMQImpl$Tx.class
│ │ │ │ ├── AMQImpl.class
│ │ │ │ ├── CRDemoMechanism$CRDemoSaslConfig.class
│ │ │ │ ├── CRDemoMechanism.class
│ │ │ │ ├── ChannelManager$1.class
│ │ │ │ ├── ChannelManager.class
│ │ │ │ ├── ChannelN$1.class
│ │ │ │ ├── ChannelN$2.class
│ │ │ │ ├── ChannelN.class
│ │ │ │ ├── ClientVersion.class
│ │ │ │ ├── ClientVersion.java.in
│ │ │ │ ├── CommandAssembler$CAState.class
│ │ │ │ ├── CommandAssembler.class
│ │ │ │ ├── ConsumerDispatcher$1.class
│ │ │ │ ├── ConsumerDispatcher$2.class
│ │ │ │ ├── ConsumerDispatcher$3.class
│ │ │ │ ├── ConsumerDispatcher$4.class
│ │ │ │ ├── ConsumerDispatcher$5.class
│ │ │ │ ├── ConsumerDispatcher.class
│ │ │ │ ├── ConsumerWorkService$WorkPoolRunnable.class
│ │ │ │ ├── ConsumerWorkService.class
│ │ │ │ ├── ContentHeaderPropertyReader.class
│ │ │ │ ├── ContentHeaderPropertyWriter.class
│ │ │ │ ├── DefaultExceptionHandler.class
│ │ │ │ ├── ExceptionHandler.class
│ │ │ │ ├── ExternalMechanism.class
│ │ │ │ ├── Frame.class
│ │ │ │ ├── FrameHandler.class
│ │ │ │ ├── HeartbeatSender$HeartbeatRunnable.class
│ │ │ │ ├── HeartbeatSender.class
│ │ │ │ ├── LongStringHelper$ByteArrayLongString.class
│ │ │ │ ├── LongStringHelper.class
│ │ │ │ ├── Method.class
│ │ │ │ ├── MethodArgumentReader.class
│ │ │ │ ├── MethodArgumentWriter.class
│ │ │ │ ├── PlainMechanism.class
│ │ │ │ ├── SetQueue.class
│ │ │ │ ├── ShutdownNotifierComponent.class
│ │ │ │ ├── SocketFrameHandler.class
│ │ │ │ ├── TruncatedInputStream.class
│ │ │ │ ├── UnknownChannelException.class
│ │ │ │ ├── ValueReader.class
│ │ │ │ ├── ValueWriter.class
│ │ │ │ ├── Version.class
│ │ │ │ ├── WorkPool.class
│ │ │ │ └── package.html
│ │ │ ├── package.html
│ │ │ └── test
│ │ │ ├── AMQBuilderApiTest.class
│ │ │ ├── AMQConnectionTest$MockFrameHandler.class
│ │ │ ├── AMQConnectionTest$MyExceptionHandler.class
│ │ │ ├── AMQConnectionTest.class
│ │ │ ├── AmqpUriTest.class
│ │ │ ├── BlockingCellTest$1.class
│ │ │ ├── BlockingCellTest$2.class
│ │ │ ├── BlockingCellTest$3.class
│ │ │ ├── BlockingCellTest$4.class
│ │ │ ├── BlockingCellTest$5.class
│ │ │ ├── BlockingCellTest.class
│ │ │ ├── BrokenFramesTest$MyFrameHandler.class
│ │ │ ├── BrokenFramesTest.class
│ │ │ ├── BrokerTestCase.class
│ │ │ ├── Bug20004Test$1.class
│ │ │ ├── Bug20004Test.class
│ │ │ ├── ChannelNumberAllocationTests$1.class
│ │ │ ├── ChannelNumberAllocationTests.class
│ │ │ ├── ClientTests.class
│ │ │ ├── ClonePropertiesTest.class
│ │ │ ├── CloseInMainLoop$1.class
│ │ │ ├── CloseInMainLoop$SpecialConnection$1.class
│ │ │ ├── CloseInMainLoop$SpecialConnection.class
│ │ │ ├── CloseInMainLoop.class
│ │ │ ├── ConfirmBase$1.class
│ │ │ ├── ConfirmBase.class
│ │ │ ├── MultiThreadedChannel$1.class
│ │ │ ├── MultiThreadedChannel$2.class
│ │ │ ├── MultiThreadedChannel.class
│ │ │ ├── QueueingConsumerShutdownTests$1.class
│ │ │ ├── QueueingConsumerShutdownTests.class
│ │ │ ├── TableTest.class
│ │ │ ├── TruncatedInputStreamTest.class
│ │ │ ├── ValueOrExceptionTest$InsufficientMagicException.class
│ │ │ ├── ValueOrExceptionTest.class
│ │ │ ├── functional
│ │ │ │ ├── AbstractRejectTest.class
│ │ │ │ ├── AlternateExchange$1.class
│ │ │ │ ├── AlternateExchange.class
│ │ │ │ ├── BindingLifecycle.class
│ │ │ │ ├── BindingLifecycleBase$Binding.class
│ │ │ │ ├── BindingLifecycleBase.class
│ │ │ │ ├── CcRoutes.class
│ │ │ │ ├── ClusteredTestBase.class
│ │ │ │ ├── Confirm$1.class
│ │ │ │ ├── Confirm.class
│ │ │ │ ├── ConnectionOpen.class
│ │ │ │ ├── ConsumerCancelNotificiation$1.class
│ │ │ │ ├── ConsumerCancelNotificiation$2.class
│ │ │ │ ├── ConsumerCancelNotificiation.class
│ │ │ │ ├── DefaultExchange.class
│ │ │ │ ├── DoubleDeletion.class
│ │ │ │ ├── DurableOnTransient.class
│ │ │ │ ├── ExchangeDeclare.class
│ │ │ │ ├── ExchangeDeleteIfUnused.class
│ │ │ │ ├── ExchangeEquivalenceBase.class
│ │ │ │ ├── ExchangeExchangeBindings.class
│ │ │ │ ├── ExchangeExchangeBindingsAutoDelete.class
│ │ │ │ ├── FrameMax$MyConnectionFactory.class
│ │ │ │ ├── FrameMax$MyFrameHandler.class
│ │ │ │ ├── FrameMax.class
│ │ │ │ ├── FunctionalTests.class
│ │ │ │ ├── Heartbeat.class
│ │ │ │ ├── InternalExchange.class
│ │ │ │ ├── InvalidAcks.class
│ │ │ │ ├── InvalidAcksBase.class
│ │ │ │ ├── InvalidAcksTx.class
│ │ │ │ ├── Nack.class
│ │ │ │ ├── NoRequeueOnCancel.class
│ │ │ │ ├── PerQueueTTL.class
│ │ │ │ ├── QosTests$1.class
│ │ │ │ ├── QosTests.class
│ │ │ │ ├── QueueExclusivity.class
│ │ │ │ ├── QueueLease.class
│ │ │ │ ├── QueueLifecycle.class
│ │ │ │ ├── Recover$1.class
│ │ │ │ ├── Recover$2.class
│ │ │ │ ├── Recover$3.class
│ │ │ │ ├── Recover$RecoverCallback.class
│ │ │ │ ├── Recover.class
│ │ │ │ ├── Reject.class
│ │ │ │ ├── RequeueOnChannelClose.class
│ │ │ │ ├── RequeueOnClose.class
│ │ │ │ ├── RequeueOnConnectionClose.class
│ │ │ │ ├── Routing.class
│ │ │ │ ├── SaslMechanisms$Config.class
│ │ │ │ ├── SaslMechanisms$Mechanism.class
│ │ │ │ ├── SaslMechanisms.class
│ │ │ │ ├── Tables.class
│ │ │ │ ├── Transactions.class
│ │ │ │ ├── UnbindAutoDeleteExchange.class
│ │ │ │ ├── UnexpectedFrames$1.class
│ │ │ │ ├── UnexpectedFrames$2.class
│ │ │ │ ├── UnexpectedFrames$3.class
│ │ │ │ ├── UnexpectedFrames$4.class
│ │ │ │ ├── UnexpectedFrames$ConfusedConnectionFactory.class
│ │ │ │ ├── UnexpectedFrames$ConfusedFrameHandler$1.class
│ │ │ │ ├── UnexpectedFrames$ConfusedFrameHandler.class
│ │ │ │ ├── UnexpectedFrames$Confuser.class
│ │ │ │ ├── UnexpectedFrames.class
│ │ │ │ └── UserIDHeader.class
│ │ │ ├── impl
│ │ │ │ └── WorkPoolTests.class
│ │ │ ├── performance
│ │ │ │ ├── CLIHelper.class
│ │ │ │ ├── QosScaling$Parameters.class
│ │ │ │ ├── QosScaling.class
│ │ │ │ ├── ScalabilityTest$1.class
│ │ │ │ ├── ScalabilityTest$2.class
│ │ │ │ ├── ScalabilityTest$CreationMeasurements.class
│ │ │ │ ├── ScalabilityTest$DeletionMeasurements.class
│ │ │ │ ├── ScalabilityTest$Measurements.class
│ │ │ │ ├── ScalabilityTest$Parameters.class
│ │ │ │ ├── ScalabilityTest$Results.class
│ │ │ │ └── ScalabilityTest.class
│ │ │ ├── server
│ │ │ │ ├── AlternateExchangeEquivalence.class
│ │ │ │ ├── Bug19219Test$1.class
│ │ │ │ ├── Bug19219Test.class
│ │ │ │ ├── DurableBindingLifecycle.class
│ │ │ │ ├── EffectVisibilityCrossNodeTest.class
│ │ │ │ ├── ExclusiveQueueDurability.class
│ │ │ │ ├── Firehose.class
│ │ │ │ ├── MemoryAlarms.class
│ │ │ │ ├── MessageRecovery.class
│ │ │ │ ├── Permissions$1.class
│ │ │ │ ├── Permissions$10.class
│ │ │ │ ├── Permissions$11.class
│ │ │ │ ├── Permissions$12.class
│ │ │ │ ├── Permissions$13.class
│ │ │ │ ├── Permissions$14.class
│ │ │ │ ├── Permissions$15.class
│ │ │ │ ├── Permissions$16.class
│ │ │ │ ├── Permissions$17.class
│ │ │ │ ├── Permissions$18.class
│ │ │ │ ├── Permissions$19.class
│ │ │ │ ├── Permissions$2.class
│ │ │ │ ├── Permissions$20.class
│ │ │ │ ├── Permissions$21.class
│ │ │ │ ├── Permissions$22.class
│ │ │ │ ├── Permissions$23.class
│ │ │ │ ├── Permissions$24.class
│ │ │ │ ├── Permissions$25.class
│ │ │ │ ├── Permissions$3.class
│ │ │ │ ├── Permissions$4.class
│ │ │ │ ├── Permissions$5.class
│ │ │ │ ├── Permissions$6.class
│ │ │ │ ├── Permissions$7.class
│ │ │ │ ├── Permissions$8.class
│ │ │ │ ├── Permissions$9.class
│ │ │ │ ├── Permissions$WithName.class
│ │ │ │ ├── Permissions.class
│ │ │ │ └── ServerTests.class
│ │ │ └── ssl
│ │ │ ├── BadVerifiedConnection.class
│ │ │ ├── SSLTests.class
│ │ │ ├── UnverifiedConnection.class
│ │ │ └── VerifiedConnection.class
│ │ ├── examples
│ │ │ ├── BufferPerformanceMetrics$1.class
│ │ │ ├── BufferPerformanceMetrics.class
│ │ │ ├── ChannelCreationPerformance$1.class
│ │ │ ├── ChannelCreationPerformance$2.class
│ │ │ ├── ChannelCreationPerformance$3.class
│ │ │ ├── ChannelCreationPerformance$4.class
│ │ │ ├── ChannelCreationPerformance$5.class
│ │ │ ├── ChannelCreationPerformance$PerformanceTest.class
│ │ │ ├── ChannelCreationPerformance.class
│ │ │ ├── ConfirmDontLoseMessages$Consumer.class
│ │ │ ├── ConfirmDontLoseMessages$Publisher.class
│ │ │ ├── ConfirmDontLoseMessages.class
│ │ │ ├── ConsumerMain$1.class
│ │ │ ├── ConsumerMain$LatencyExperimentConsumer.class
│ │ │ ├── ConsumerMain.class
│ │ │ ├── FileConsumer.class
│ │ │ ├── FileProducer.class
│ │ │ ├── HelloClient.class
│ │ │ ├── HelloJsonClient.class
│ │ │ ├── HelloJsonServer$1.class
│ │ │ ├── HelloJsonServer.class
│ │ │ ├── HelloJsonService.class
│ │ │ ├── HelloServer$1.class
│ │ │ ├── HelloServer.class
│ │ │ ├── LogTail.class
│ │ │ ├── ManyConnections$1.class
│ │ │ ├── ManyConnections.class
│ │ │ ├── MulticastMain$Consumer.class
│ │ │ ├── MulticastMain$Producer.class
│ │ │ ├── MulticastMain$Stats.class
│ │ │ ├── MulticastMain.class
│ │ │ ├── PerQueueTTLGetter.class
│ │ │ ├── PerQueueTTLPublisher.class
│ │ │ ├── ProducerMain$1.class
│ │ │ ├── ProducerMain.class
│ │ │ ├── SendString.class
│ │ │ ├── SimpleConsumer.class
│ │ │ ├── SimpleProducer.class
│ │ │ ├── SimpleTopicConsumer.class
│ │ │ ├── SimpleTopicProducer.class
│ │ │ ├── SpammyTopicProducer.class
│ │ │ ├── StressPersister.class
│ │ │ ├── TestMain$1.class
│ │ │ ├── TestMain$2.class
│ │ │ ├── TestMain$3.class
│ │ │ ├── TestMain$4.class
│ │ │ ├── TestMain$5.class
│ │ │ ├── TestMain$6.class
│ │ │ ├── TestMain$BatchedTracingConsumer.class
│ │ │ ├── TestMain$TestConnectionFactory$1.class
│ │ │ ├── TestMain$TestConnectionFactory.class
│ │ │ ├── TestMain$TracingConsumer.class
│ │ │ ├── TestMain$UnexpectedSuccessException.class
│ │ │ ├── TestMain.class
│ │ │ ├── TracerConcurrencyTest$1.class
│ │ │ ├── TracerConcurrencyTest$2.class
│ │ │ └── TracerConcurrencyTest.class
│ │ ├── tools
│ │ │ ├── Host.class
│ │ │ ├── Tracer$AsyncLogger$AsyncLoggerRunnable.class
│ │ │ ├── Tracer$AsyncLogger$LogCmd.class
│ │ │ ├── Tracer$AsyncLogger$Pr.class
│ │ │ ├── Tracer$AsyncLogger.class
│ │ │ ├── Tracer$DirectionHandler.class
│ │ │ ├── Tracer$Logger.class
│ │ │ ├── Tracer$SafeCounter.class
│ │ │ ├── Tracer.class
│ │ │ ├── json
│ │ │ │ ├── JSONReader.class
│ │ │ │ ├── JSONSerializable.class
│ │ │ │ ├── JSONUtil.class
│ │ │ │ ├── JSONWriter.class
│ │ │ │ └── package.html
│ │ │ ├── jsonrpc
│ │ │ │ ├── JsonRpcClient.class
│ │ │ │ ├── JsonRpcException.class
│ │ │ │ ├── JsonRpcServer.class
│ │ │ │ ├── ParameterDescription.class
│ │ │ │ ├── ProcedureDescription.class
│ │ │ │ ├── ServiceDescription.class
│ │ │ │ └── package.html
│ │ │ └── package.html
│ │ └── utility
│ │ ├── BlockingCell.class
│ │ ├── BlockingValueOrException.class
│ │ ├── IntAllocator.class
│ │ ├── IntAllocatorTests.class
│ │ ├── SensibleClone.class
│ │ ├── SingleShotLinearTimer$TimerThread.class
│ │ ├── SingleShotLinearTimer.class
│ │ ├── Utility$ThrowableCreatedElsewhere.class
│ │ ├── Utility.class
│ │ ├── ValueOrException.class
│ │ └── package.html
│ ├── maven-archiver
│ │ └── pom.properties
│ └── surefire
└── test
└── src
└── com
└── rabbitmq
├── client
│ └── test
│ ├── AMQBuilderApiTest.java
│ ├── AMQConnectionTest.java
│ ├── AmqpUriTest.java
│ ├── BlockingCellTest.java
│ ├── BrokenFramesTest.java
│ ├── BrokerTestCase.java
│ ├── Bug20004Test.java
│ ├── ChannelNumberAllocationTests.java
│ ├── ClientTests.java
│ ├── ClonePropertiesTest.java
│ ├── CloseInMainLoop.java
│ ├── ConfirmBase.java
│ ├── MultiThreadedChannel.java
│ ├── QueueingConsumerShutdownTests.java
│ ├── TableTest.java
│ ├── TruncatedInputStreamTest.java
│ ├── ValueOrExceptionTest.java
│ ├── functional
│ │ ├── AbstractRejectTest.java
│ │ ├── AlternateExchange.java
│ │ ├── BindingLifecycle.java
│ │ ├── BindingLifecycleBase.java
│ │ ├── CcRoutes.java
│ │ ├── ClusteredTestBase.java
│ │ ├── Confirm.java
│ │ ├── ConnectionOpen.java
│ │ ├── ConsumerCancelNotificiation.java
│ │ ├── DefaultExchange.java
│ │ ├── DoubleDeletion.java
│ │ ├── DurableOnTransient.java
│ │ ├── ExchangeDeclare.java
│ │ ├── ExchangeDeleteIfUnused.java
│ │ ├── ExchangeEquivalenceBase.java
│ │ ├── ExchangeExchangeBindings.java
│ │ ├── ExchangeExchangeBindingsAutoDelete.java
│ │ ├── FrameMax.java
│ │ ├── FunctionalTests.java
│ │ ├── Heartbeat.java
│ │ ├── InternalExchange.java
│ │ ├── InvalidAcks.java
│ │ ├── InvalidAcksBase.java
│ │ ├── InvalidAcksTx.java
│ │ ├── Nack.java
│ │ ├── NoRequeueOnCancel.java
│ │ ├── PerQueueTTL.java
│ │ ├── QosTests.java
│ │ ├── QueueExclusivity.java
│ │ ├── QueueLease.java
│ │ ├── QueueLifecycle.java
│ │ ├── Recover.java
│ │ ├── Reject.java
│ │ ├── RequeueOnChannelClose.java
│ │ ├── RequeueOnClose.java
│ │ ├── RequeueOnConnectionClose.java
│ │ ├── Routing.java
│ │ ├── SaslMechanisms.java
│ │ ├── Tables.java
│ │ ├── Transactions.java
│ │ ├── UnbindAutoDeleteExchange.java
│ │ ├── UnexpectedFrames.java
│ │ └── UserIDHeader.java
│ ├── impl
│ │ └── WorkPoolTests.java
│ ├── performance
│ │ ├── CLIHelper.java
│ │ ├── QosScaling.java
│ │ └── ScalabilityTest.java
│ ├── server
│ │ ├── AlternateExchangeEquivalence.java
│ │ ├── Bug19219Test.java
│ │ ├── DurableBindingLifecycle.java
│ │ ├── EffectVisibilityCrossNodeTest.java
│ │ ├── ExclusiveQueueDurability.java
│ │ ├── Firehose.java
│ │ ├── MemoryAlarms.java
│ │ ├── MessageRecovery.java
│ │ ├── Permissions.java
│ │ └── ServerTests.java
│ └── ssl
│ ├── BadVerifiedConnection.java
│ ├── SSLTests.java
│ ├── UnverifiedConnection.java
│ └── VerifiedConnection.java
├── examples
│ ├── BufferPerformanceMetrics.java
│ ├── ChannelCreationPerformance.java
│ ├── ConfirmDontLoseMessages.java
│ ├── ConsumerMain.java
│ ├── FileConsumer.java
│ ├── FileProducer.java
│ ├── HelloClient.java
│ ├── HelloJsonClient.java
│ ├── HelloJsonServer.java
│ ├── HelloJsonService.java
│ ├── HelloServer.java
│ ├── LogTail.java
│ ├── ManyConnections.java
│ ├── MulticastMain.java
│ ├── PerQueueTTLGetter.java
│ ├── PerQueueTTLPublisher.java
│ ├── ProducerMain.java
│ ├── SendString.java
│ ├── SimpleConsumer.java
│ ├── SimpleProducer.java
│ ├── SimpleTopicConsumer.java
│ ├── SimpleTopicProducer.java
│ ├── SpammyTopicProducer.java
│ ├── StressPersister.java
│ ├── TestMain.java
│ └── TracerConcurrencyTest.java
├── tools
│ └── Host.java
└── utility
└── IntAllocatorTests.java
68 directories, 1146 files
相关软件
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论