| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r494553 | cctrieloff | 2007-01-09 15:15:52 -0500 (Tue, 09 Jan 2007) | 4 lines
code gen part of last change. requires bootstrap
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@517826 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r494540 | cctrieloff | 2007-01-09 14:44:50 -0500 (Tue, 09 Jan 2007) | 5 lines
Most of remaining version changes for C++. Still need to deal with AMQFrame
defualt constructor and do some clean up here and there..
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@517824 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r493126 | aconway | 2007-01-05 13:34:08 -0500 (Fri, 05 Jan 2007) | 2 lines
Add refernece to prereqs in README-dist.
........
r493140 | aconway | 2007-01-05 14:09:10 -0500 (Fri, 05 Jan 2007) | 8 lines
2007-01-05 Jim Meyering <meyering@redhat.com>
* gen/Makefile.am (gen-src.mk) [CAN_GENERATE_CODE]: Emit an empty
dependency for each generated file, in case they are renamed,
removed, or no longer generated. Otherwise, "./bootstrap --build"
would fail with e.g., `*** No rule to make target
../../gentools/templ.cpp/AMQP_HighestVersion.cpp.tmpl'.
........
r493151 | aconway | 2007-01-05 14:25:32 -0500 (Fri, 05 Jan 2007) | 6 lines
2007-01-05 Jim Meyering <meyering@redhat.com>
* lib/broker/Makefile.am (libqpidbroker_la_LIBADD): Define, so we
link with libqpidcommon.la.
* lib/client/Makefile.am (libqpidclient_la_LIBADD): Likewise.
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516489 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r492756 | kpvdr | 2007-01-04 16:30:39 -0500 (Thu, 04 Jan 2007) | 1 line
Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and tidy-up in related code.
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516485 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r492641 | aconway | 2007-01-04 12:06:38 -0500 (Thu, 04 Jan 2007) | 2 lines
Removed unused qpid/ subdirectory.
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516460 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
........
r492636 | aconway | 2007-01-04 11:55:03 -0500 (Thu, 04 Jan 2007) | 3 lines
Added "make check" to -build flag.
Removed rpm build directories from svn. Create them during make.
........
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516459 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Correctly split reference messages into chunks shorter than
the framesize
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516157 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@515721 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
version >= 0-8.
* python/qpid/spec.py (Spec.__init__): Remove unused parameter.
* python/qpid/testlib.py (TestRunner._parseargs): Add --errata option,
set default errata only if --spec is not present.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@515363 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Refactored message transfer to extract commmonality from deliver/get
r1242@fuschia: andrew | 2007-03-05 17:54:44 +0000
Turn oversize inline transfers into reference transfers
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@514751 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
generated code
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@511004 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Bug in acks - Small typo fixed
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510986 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510913 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510912 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
from Channel into separate Basic class.
* cpp/lib/client/*, cpp/test/*: Adjusted for new Channel::getBasic() API.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510705 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510553 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510180 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* cpp/lib/client/MessageListener.h: const correctness.
* cpp/tests/*: MessageListener const change.
* cpp/lib/broker/Content.h: Removed out-of-date FIXME comments.
* cpp/lib/client/ClientChannel.h/ .cpp():
- added locking for consumers map and other member access.
- refactored implementations of Basic get, deliver, return:
most logic now encapsulted in IncomingMessage class.
- fix channel close problems.
* cpp/lib/client/ClientMessage.h/.cpp:
- const correctness & API convenience fixes.
- getMethod/setMethod/getHeader: for new IncomingMessage
* cpp/lib/client/Connection.h/.cpp:
- Fixes to channel closure.
* cpp/lib/client/IncomingMessage.h/.cpp:
- Encapsulate *all* incoming message handling for client.
- Moved handling of BasicGetOk to IncomingMessage to fix race.
- Thread safety fixes.
* cpp/lib/client/ResponseHandler.h/.cpp:
- added getResponse for ClientChannel.
* cpp/lib/common/Exception.h:
- added missing throwSelf implementations.
- added ShutdownException as general purpose shut-down indicator.
- added EmptyException as general purpose "empty" indicator.
* cpp/lib/common/sys/Condition|Monitor|Mutex.h|.cpp:
- Condition variable abstraction extracted from Monitor for situations
where a single lock is associated with multiple conditions.
* cpp/tests/ClientChannelTest.cpp:
- Test incoming message transfer, get, consume etc.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510161 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510128 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Updated expected cpp broker test failures
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510114 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510107 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
Attach reference to transfer, as it will be deleted on close
Altered tests to get reference from the message on the queue rather than looking them up from channel as they are already gone there
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510096 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
| |
More support for references (and transfers of reference content)
r1220@fuschia: andrew | 2007-02-21 00:22:53 +0000
Working version of delivering Message Transfers by reference
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509834 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
transfers. There is plenty of scope for more sophisticated tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509755 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
transfers. There is plenty of scope for more sophisticated tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509754 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509738 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509617 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509616 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
listener for response.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@509611 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508706 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* cpp/lib/client/IncomingMessage.cpp: Simplified message aggregation.
* cpp/lib/common/framing/AMQ*Body.h: remove unnecessary virtual inheritance.
* cpp/lib/common/framing/AMQMethodBody.h: add bool isRequest, isResponse
* cpp/lib/common/sys/Mutex.h (class ScopedUnlock): Added ScopedUnlock
* cpp/lib/common/sys/ThreadSafeQueue.h: Thread-safe queue template.
* cpp/tests/BrokerChannelTest.cpp: Renamed from ChannelTest.
* cpp/tests/ClientChannelTest.cpp: Test client API.
* cpp/tests/RequestResponseTest.cpp: Removed empty test.
* cpp/lib/client/Connection.h,.cpp:
- non-static channelIdCounter
- No close() in dtor.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508705 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508460 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508396 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508391 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508379 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
| |
Added better error handling when connection closes without close method
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508377 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508233 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508156 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508150 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508098 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
disconnected
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507993 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
rollback(), however.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507960 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
| |
passing yet
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507672 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
(This change also applied on trunk)
Minor update of accumulated ack and test.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507622 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
| |
Fixed tests, and fixed an exposed bug
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507602 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
General-purpose producer-consumer synchronization. Anywhere we have
producer/consumer threads in qpid we should re-use this sync object
rather than re-inventing the synchronization each time.
* cpp/lib/common/sys/AtomicCount.h: Separated ScopedIncrement/ScopedDecrement
into ScopedIncrement.h
* cpp/tests/InProcessBroker.h: Added class InProcessBrokerClient, a
self contained in-process client + broker convenience for tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507560 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507491 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
| |
Removed currently unused request tracking logic
r1125@fuschia: andrew | 2007-02-13 21:51:30 +0000
Implemented receiveing batched Message.ok in c++ broker
Implemented batched response frames in python client code
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507249 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
classes to make them directly usable as an API for low-level AMQP access.
- Proxies hold reference to a ChannelAdapter not just an output handler.
- Removed MethodContext parameter, makes no sense on requester end.
- Return RequestId from request methods so caller can correlate
incoming responses.
- Add RequestId parameter to response methods so caller can provide
correlation for outgoing responses.
- No longer inherit from *Operations classes as the signatures no
longer match. Proxy is for caller (client/requester) and Operations
is for callee (server/responder)
* cpp/lib/client/ClientChannel.h: Channel provides a raw proxy to the broker.
Normal users will still use the Channel API to deal with the broker, but
advanced users (incl ourselves!) can use the raw API to directly send
and receive any AMQP message.
* cpp/lib/broker/BrokerChannel,BrokerAdapter: Refactor for new proxies.
broker::Channel is also a ClientProxy
* Sundry files:
- Pass ProtcolVersion by value, it is only two bytes.
- Misc. const correctness fixes.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506823 13f79535-47bb-0310-9956-ffa450edef68
|
|
|
|
| |
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506566 13f79535-47bb-0310-9956-ffa450edef68
|