You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2016/03/29 23:21:49 UTC
qpid-dispatch git commit: DISPATCH_57 - Prevent in-process
subscribers from using ANYCAST_BALANCED distribution. Balanced distribution
relies on tracking unsettled deliveries to determine which specific
destination to send to. In-process subscribers don
Repository: qpid-dispatch
Updated Branches:
refs/heads/master 96ce4a6c8 -> b0ad2eb2f
DISPATCH_57 - Prevent in-process subscribers from using ANYCAST_BALANCED distribution.
Balanced distribution relies on tracking unsettled deliveries to determine which
specific destination to send to. In-process subscribers don't participate in delivery
settlement and therefore can't easily participate in balanced distribution.
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/b0ad2eb2
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/b0ad2eb2
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/b0ad2eb2
Branch: refs/heads/master
Commit: b0ad2eb2f8a09d66e05b4cc28382ee0b623bb01d
Parents: 96ce4a6
Author: Ted Ross <tr...@redhat.com>
Authored: Tue Mar 29 17:20:04 2016 -0400
Committer: Ted Ross <tr...@redhat.com>
Committed: Tue Mar 29 17:20:04 2016 -0400
----------------------------------------------------------------------
src/python_embedded.c | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/b0ad2eb2/src/python_embedded.c
----------------------------------------------------------------------
diff --git a/src/python_embedded.c b/src/python_embedded.c
index d9b8069..4946856 100644
--- a/src/python_embedded.c
+++ b/src/python_embedded.c
@@ -527,13 +527,17 @@ static int IoAdapter_init(IoAdapter *self, PyObject *args, PyObject *kwds)
PyObject *addr;
char aclass = 'L';
char phase = '0';
- int treatment = QD_TREATMENT_ANYCAST_BALANCED;
+ int treatment = QD_TREATMENT_ANYCAST_CLOSEST;
if (!PyArg_ParseTuple(args, "OO|cci", &self->handler, &addr, &aclass, &phase, &treatment))
return -1;
if (!PyCallable_Check(self->handler)) {
PyErr_SetString(PyExc_TypeError, "IoAdapter.__init__ handler is not callable");
return -1;
}
+ if (treatment == QD_TREATMENT_ANYCAST_BALANCED) {
+ PyErr_SetString(PyExc_TypeError, "IoAdapter: ANYCAST_BALANCED is not supported for in-process subscriptions");
+ return -1;
+ }
Py_INCREF(self->handler);
self->qd = dispatch;
self->core = qd_router_core(self->qd);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org