From bcfa0a86baebb2598c0be270121d98a0f31b19c6 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Fri, 30 Jan 2009 18:59:24 +0000 Subject: Correction for: start a broker in cluster, send messages that are flow to disk, then join a broker to the cluster. Then consume from the new node. Cotent released messages where loosing content. This patch corrects that. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@739378 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/SessionImpl.cpp | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'cpp/src/qpid/client/SessionImpl.cpp') diff --git a/cpp/src/qpid/client/SessionImpl.cpp b/cpp/src/qpid/client/SessionImpl.cpp index 7cf68956ea..c179a31853 100644 --- a/cpp/src/qpid/client/SessionImpl.cpp +++ b/cpp/src/qpid/client/SessionImpl.cpp @@ -322,6 +322,11 @@ Future SessionImpl::send(const AMQBody& command, const FrameSet& content) { return f; } +void SessionImpl::sendRawFrame(AMQFrame& frame) { + Acquire a(sendLock); + handleOut(frame); +} + Future SessionImpl::sendCommand(const AMQBody& command, const MethodContent* content) { Acquire a(sendLock); @@ -767,4 +772,9 @@ void SessionImpl::setWeakPtr(bool weak) { connectionShared = connectionWeak.lock(); } +shared_ptr SessionImpl::getConnection() +{ + return connectionWeak.lock(); +} + }} -- cgit v1.2.1