diff options
author | Diego <diegolparra@gmail.com> | 2014-03-15 11:21:44 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-03-15 11:25:02 -0300 |
commit | cc079f18a2c00678397fae0714eb524dfe8961f2 (patch) | |
tree | 24dd0dcc0c63b6aa4aa01b19c7dee524f25de0d4 /kamon-core/src/main/scala/kamon/weaver | |
parent | 75a0a4303c313266d34efd5711fe62ed70ce79b3 (diff) | |
download | Kamon-cc079f18a2c00678397fae0714eb524dfe8961f2.tar.gz Kamon-cc079f18a2c00678397fae0714eb524dfe8961f2.tar.bz2 Kamon-cc079f18a2c00678397fae0714eb524dfe8961f2.zip |
implementation of IMessageHandler interface in order to control Aspectj weaving messages through kamon
Diffstat (limited to 'kamon-core/src/main/scala/kamon/weaver')
-rw-r--r-- | kamon-core/src/main/scala/kamon/weaver/logging/KamonWeaverMessageHandler.scala | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/kamon-core/src/main/scala/kamon/weaver/logging/KamonWeaverMessageHandler.scala b/kamon-core/src/main/scala/kamon/weaver/logging/KamonWeaverMessageHandler.scala new file mode 100644 index 00000000..1aa0aae0 --- /dev/null +++ b/kamon-core/src/main/scala/kamon/weaver/logging/KamonWeaverMessageHandler.scala @@ -0,0 +1,58 @@ +/* + * ========================================================================================= + * Copyright © 2013-2014 the kamon project <http://kamon.io/> + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the + * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, + * either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + * ========================================================================================= + */ + +package kamon.weaver.logging + +import org.aspectj.bridge.{ IMessage, IMessageHandler } +import org.slf4j.LoggerFactory +import com.typesafe.config.ConfigFactory + +class KamonWeaverMessageHandler extends IMessageHandler { + import IMessage._ + + private val log = LoggerFactory.getLogger("AspectJ Weaver") + private val conf = ConfigFactory.load().getConfig("kamon.weaver") + + private val isVerbose = conf.getBoolean("verbose") + private val isDebug = conf.getBoolean("debug") + private val showWeaveInfo = conf.getBoolean("showWeaveInfo") + private val showWarn = conf.getBoolean("showWarn") + + def handleMessage(message: IMessage) = message.getKind match { + case WEAVEINFO if showWeaveInfo ⇒ showMessage(message) + case DEBUG if isDebug ⇒ showMessage(message) + case WARNING if showWarn ⇒ showMessage(message) + case DEBUG if isDebug ⇒ showMessage(message) + case INFO if isVerbose ⇒ showMessage(message) + case ERROR ⇒ showErrorMessage(message) + case _ ⇒ false + } + + def isIgnoring(kind: IMessage.Kind): Boolean = false // We want to see everything. + def dontIgnore(kind: IMessage.Kind) = {} + def ignore(kind: IMessage.Kind) = {} + + private def showMessage(msg: IMessage): Boolean = { + log.info(msg.getMessage) + true + } + + private def showErrorMessage(msg: IMessage): Boolean = { + log.error(msg.getMessage) + true + } +} + |