summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Bridge.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/Bridge.cpp')
-rw-r--r--cpp/src/qpid/broker/Bridge.cpp11
1 files changed, 10 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Bridge.cpp b/cpp/src/qpid/broker/Bridge.cpp
index ea9a41ac9d..8c4b5d6faf 100644
--- a/cpp/src/qpid/broker/Bridge.cpp
+++ b/cpp/src/qpid/broker/Bridge.cpp
@@ -59,7 +59,16 @@ void Bridge::create()
} else {
string queue = "bridge_queue_";
queue += Uuid(true).str();
- peer.getQueue().declare(queue, "", false, false, true, true, FieldTable());
+ FieldTable queueSettings;
+ if (args.i_id.size()) {
+ queueSettings.setString("qpid.trace.id", args.i_id);
+ }
+ if (args.i_excludes.size()) {
+ queueSettings.setString("qpid.trace.exclude", args.i_excludes);
+ }
+ bool durable = false;//should this be an arg, or would be use src_is_queue for durable queues?
+ 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().flow(args.i_dest, 0, 0xFFFFFFFF);