| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-10@686136 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
I also removed commented code as well as code that wasn't used.
Cleaned up unused imports as well.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668333 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668309 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668308 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
handling of incoming known-completed to clear out processed set
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667615 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667540 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@667501 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@666259 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
dump into the log
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665798 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@665733 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664698 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the negotiated channel-max; also removed unnecessary catches that were swallowing stack traces from several tests
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664339 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@664140 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
instead of sync command on message transfer
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663813 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
now waits for the session to be detached before returning, this guarantees we won't have any active sessions when the connection close is attempted
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663677 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
BBDecoder/Encoder to use byte buffer primitives, made various classes final (including generated classes)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663325 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662859 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
override commonly used size methods for improved performance
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@662849 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
IoHandler and IoSender uses the java.io classes for IO operations and have shown very good improvement in latency and memory usage over MINA.
For certain tests with pub/sub it gives a 2X improvement in throughput.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@661561 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
values before trying to encode them. Also, moved createDurableSubscriber from AMQSession_0_10 -> AMQSession.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@659631 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
QPID-861. Also switched command ids from long -> int, and added a mutex to channel to prevent multi-frame commands from interleaving when invoked from separate threads.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@659271 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
session.flush completed
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@658689 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
read/write method of structs into generated code resulting in roughly a 2x improvement
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@656760 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
when the corresponding property is set.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655923 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
transitions that don't consume input bytes
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@655585 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653518 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653400 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
size -QPID-1007: added io write handler into MINA chain
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653354 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@652386 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
infinite loop
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@652170 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651325 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651134 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651133 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
|
| |
|
|
|
|
|
| |
When the message id is set, _hasBeenUpdated will be set to true.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@646519 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
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@641304 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@641212 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
previously it was hard-coded." Those constants must be used when the connection is established.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@638344 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Modified the ConnectionDelegate to use the Constants for AMQP version.
Also the version cosntants were changed to 99-0 to work with the c++ broker until the 0-10 framing gets completed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@636791 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634673 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
Modified the AMQBindingURL to fix an error in the toString method
Added more test cases to the main method in the BindingURLParser for quick testing, these cases are also present as unit tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@631695 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
This allows adding multiple binding keys, using # and * in the URLs.
This is tracked via QPID-814
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@631489 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629991 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629747 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627607 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@627154 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@620584 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619538 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
included in the JMS Exception thrown via the ExceptionListener
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619189 13f79535-47bb-0310-9956-ffa450edef68
|