| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829106 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
topic publication easier, added MultiMessageDispatcher class to allow parameterised sending of messages to a queue or a topic
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829102 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
as client examples.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@805418 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Fixed the verify files to use the correct paths for log4j file, python and c++ examples.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757641 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756072 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756071 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
!!! HACK ALERT !!!
These files have long contained a default path used in one particular vendor's installation. We need to fix this! Today's fix makes the default correct for at least that one vendor, but we need to find a better way to do this.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@756032 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
before returning null. Also modified AMQQueueBrowser to use receiveNoWait() when browsing queues using 0-10. These changes uncovered numerous second order bugs, mostly in failover. These are also fixed. This fixes QPID-1642 and QPID-1643.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747963 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@741151 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@734994 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@726943 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@724948 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
to ensure that it is zero before exit.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720183 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@720181 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@714267 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
added a boolean to the connect method to indicate whether an SSL connection should be created.
currently there seems to be two issues.
1. The shutdownInput method used in IoReceiver is not supported by the SSLSocket implementation.
2. I haven't able to get client side authentication working.
For item 1 we may need to use nio classes to get around the issue.
For item 2 I am yet to figure out the correct config options to get client side auth working.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707453 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
in a disconnected state as well as to provide a central point from which to track session state
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703208 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@688094 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@687665 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- made AMQShortString cache the toString() value
- added static initializer to IoTransport to disable use of pooled
byte buffers
- modified IoSender to permit buffering
- removed OutputHandler and eliminated intermediate Frame generation
between Disassembler and Sender<ByteBuffer> (IoSender)
- made Disassembler take advantage of IoSender's buffering
- removed Header and Data as distinct protocol events, added Header
and Body members to MessageTransfer
- modified Assembler and Disassembler to decode/encode Header and
Data directly to/from MessageTransfer
- modified Disassembler to only write data if encoding of headers is
successful
- added Strings.toUTF8(String) -> byte[] to do proper UTF-8 encoding
that is also fast for 7-bit ascii
- modified JMSTextMessage to use the Strings.toUTF8
- modified QpidBench to only generate 7-bit ascii when using
TextMessage
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@682887 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680803 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- added batched writes of commands/controls issued on a session
- copy fragmented frames and segments rather than trying to decode
them piecemeal, removed FragmentDecoder
- added caching for str8 encode/decode
- compute sizes as we encode by going back and filling in the amount
of bytes written rather than computing it up front
- added SYNC option to commands
- renamed NO_OPTION argument to NONE
- added a timeout to Client.java
- removed use of UUID.fromString in BasicMessageProducer_0_10.java
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@675165 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@672766 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667015 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
We need to get rid of the defaults that points to rhm.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@660254 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
python code in rev 655965.
The change was to correct a few typos.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@656071 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
keep automated testing working.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655568 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653253 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651133 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
are now checked with the 0-10 final updates
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@648784 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
the 0-10 preview spec; this includes improvements to the codegen process as well as some modifications to the shared code path in the client to not lose per message state when consumers are closed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@648692 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
broker response. We first try the highest protocol version and update the handler if the broker replies with a different protocol version. NOTE that we need to update the current java broker and 0.8 client for handling protocol headers. This should happen with the M2.1 merge. For the moment we only support an in VM 0.8 broker. Moreover, we'll need to migrate to a 0.10 vs 99.0 protocol version.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@643822 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
This contains verify scripts and xxx.in files for pubsub, fanout and requestResponse.
These scripts will run the java examples against itself, c++ and python
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@639095 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
This allows the Listener or Consumer to start multiple instances by taking a JNDI name of a queue bound to the topic exchange as a program argument.
The JNDI name should be defined in the fanout.properties. Currently 3 such queues are defined.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@639090 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
I also took the oportunity to organize the code a bit more.
Also removed the temp hack we used to bind a Topic to more than one routingkey to interop with the c++/python examples.
The topics can now be bound to more than one routingkey in the jndi properties file.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@639078 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
The verify_all script will run all verify scripts under each example
Following is a description of each script type
==============================================
verify - runs java producer and consumer.
verify_java_python - runs java producer and python consumer
verify_python_java - runs python consumer and java consumer
verify_cpp_java - runs cpp producer and java consumer
verify_java_cpp - runs java producer and cpp consumer
The xxx.in file contains the expected output.
It will be compared against the output of the test to determine any failures.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@638553 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@638019 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627654 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627536 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
those changes
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616545 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@616542 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@613155 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@613114 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612829 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612811 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
python and c++ client
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612598 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
looksup a destination defined in the properties file. The destination defines a fannout exchange and a queue
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612597 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612593 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
| |
python examples
by allowing the ability to specify a routing key that is different from it's queue name.
Also deleted the sample.properties and replaced them by property files for each example.
I also removed the dependency on the BaseExamples class. Waiting for Arnaud to review it.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612584 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@612473 13f79535-47bb-0310-9956-ffa450edef68
|