You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2008/05/02 19:14:46 UTC
svn commit: r652829 -
/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp
Author: gsim
Date: Fri May 2 10:14:46 2008
New Revision: 652829
URL: http://svn.apache.org/viewvc?rev=652829&view=rev
Log:
Use no-ack in bridging as it is currently an exclusive, temp queue
(will eventually be configurable)
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp?rev=652829&r1=652828&r2=652829&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Bridge.cpp Fri May 2 10:14:46 2008
@@ -53,7 +53,7 @@
//TODO: handle 'push' here... simplest way is to create frames and pass them to Connection::received()
} else {
if (args.i_src_is_queue) {
- peer.getMessage().subscribe(args.i_src, args.i_dest, 0, 0, false, "", 0, FieldTable());
+ peer.getMessage().subscribe(args.i_src, args.i_dest, 1, 0, false, "", 0, FieldTable());
peer.getMessage().flow(args.i_dest, 0, 0xFFFFFFFF);
peer.getMessage().flow(args.i_dest, 1, 0xFFFFFFFF);
} else {
@@ -70,7 +70,7 @@
bool autoDelete = !durable;//auto delete transient queues?
peer.getQueue().declare(queue, "", false, durable, true, autoDelete, queueSettings);
peer.getExchange().bind(queue, args.i_src, args.i_key, FieldTable());
- peer.getMessage().subscribe(queue, args.i_dest, 0, 0, false, "", 0, FieldTable());
+ peer.getMessage().subscribe(queue, args.i_dest, 1, 0, false, "", 0, FieldTable());
peer.getMessage().flow(args.i_dest, 0, 0xFFFFFFFF);
peer.getMessage().flow(args.i_dest, 1, 0xFFFFFFFF);
}