diff options
| author | Gordon Sim <gsim@apache.org> | 2007-09-14 14:09:08 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-09-14 14:09:08 +0000 |
| commit | 9b3748849707c476b76c09fcabfefd965087a108 (patch) | |
| tree | f0d41cf4feb25f36e9a1e33065175b09f18ba3ec /cpp/src/qpid/broker/SemanticHandler.h | |
| parent | e10d11937bccc3cdbdd867266501c3e16d28e933 (diff) | |
| download | qpid-python-9b3748849707c476b76c09fcabfefd965087a108.tar.gz | |
Handle asynchronous enqueue of messages.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@575689 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticHandler.h')
| -rw-r--r-- | cpp/src/qpid/broker/SemanticHandler.h | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/SemanticHandler.h b/cpp/src/qpid/broker/SemanticHandler.h index 478dfb6760..f17ef67bfc 100644 --- a/cpp/src/qpid/broker/SemanticHandler.h +++ b/cpp/src/qpid/broker/SemanticHandler.h @@ -25,6 +25,7 @@ #include "BrokerAdapter.h" #include "DeliveryAdapter.h" #include "MessageBuilder.h" +#include "IncomingExecutionContext.h" #include "qpid/framing/amqp_types.h" #include "qpid/framing/AMQP_ServerOperations.h" @@ -53,7 +54,7 @@ class SemanticHandler : public DeliveryAdapter, Session& session; Connection& connection; BrokerAdapter adapter; - framing::Window incoming; + IncomingExecutionContext incoming; framing::Window outgoing; sys::Mutex outLock; MessageBuilder msgBuilder; @@ -65,6 +66,8 @@ class SemanticHandler : public DeliveryAdapter, void handleCommand(framing::AMQMethodBody* method); void handleContent(framing::AMQFrame& frame); + void sendCompletion(); + //ChannelAdapter virtual methods: void handleMethod(framing::AMQMethodBody* method); |