You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openwhisk.apache.org by "KeonHee (Confluence)" <no...@apache.org> on 2021/05/28 06:28:24 UTC
[CONF] OpenWhisk > QueueManager

|
[![](cid:avatar_28855ef39c6d72ce993aded2e21d1a4b)](https://cwiki.apache.org/confluence/display/~keonhee?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6) | KeonHee
**created** a page  
---|---  
|  
---  
|  | [![page icon](cid:page-
icon)](https://cwiki.apache.org/confluence/display/OPENWHISK/QueueManager?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=view
"page icon")  
---  
[QueueManager](https://cwiki.apache.org/confluence/display/OPENWHISK/QueueManager?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=view
"QueueManager")  
|

#  **1\. Introduction**

The queue manager has a queue pool and decides to create and delete queues. If
there is a queue of the same action in another scheduler, it will not be
created. It is also responsible for passing activations to each queue. And
when the action is updated, it deletes the existing queue and creates a new
version of the queue.

#  **2\. Architecture Diagram**

##  **2-1. Create Queue**

When receiving the message **CreateQueue**  that creates a new queue, it
creates a new queue. If there is already a queue for an action in another
scheduler, it is not created.

![](https://cwiki.apache.org/confluence/download/attachments/embedded-
page/OPENWHISK/QueueManager/%E1%84%89%E1%85%B3%E1%84%8F%E1%85%B3%E1%84%85%E1%85%B5%E1%86%AB%E1%84%89%E1%85%A3%E1%86%BA%202021-05-28%20%E1%84%8B%E1%85%A9%E1%84%92%E1%85%AE%203.01.35.png?api=v2)

##  **2-2. Update Queue**

When the action is updated, the queue is also updated to the new version.

![](https://cwiki.apache.org/confluence/download/attachments/embedded-
page/OPENWHISK/QueueManager/%E1%84%89%E1%85%B3%E1%84%8F%E1%85%B3%E1%84%85%E1%85%B5%E1%86%AB%E1%84%89%E1%85%A3%E1%86%BA%202021-05-28%20%E1%84%8B%E1%85%A9%E1%84%92%E1%85%AE%203.01.37.png?api=v2)

  

##  **2-3. Distribute Activations**

It is responsible for distributing the activations to each queue.

![](https://cwiki.apache.org/confluence/download/attachments/embedded-
page/OPENWHISK/QueueManager/%E1%84%89%E1%85%B3%E1%84%8F%E1%85%B3%E1%84%85%E1%85%B5%E1%86%AB%E1%84%89%E1%85%A3%E1%86%BA%202021-05-28%20%E1%84%8B%E1%85%A9%E1%84%92%E1%85%AE%203.05.42.png?api=v2)  
  
---  
|  | [![View page Icon](cid:com.atlassian.confluence.plugins.confluence-email-
resources_view-page-email-adg-footer-
item_icon)](https://cwiki.apache.org/confluence/display/OPENWHISK/QueueManager?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=view
"View page Icon") | [View
page](https://cwiki.apache.org/confluence/display/OPENWHISK/QueueManager?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=view
"View page") | •  
---|---|---  
[![Like Icon](cid:com.atlassian.confluence.plugins.confluence-like_view-email-
adg-content-
item_icon)](https://cwiki.apache.org/confluence/plugins/likes/like.action?contentId=181308138&src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=like&jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ4c3JmOjhhYTk4MDg3NWJmMjQ2MzUwMTVjOTI2N2JjOGUwMmY2IiwicXNoIjoiODFlYWQwMTcxZjYzZGFhMGY4MzFhZmFlNGZkMDI0ZjExNjkzOTU1Yjc5OGRkODNjMzkyMzFmYWY2MDQxZDQzMiIsImlzcyI6ImNvbmZsdWVuY2Vfbm90aWZpY2F0aW9uc0FSRUgtWFVEMS1QT1FHLUNTQU8iLCJleHAiOjE2MjI3ODgxMDQsImlhdCI6MTYyMjE4MzMwNH0.Bl-
ajlGqfYO4BNmC_rpeLlnlgQ7hLFXoVt4-6I5IvAQ "Like Icon") |
[Like](https://cwiki.apache.org/confluence/plugins/likes/like.action?contentId=181308138&src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=like&jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ4c3JmOjhhYTk4MDg3NWJmMjQ2MzUwMTVjOTI2N2JjOGUwMmY2IiwicXNoIjoiODFlYWQwMTcxZjYzZGFhMGY4MzFhZmFlNGZkMDI0ZjExNjkzOTU1Yjc5OGRkODNjMzkyMzFmYWY2MDQxZDQzMiIsImlzcyI6ImNvbmZsdWVuY2Vfbm90aWZpY2F0aW9uc0FSRUgtWFVEMS1QT1FHLUNTQU8iLCJleHAiOjE2MjI3ODgxMDQsImlhdCI6MTYyMjE4MzMwNH0.Bl-
ajlGqfYO4BNmC_rpeLlnlgQ7hLFXoVt4-6I5IvAQ "Like")  
---|---  
  
|  | [Stop watching
space](https://cwiki.apache.org/confluence/users/removespacenotification.action?spaceKey=OPENWHISK&src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=stop-
watching&jwt=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ4c3JmOjhhYTk4MDg3NWJmMjQ2MzUwMTVjOTI2N2JjOGUwMmY2IiwicXNoIjoiYTgyYWU3YmMzMWVkODdjODdiYmYzMTBkYzU4OGQ0NGUyMmJjNzkwZTE0YWY1MzJmYTk4MDc2ZGIwOTA1ZWVjNiIsImlzcyI6ImNvbmZsdWVuY2Vfbm90aWZpY2F0aW9uc0FSRUgtWFVEMS1QT1FHLUNTQU8iLCJleHAiOjE2MjI3ODgxMDQsImlhdCI6MTYyMjE4MzMwNH0.uApFAE89IK1Xdm7H19IGa0rSV0a3OLlGBb0r0CxgmRo)
| •  
---|---  
[Manage
notifications](https://cwiki.apache.org/confluence/users/editmyemailsettings.action?src=mail&src.mail.product=confluence-
server&src.mail.timestamp=1622183304706&src.mail.notification=com.atlassian.confluence.plugins.confluence-
content-notifications-plugin%3Apage-created-
notification&src.mail.recipient=8aa980875bf24635015c9267bc8e02f6&src.mail.action=manage)  
---  
| ![Confluence logo big](cid:footer-desktop-logo)  
---  
This message was sent by Atlassian Confluence 7.5.0  
![](cid:footer-mobile-logo)  
---