You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2011/05/17 23:17:54 UTC
svn commit: r1104562 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
Author: tabish
Date: Tue May 17 21:17:53 2011
New Revision: 1104562
URL: http://svn.apache.org/viewvc?rev=1104562&view=rev
Log:
Make the ulimit warn message a bit more readable.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala?rev=1104562&r1=1104561&r2=1104562&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala Tue May 17 21:17:53 2011
@@ -193,7 +193,7 @@ object Broker extends Log {
* @author <a href="http://hiramchirino.com">Hiram Chirino</a>
*/
class Broker() extends BaseService {
-
+
import Broker._
var tmp: File = _
@@ -208,7 +208,7 @@ class Broker() extends BaseService {
val dispatch_queue = createQueue("broker")
def id = "default"
-
+
val connection_id_counter = new LongCounter
var key_storage:KeyStorage = _
@@ -416,7 +416,7 @@ class Broker() extends BaseService {
}
if( l < min_limit ) {
- console_log.warn("Please increase the process file limit using 'ulimit -n %d' or configure lower the connection limits on the broker connectors.", min_limit)
+ console_log.warn("Please increase the process file limit using 'ulimit -n %d' or configure lower connection limits on the broker connectors.", min_limit)
}
}
} catch {