Merge pull request #799 from wagnert/1.0

1.0
appserver-io · May 11, 2015 · 9e1f3e6 · 9e1f3e6
2 parents 4a19232 + 884a728
commit 9e1f3e6
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/AppserverIo/Appserver/MessageQueue/QueueWorker.php b/src/AppserverIo/Appserver/MessageQueue/QueueWorker.php
@@ -292,8 +292,8 @@ public function run()
                                 // count messages in queue
                                 $inQueue = sizeof($jobsExecuting);
 
-                                // we only process 50 jobs in parallel
-                                if ($inQueue < 50) {
+                                // we only process 200 jobs in parallel
+                                if ($inQueue < 200) {
                                     // start the job and add it to the internal array
                                     $jobsExecuting[$message->getMessageId()] = new Job(clone $message, $application);
 
@@ -302,7 +302,7 @@ public function run()
 
                                 } else {
                                     // log a message that queue is actually full
-                                    $application->getInitialContext()->getSystemLogger()->debug(
+                                    $application->getInitialContext()->getSystemLogger()->info(
                                         sprintf('Job queue full - (%d jobs/%d msg wait)', $inQueue, sizeof($messages))
                                     );
                                 }