You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "chenta lee (JIRA)" <qp...@incubator.apache.org> on 2009/09/14 14:49:57 UTC

[jira] Issue Comment Edited: (QPID-1766) Implemention of selector using Xquery

    [ https://issues.apache.org/jira/browse/QPID-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12754964#action_12754964 ] 

chenta lee edited comment on QPID-1766 at 9/14/09 5:49 AM:
-----------------------------------------------------------

After some experiment, add a pointer to consumer in QueuedMessage can solve the problem and past the python test. 

However, if I only put one consumer pointer in the QueuedMessge that also mean I can only update one consumer's position property when requeue the message. I am thinking that if we requeued a message, does it also mean that this message is available to ALL consumers? so I need to update the position property to ALL consumer. Am I correct?

If my assumption is correct, then I need to find all the functions that invoke Queue::requeue and insert some code before calling it.

      was (Author: chenta):
    After some experiment, add a point to consumer in QueuedMessage can solve the problem and past the python test. 

However, if I only put one consumer point in the QueuedMessge that also mean I can only update one consumer's position property when requeue the message. I am thinking that if we requeued a message, does it also mean that this message is available to ALL consumers? so I need to update the position property to ALL consumer. Am I correct?

If my assumption is correct, then I need to find all the functions that invoke Queue::requeue and insert some code before calling it.
  
> Implemention of selector using Xquery
> -------------------------------------
>
>                 Key: QPID-1766
>                 URL: https://issues.apache.org/jira/browse/QPID-1766
>             Project: Qpid
>          Issue Type: Improvement
>          Components: C++ Broker, C++ Client
>         Environment: Linux
>            Reporter: chenta lee
>         Attachments: chenta.diff, Makefile.patch, Makefile.patch, message_selector_pytest.patch, selector.diff, selector.diff, selector.patch, selector.patch, selector_broker.patch, selector_client.patch, selector_client.patch, selector_example.zip
>
>
> I implemented the message selector for C++ broker and client using Xquery.
> I will attach an example later.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org