cleaning up (263901a0) · Commits · github_fork / Clip

fnordmetric-enterprise/src/FnordMetric.scala

+5 −5

Original line number	Diff line number	Diff line
		@@ -83,17 +83,17 @@ object FnordMetric {
		def boot = try {
		FnordMetric.log("Booting...")

		val tcp_server = if (CONFIG contains 'tcp_port)
		new TCPServer(
		CONFIG('tcp_port).toInt,
		CONFIG('tcp_threads).toInt)

		val ws_server = if (CONFIG contains 'websocket_port)
		new HTTPServer(
		CONFIG('websocket_port).toInt,
		CONFIG('websocket_threads).toInt,
		new WebSocketHandler)

		val tcp_server = if (CONFIG contains 'tcp_port)
		new TCPServer(
		CONFIG('tcp_port).toInt,
		CONFIG('tcp_threads).toInt)

		} catch {
		case e: Exception => exception(e, true)
		}

+2 −0

Original line number	Diff line number	Diff line
		@@ -29,6 +29,8 @@ class TCPServer(port: Int, threads: Int) {
		bootstrap.setPipelineFactory(new TCPServerPipelineFactory)
		bootstrap.bind(new InetSocketAddress(port))

		FnordMetric.log("Listening on tcp://0.0.0.0:" + port)

		class TCPServerPipelineFactory extends ChannelPipelineFactory {

		override def getPipeline : ChannelPipeline = {