| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600599 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600561 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600501 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600442 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
src/qpid/client/SessionCore.cpp: close/open Demux on suspend/resume.
src/tests/exception_test.cpp: convert to Session API, boost test.
- Temporarily disabled due issues noted in TODO comments
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600046 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599887 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599876 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599868 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
| |
transports using -Dtransport="nio". By default it's the MINA transport.
You can also turn on batching for the nio transport by using -Dbatch="true". This option has no effect on MINA.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599856 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Exposed start() through the subscription manager in addition to run().
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599832 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599810 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599725 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599637 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
And made the default log frequency to every 1000 msgs
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599624 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
the test cases
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599611 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
error has been solved (elsewhere)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599592 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
collection
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599528 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
enqueueComplete()
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599495 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599452 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599424 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599422 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599413 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599412 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599403 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
| |
dispatch to consumers
Fix to PersistableMessage: use correct lock when accessing synclist, don't hold enqueue lock when notifying queues
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599395 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
* Added DeletionManager class to delete handles
* Used to stop PollerHandles being deleted whilst still in use
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599390 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
noAck still has to clear our internal command ids.
increased the default max prefetch to 1000
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599255 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
had compilation errors due missing classes from the new mina version
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599216 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599203 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
"enable_command_replay" is false.
However we still need to keep the command_id to implement sync properly.
By default "enable_command_replay" is false.
The earlier implementation completely avoided incrementing the command count and putting it in the map.
This causes a problem as it will break the contract for sync. When the client code calls sync we need to only return when the broker has sent the EM that is at or above that command_id. So we need to keep that around.
Keeping track of command_ids is different from keeping commands around. We keep commands around for reply, but we need to keep track of command_id's to implement the execution layer properly.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599144 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
Updated/removed sundry FIXME comments.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599128 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599124 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
| |
If useQueue is present then we use p2p.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599117 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
Now the Broker module does not compile as it seem to depend on an obselete package.
So I haev commented the broker module in the build. We can move the broker code to work with the new MINA version during the f2f.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599116 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599103 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- boost::ptr_map API changed.
- Boost.Test unit test framework changes.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599067 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599047 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599030 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599028 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
| |
- Added help text explaining multi-process use.
- Fixed bug in multi-process mode, too many threads were started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@599025 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598992 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598939 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598924 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
NOTE: options have changed, see perftest --help.
- Supports multiple publishers.
- Subscribers set credit to receive exactly the expected no. of messages.
- All transfers unconfirmed by default.
client/Connector.cpp: Added connector ID to RECV/SENT logging
client/Completion.h: Added default ctor.
broker/Broker.cpp: --ack defaults to 0 - session acks disabled.
client/SessionCore.cpp: Ignore surplus frames in CLOSING state.
log/Options.cpp: By default log to stdout instead of stderr. Easier to grep.
framing/AMQContentBody.h: Log message content even in NDEBUG mode.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598770 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598719 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
solution used a Qpid specific NO_ACK method in the extended session. However if people are using a pure JMS API then they have no way of taking use of this feature, therefore I added this jvm switch
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598717 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598684 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598559 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598556 13f79535-47bb-0310-9956-ffa450edef68
|
| |
|
|
|
|
| |
intrusive_ptr<PersistentMessage>, so as to hook into the refcount for a message while it is in the store.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@598440 13f79535-47bb-0310-9956-ffa450edef68
|