plugin to work with SelectiveQueue is routingOut is set to priority

dream/plugins/SetRoutingOut.py

+from copy import copy
+import json
+import time
+import random
+import operator
+from datetime import datetime
+
+from dream.plugins import plugin
+
+class SetRoutingOut(plugin.InputPreparationPlugin):
+    """ Input preparation
+        takes a model and if the queue is set to priority sets the class to selectiveQueue
+    """
+
+    def preprocess(self, data):
+        nodes=data['graph']['node']
+        for node_id,node in nodes.iteritems():
+            if node.get('_class',None)=='Dream.Queue':
+                if node.get('routingOut',None)=='Priority':
+                    node['_class']="dream.simulation.Examples.SelectiveQueue.SelectiveQueue"
+        return data
+    
\ No newline at end of file

dream/simulation/Examples/GUI_models/DemoPackage2.json

@@ -236,6 +236,10 @@
         {
           "_class": "dream.plugins.WIPSpreadsheet.WIPSpreadsheet", 
           "input_id": "WIPdata"
+        },
+        {
+          "_class": "dream.plugins.SetRoutingOut.SetRoutingOut", 
+          "input_id": "routingOut"
         }
       ]
     }, 

dream/simulation/Examples/SelectiveQueue.py

+from dream.simulation.imports import Queue
+
+#the custom queue
+class SelectiveQueue(Queue):
+    #override so that it chooses receiver according to priority
+    def selectReceiver(self,possibleReceivers=[]):
+        # sort the receivers according to their priority
+        possibleReceivers.sort(key=lambda x: x.priority, reverse=True)
+        if possibleReceivers[0].canAccept():
+            return possibleReceivers[0]
+        elif possibleReceivers[1].canAccept():
+            return possibleReceivers[1]
+        return None