Added first cut of generated client interface.

Old channel interface still supported; shares SessionCore with the new interface.
Todo: allow applications to signal completion of received commands; keywrod args for interface.



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@562866 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 4 deletions

diff --git a/cpp/src/qpid/client/ExecutionHandler.h b/cpp/src/qpid/client/ExecutionHandler.h
index 99b0f4b915..f62598ef95 100644
--- a/cpp/src/qpid/client/ExecutionHandler.h
+++ b/cpp/src/qpid/client/ExecutionHandler.h
@@ -43,6 +43,7 @@ class ExecutionHandler :
     Correlator correlation;
     CompletionTracker completion;
     framing::ProtocolVersion version;
+    uint64_t maxFrameSize;
 
     void complete(uint32_t mark, framing::SequenceNumberSet range);    
     void flush();
@@ -50,7 +51,9 @@ class ExecutionHandler :
 public:
     BlockingQueue<ReceivedContent::shared_ptr> received; 
 
-    ExecutionHandler();
+    ExecutionHandler(uint64_t maxFrameSize = 65536);
+
+    void setMaxFrameSize(uint64_t size) { maxFrameSize = size; }
 
     void handle(framing::AMQFrame& frame);
     void send(framing::AMQBody::shared_ptr command, 
@@ -58,11 +61,9 @@ public:
               Correlator::Listener g = Correlator::Listener());
     void sendContent(framing::AMQBody::shared_ptr command, 
                      const framing::BasicHeaderProperties& headers, const std::string& data, 
-                     uint64_t frameSize,
                      CompletionTracker::Listener f = CompletionTracker::Listener(), 
                      Correlator::Listener g = Correlator::Listener());
-
-    void sendContent(framing::AMQBody::shared_ptr content);
+    void sendFlush();
 };
 
 }}