1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*
* =========================================================================================
* Copyright © 2013-2015 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
import _root_.akka.actor
import _root_.akka.actor._
import kamon.util.logger.LazyLogger
import org.aspectj.lang.ProceedingJoinPoint
import org.aspectj.lang.annotation.{Around, Aspect, Pointcut}
private[kamon] object ModuleLoader extends ExtensionId[ModuleLoaderExtension] with ExtensionIdProvider {
def lookup(): ExtensionId[_ <: actor.Extension] = ModuleLoader
def createExtension(system: ExtendedActorSystem): ModuleLoaderExtension = new ModuleLoaderExtension(system)
}
private[kamon] class ModuleLoaderExtension(system: ExtendedActorSystem) extends Kamon.Extension {
val log = LazyLogger(getClass)
val settings = ModuleLoaderSettings(system)
if (settings.modulesRequiringAspectJ.nonEmpty && !isAspectJPresent && settings.showAspectJMissingWarning)
logAspectJWeaverMissing(settings.modulesRequiringAspectJ)
// Force initialization of all modules marked with auto-start.
settings.availableModules.filter(_.startInfo.nonEmpty).foreach {
case AvailableModuleInfo(name, requiresAJ, Some(ModuleStartInfo(autoStart, extensionClass))) if autoStart ⇒
system.dynamicAccess.getObjectFor[ExtensionId[Kamon.Extension]](extensionClass).map { moduleID ⇒
log.debug(s"Auto starting the [$name] module.")
moduleID.get(system)
} recover {
case th: Throwable ⇒ log.error(s"Failed to auto start the [$name] module.", th)
}
case other ⇒
}
// When AspectJ is present the kamon.supervisor.AspectJPresent aspect will make this return true.
def isAspectJPresent: Boolean = false
def logAspectJWeaverMissing(modulesRequiringAspectJ: List[AvailableModuleInfo]): Unit = {
val moduleNames = modulesRequiringAspectJ.map(_.name).mkString(", ")
val weaverMissingMessage =
"""
|
| ___ _ ___ _ _ ___ ___ _ _
| / _ \ | | |_ | | | | | | \/ |(_) (_)
|/ /_\ \ ___ _ __ ___ ___ | |_ | | | | | | ___ __ _ __ __ ___ _ __ | . . | _ ___ ___ _ _ __ __ _
|| _ |/ __|| '_ \ / _ \ / __|| __| | | | |/\| | / _ \ / _` |\ \ / // _ \| '__| | |\/| || |/ __|/ __|| || '_ \ / _` |
|| | | |\__ \| |_) || __/| (__ | |_ /\__/ / \ /\ /| __/| (_| | \ V /| __/| | | | | || |\__ \\__ \| || | | || (_| |
|\_| |_/|___/| .__/ \___| \___| \__|\____/ \/ \/ \___| \__,_| \_/ \___||_| \_| |_/|_||___/|___/|_||_| |_| \__, |
| | | __/ |
| |_| |___/
|
| It seems like your application was not started with the -javaagent:/path-to-aspectj-weaver.jar option but Kamon detected
| the following modules which require AspectJ to work properly:
|
""".stripMargin + moduleNames +
"""
|
| If you need help on setting up the aspectj weaver go to http://kamon.io/introduction/get-started/ for more info. On the
| other hand, if you are sure that you do not need or do not want to use the weaver then you can disable this error message
| by changing the kamon.show-aspectj-missing-warning setting in your configuration file.
|
""".stripMargin
log.error(weaverMissingMessage)
}
}
private[kamon] case class AvailableModuleInfo(name: String, requiresAspectJ: Boolean, startInfo: Option[ModuleStartInfo])
private[kamon] case class ModuleStartInfo(autoStart: Boolean, extensionClass: String)
private[kamon] case class ModuleLoaderSettings(showAspectJMissingWarning: Boolean, availableModules: List[AvailableModuleInfo]) {
val modulesRequiringAspectJ = availableModules.filter(_.requiresAspectJ)
}
private[kamon] object ModuleLoaderSettings {
def apply(system: ActorSystem): ModuleLoaderSettings = {
import kamon.util.ConfigTools.Syntax
val config = system.settings.config.getConfig("kamon.modules")
val showAspectJMissingWarning = system.settings.config.getBoolean("kamon.show-aspectj-missing-warning")
val modules = config.firstLevelKeys
val availableModules = modules.map { moduleName ⇒
val moduleConfig = config.getConfig(moduleName)
val requiresAspectJ = moduleConfig.getBoolean("requires-aspectj")
val startInfo =
if (moduleConfig.hasPath("auto-start") && moduleConfig.hasPath("extension-class"))
Some(ModuleStartInfo(moduleConfig.getBoolean("auto-start"), moduleConfig.getString("extension-class")))
else
None
AvailableModuleInfo(moduleName, requiresAspectJ, startInfo)
} toList
ModuleLoaderSettings(showAspectJMissingWarning, availableModules)
}
}
@Aspect
private[kamon] class AspectJPresent {
@Pointcut("execution(* kamon.ModuleLoaderExtension.isAspectJPresent())")
def isAspectJPresentAtModuleSupervisor(): Unit = {}
@Around("isAspectJPresentAtModuleSupervisor()")
def aroundIsAspectJPresentAtModuleSupervisor(pjp: ProceedingJoinPoint): Boolean = true
}
|
