[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[ https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803327#comment-16803327 ] ASF GitHub Bot commented on QPID-8286: -- asfgit commented on pull request #22: QPID-8286: [Broker-J] Add operations into priority queue to change message priority URL: https://github.com/apache/qpid-broker-j/pull/22 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > [Broker-J] Add operation into priority queue to change message priority > --- > > Key: QPID-8286 > URL: https://issues.apache.org/jira/browse/QPID-8286 > Project: Qpid > Issue Type: Improvement > Components: Broker-J >Reporter: Alex Rudyy >Priority: Major > Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2 > > > The functionality to change message priority is required for some use case > scenarios involving priority queues. At the moment, in order to change the > priority, the messages need to be consumed (for example, using selector > 'JMSMessageID=ID:XYZ') and re-published with a different priority. I > management operation can be introduced on the priority queue which can simply > dequeue the message and re-enqueue it with a provided priority. -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org
[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[ https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803326#comment-16803326 ] ASF subversion and git services commented on QPID-8286: --- Commit 159a75361cc584b28d92dec2d0abce6a311480f5 in qpid-broker-j's branch refs/heads/master from Alex Rudyy [ https://gitbox.apache.org/repos/asf?p=qpid-broker-j.git;h=159a753 ] QPID-8286: [Broker-J] Add operation into priority queue to change message priority This closes #22 > [Broker-J] Add operation into priority queue to change message priority > --- > > Key: QPID-8286 > URL: https://issues.apache.org/jira/browse/QPID-8286 > Project: Qpid > Issue Type: Improvement > Components: Broker-J >Reporter: Alex Rudyy >Priority: Major > Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2 > > > The functionality to change message priority is required for some use case > scenarios involving priority queues. At the moment, in order to change the > priority, the messages need to be consumed (for example, using selector > 'JMSMessageID=ID:XYZ') and re-published with a different priority. I > management operation can be introduced on the priority queue which can simply > dequeue the message and re-enqueue it with a provided priority. -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org
[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[
https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802327#comment-16802327
]
Alex Rudyy commented on QPID-8286:
--
[~rgodfrey], I finally found some time to implement my ideas about changing
message priority. In PR22 I added 2 operations into priority queue :
{{reenqueueMessageForPriorityChange}} and
{{reenqueueMessagesForPriorityChange}}. In both operations the messages(s) are
replaced with new ones having given priority. I am planning to merge the
changes into 7.1.x and spin 7.1.2 release.
> [Broker-J] Add operation into priority queue to change message priority
> ---
>
> Key: QPID-8286
> URL: https://issues.apache.org/jira/browse/QPID-8286
> Project: Qpid
> Issue Type: Improvement
> Components: Broker-J
>Reporter: Alex Rudyy
>Priority: Major
> Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2
>
>
> The functionality to change message priority is required for some use case
> scenarios involving priority queues. At the moment, in order to change the
> priority, the messages need to be consumed (for example, using selector
> 'JMSMessageID=ID:XYZ') and re-published with a different priority. I
> management operation can be introduced on the priority queue which can simply
> dequeue the message and re-enqueue it with a provided priority.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
-
To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org
[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[ https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802326#comment-16802326 ] ASF GitHub Bot commented on QPID-8286: -- alex-rufous commented on pull request #22: QPID-8286: [Broker-J] Add operations into priority queue to change message priority URL: https://github.com/apache/qpid-broker-j/pull/22 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > [Broker-J] Add operation into priority queue to change message priority > --- > > Key: QPID-8286 > URL: https://issues.apache.org/jira/browse/QPID-8286 > Project: Qpid > Issue Type: Improvement > Components: Broker-J >Reporter: Alex Rudyy >Priority: Major > Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2 > > > The functionality to change message priority is required for some use case > scenarios involving priority queues. At the moment, in order to change the > priority, the messages need to be consumed (for example, using selector > 'JMSMessageID=ID:XYZ') and re-published with a different priority. I > management operation can be introduced on the priority queue which can simply > dequeue the message and re-enqueue it with a provided priority. -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org
[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[
https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793695#comment-16793695
]
Alex Rudyy commented on QPID-8286:
--
[~rgodfrey], ideally, it is expected that new functionality should allow to
change message priority (increase it) in order to process it faster due to big
backlog of messages waiting for processing. How it is implemented and what
priority client would see, it is up to the implementation. Here are my thoughts
how this can be achieved
* within virtualhost transaction
** find the message (either using selector or id)
** acquire the message to prevent its consumption (if message is already
acquired by either consumer or other operation, abort the operation)
** dequeue the message
** create new message from original one but set priority to desired value
** enqueue new message
* commit transaction
Thus, the operation will remove the original message and enqueue a new one.
Thus, the consumer would see completely new message with new priority, new
message id and new message timestamp.
Perhaps, the operation would be better named
{{replaceMessageWithNewOneHavingDifferentPriority}} :)
At the moment, the need for this functionality is in a process of discussion.
As it would introduce a vendor locking to Qpid for the application. Though,
ArtemisMQ, ActiveMQ already have operations for changing message priorities.
RabbitMQ, Solace, IBM MQ do not have such functionality.
> [Broker-J] Add operation into priority queue to change message priority
> ---
>
> Key: QPID-8286
> URL: https://issues.apache.org/jira/browse/QPID-8286
> Project: Qpid
> Issue Type: Improvement
> Components: Broker-J
>Reporter: Alex Rudyy
>Priority: Major
> Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2
>
>
> The functionality to change message priority is required for some use case
> scenarios involving priority queues. At the moment, in order to change the
> priority, the messages need to be consumed (for example, using selector
> 'JMSMessageID=ID:XYZ') and re-published with a different priority. I
> management operation can be introduced on the priority queue which can simply
> dequeue the message and re-enqueue it with a provided priority.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
-
To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org
For additional commands, e-mail: dev-h...@qpid.apache.org
[jira] [Commented] (QPID-8286) [Broker-J] Add operation into priority queue to change message priority
[ https://issues.apache.org/jira/browse/QPID-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793661#comment-16793661 ] Rob Godfrey commented on QPID-8286: --- [~orudyy] is the expectation here that this update to priority would modify the persistent storage of the message (including flowing to/restoring from disk? Also what value would the receiving client see as the message priority - the original or the updated value? > [Broker-J] Add operation into priority queue to change message priority > --- > > Key: QPID-8286 > URL: https://issues.apache.org/jira/browse/QPID-8286 > Project: Qpid > Issue Type: Improvement > Components: Broker-J >Reporter: Alex Rudyy >Priority: Major > Fix For: qpid-java-broker-8.0.0, qpid-java-broker-7.1.2 > > > The functionality to change message priority is required for some use case > scenarios involving priority queues. At the moment, in order to change the > priority, the messages need to be consumed (for example, using selector > 'JMSMessageID=ID:XYZ') and re-published with a different priority. I > management operation can be introduced on the priority queue which can simply > dequeue the message and re-enqueue it with a provided priority. -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org
