diff --git a/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorsSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorsSpec.scala index 71a03c6e01..df4048a56e 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorsSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/dispatch/DispatcherActorsSpec.scala @@ -6,8 +6,6 @@ import akka.testkit.AkkaSpec /** * Tests the behavior of the executor based event driven dispatcher when multiple actors are being dispatched on it. - * - * @author Jan Van Besien */ @org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner]) class DispatcherActorsSpec extends AkkaSpec { diff --git a/akka-actor/src/main/scala/akka/AkkaException.scala b/akka-actor/src/main/scala/akka/AkkaException.scala index 0dc3a81728..b8d83abf7a 100644 --- a/akka-actor/src/main/scala/akka/AkkaException.scala +++ b/akka-actor/src/main/scala/akka/AkkaException.scala @@ -14,8 +14,6 @@ import java.net.{ InetAddress, UnknownHostException } *
  • toString that includes exception name, message and uuid
    • *
  • toLongString which also includes the stack trace
    • * - * - * @author Jonas Bonér */ class AkkaException(message: String = "", cause: Throwable = null) extends RuntimeException(message, cause) with Serializable { val uuid = "%s_%s".format(AkkaException.hostname, newUuid) diff --git a/akka-actor/src/main/scala/akka/actor/Actor.scala b/akka-actor/src/main/scala/akka/actor/Actor.scala index 88936f2c86..df1bb0e6a5 100644 --- a/akka-actor/src/main/scala/akka/actor/Actor.scala +++ b/akka-actor/src/main/scala/akka/actor/Actor.scala @@ -167,8 +167,6 @@ object Actor { * *

    * The Actor's own ActorRef is available in the 'self' member variable. - * - * @author Jonas Bonér */ trait Actor { diff --git a/akka-actor/src/main/scala/akka/actor/ActorRef.scala b/akka-actor/src/main/scala/akka/actor/ActorRef.scala index c6f6333822..a5253c440b 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorRef.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorRef.scala @@ -45,8 +45,6 @@ import scala.annotation.tailrec * * * The natural ordering of ActorRef is defined in terms of its [[akka.actor.ActorPath]]. - * - * @author Jonas Bonér */ abstract class ActorRef extends java.lang.Comparable[ActorRef] with Serializable { scalaRef: InternalActorRef ⇒ @@ -214,8 +212,6 @@ private[akka] case object Nobody extends MinimalActorRef { /** * Local (serializable) ActorRef that is used when referencing the Actor on its "home" node. - * - * @author Jonas Bonér */ class LocalActorRef private[akka] ( system: ActorSystemImpl, diff --git a/akka-actor/src/main/scala/akka/actor/Deployer.scala b/akka-actor/src/main/scala/akka/actor/Deployer.scala index 52381dc60b..62b4e6b818 100644 --- a/akka-actor/src/main/scala/akka/actor/Deployer.scala +++ b/akka-actor/src/main/scala/akka/actor/Deployer.scala @@ -30,8 +30,6 @@ trait ActorDeployer { /** * Deployer maps actor paths to actor deployments. - * - * @author Jonas Bonér */ class Deployer(val settings: ActorSystem.Settings, val eventStream: EventStream, val nodename: String) extends ActorDeployer { @@ -267,8 +265,6 @@ class Deployer(val settings: ActorSystem.Settings, val eventStream: EventStream, /** * Simple local deployer, only for internal use. - * - * @author Jonas Bonér */ class LocalDeployer extends ActorDeployer { private val deployments = new ConcurrentHashMap[String, Deploy] diff --git a/akka-actor/src/main/scala/akka/actor/DeploymentConfig.scala b/akka-actor/src/main/scala/akka/actor/DeploymentConfig.scala index 9a3d934f01..03e6aef683 100644 --- a/akka-actor/src/main/scala/akka/actor/DeploymentConfig.scala +++ b/akka-actor/src/main/scala/akka/actor/DeploymentConfig.scala @@ -215,8 +215,6 @@ object DeploymentConfig { * Module holding the programmatic deployment configuration classes. * Defines the deployment specification. * Most values have defaults and can be left out. - * - * @author Jonas Bonér */ class DeploymentConfig(val nodename: String) { diff --git a/akka-actor/src/main/scala/akka/actor/FSM.scala b/akka-actor/src/main/scala/akka/actor/FSM.scala index 9419fccc60..ce7e7f8318 100644 --- a/akka-actor/src/main/scala/akka/actor/FSM.scala +++ b/akka-actor/src/main/scala/akka/actor/FSM.scala @@ -564,7 +564,6 @@ trait FSM[S, D] extends ListenerManagement { /** * Stackable trait for FSM which adds a rolling event log. * - * @author Roland Kuhn * @since 1.2 */ trait LoggingFSM[S, D] extends FSM[S, D] { this: Actor ⇒ diff --git a/akka-actor/src/main/scala/akka/actor/UntypedActor.scala b/akka-actor/src/main/scala/akka/actor/UntypedActor.scala index 8c10a9fcf0..1692396a8f 100644 --- a/akka-actor/src/main/scala/akka/actor/UntypedActor.scala +++ b/akka-actor/src/main/scala/akka/actor/UntypedActor.scala @@ -48,8 +48,6 @@ import akka.dispatch.{ MessageDispatcher, Promise } * } * } * - * - * @author Jonas Bonér */ abstract class UntypedActor extends Actor { @@ -123,7 +121,5 @@ abstract class UntypedActor extends Actor { /** * Factory closure for an UntypedActor, to be used with 'Actors.actorOf(factory)'. - * - * @author Jonas Bonér */ trait UntypedActorFactory extends Creator[Actor] diff --git a/akka-actor/src/main/scala/akka/cluster/ClusterInterface.scala b/akka-actor/src/main/scala/akka/cluster/ClusterInterface.scala index 98a9f9f188..d88b5c3440 100644 --- a/akka-actor/src/main/scala/akka/cluster/ClusterInterface.scala +++ b/akka-actor/src/main/scala/akka/cluster/ClusterInterface.scala @@ -84,8 +84,6 @@ object ChangeListener { /** * Node address holds the node name and the cluster name and can be used as a hash lookup key for a Node instance. - * - * @author Jonas Bonér */ class NodeAddress(val clusterName: String, val nodeName: String) { if ((clusterName eq null) || clusterName == "") throw new NullPointerException("Cluster name must not be null or empty string") @@ -183,8 +181,6 @@ trait NodeMetricsManager { /** * Interface for cluster node. - * - * @author Jonas Bonér */ trait ClusterNode { import ChangeListener._ diff --git a/akka-actor/src/main/scala/akka/dispatch/AbstractDispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/AbstractDispatcher.scala index 8b6f66f4c7..3c9143674d 100644 --- a/akka-actor/src/main/scala/akka/dispatch/AbstractDispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/AbstractDispatcher.scala @@ -17,9 +17,6 @@ import akka.event.EventStream import akka.actor.ActorSystem.Settings import com.typesafe.config.Config -/** - * @author Jonas Bonér - */ final case class Envelope(val message: Any, val sender: ActorRef) { if (message.isInstanceOf[AnyRef] && (message.asInstanceOf[AnyRef] eq null)) throw new InvalidMessageException("Message is null") } @@ -86,9 +83,6 @@ object MessageDispatcher { implicit def defaultDispatcher(implicit system: ActorSystem) = system.dispatcher } -/** - * @author Jonas Bonér - */ abstract class MessageDispatcher(val prerequisites: DispatcherPrerequisites) extends AbstractMessageDispatcher with Serializable { import MessageDispatcher._ diff --git a/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala index 9dd0733328..96477b0d56 100644 --- a/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/BalancingDispatcher.scala @@ -28,8 +28,6 @@ import akka.util.Duration * * @see akka.dispatch.BalancingDispatcher * @see akka.dispatch.Dispatchers - * - * @author Viktor Klang */ class BalancingDispatcher( _prerequisites: DispatcherPrerequisites, diff --git a/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala index 1a40ee23cd..02c84b3099 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala @@ -55,7 +55,6 @@ import java.util.concurrent._ * But the preferred way of creating dispatchers is to use * the {@link akka.dispatch.Dispatchers} factory object. * - * @author Jonas Bonér * @param throughput positive integer indicates the dispatcher will only process so much messages at a time from the * mailbox, without checking the mailboxes of other actors. Zero or negative means the dispatcher * always continues until the mailbox is empty. @@ -153,4 +152,4 @@ abstract class PriorityGenerator extends java.util.Comparator[Envelope] { final def compare(thisMessage: Envelope, thatMessage: Envelope): Int = gen(thisMessage.message) - gen(thatMessage.message) -} \ No newline at end of file +} diff --git a/akka-actor/src/main/scala/akka/dispatch/Dispatchers.scala b/akka-actor/src/main/scala/akka/dispatch/Dispatchers.scala index a75eca9101..ddae9654c4 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Dispatchers.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Dispatchers.scala @@ -53,8 +53,6 @@ case class DefaultDispatcherPrerequisites( * .build(); * *

    - * - * @author Jonas Bonér */ class Dispatchers(val settings: ActorSystem.Settings, val prerequisites: DispatcherPrerequisites) { @@ -199,7 +197,7 @@ class Dispatchers(val settings: ActorSystem.Settings, val prerequisites: Dispatc /* * Creates of obtains a dispatcher from a ConfigMap according to the format below. - * Uses default values from default-dispatcher. + * Uses default values from default-dispatcher. * * my-dispatcher { * type = "Dispatcher" # Must be one of the following diff --git a/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala b/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala index cd33ca57a7..27b8f039d1 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Mailbox.scala @@ -33,9 +33,6 @@ object Mailbox { final val debug = false } -/** - * @author Jonas Bonér - */ abstract class Mailbox(val actor: ActorCell) extends MessageQueue with SystemMessageQueue with Runnable { import Mailbox._ diff --git a/akka-actor/src/main/scala/akka/dispatch/PinnedDispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/PinnedDispatcher.scala index ed0b3cde99..2faffb9f28 100644 --- a/akka-actor/src/main/scala/akka/dispatch/PinnedDispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/PinnedDispatcher.scala @@ -14,8 +14,6 @@ import java.util.concurrent.TimeUnit /** * Dedicates a unique thread for each actor passed in as reference. Served through its messageQueue. - * - * @author Jonas Bonér */ class PinnedDispatcher( _prerequisites: DispatcherPrerequisites, diff --git a/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala b/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala index d26842cc3b..d58444c166 100644 --- a/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala +++ b/akka-actor/src/main/scala/akka/dispatch/ThreadPoolBuilder.scala @@ -144,9 +144,6 @@ case class ThreadPoolConfigDispatcherBuilder(dispatcherFactory: (ThreadPoolConfi def configure(fs: Option[Function[ThreadPoolConfigDispatcherBuilder, ThreadPoolConfigDispatcherBuilder]]*): ThreadPoolConfigDispatcherBuilder = fs.foldLeft(this)((c, f) ⇒ f.map(_(c)).getOrElse(c)) } -/** - * @author Jonas Bonér - */ class MonitorableThreadFactory(val name: String, val daemonic: Boolean = false) extends ThreadFactory { protected val counter = new AtomicLong @@ -157,9 +154,6 @@ class MonitorableThreadFactory(val name: String, val daemonic: Boolean = false) } } -/** - * @author Jonas Bonér - */ object MonitorableThread { val DEFAULT_NAME = "MonitorableThread".intern @@ -168,9 +162,6 @@ object MonitorableThread { val alive = new AtomicInteger } -/** - * @author Jonas Bonér - */ class MonitorableThread(runnable: Runnable, name: String) extends Thread(runnable, name + "-" + MonitorableThread.created.incrementAndGet) { diff --git a/akka-actor/src/main/scala/akka/experimental.scala b/akka-actor/src/main/scala/akka/experimental.scala index cfc976551a..c37197a10d 100644 --- a/akka-actor/src/main/scala/akka/experimental.scala +++ b/akka-actor/src/main/scala/akka/experimental.scala @@ -10,7 +10,6 @@ import annotation.target._ * This annotation marks a feature which is not yet considered stable and may * change or be removed in a future release. * - * @author Roland Kuhn * @since 1.2 */ @getter diff --git a/akka-actor/src/main/scala/akka/routing/ConnectionManager.scala b/akka-actor/src/main/scala/akka/routing/ConnectionManager.scala index 6e45a50cad..572bd986ee 100644 --- a/akka-actor/src/main/scala/akka/routing/ConnectionManager.scala +++ b/akka-actor/src/main/scala/akka/routing/ConnectionManager.scala @@ -26,8 +26,6 @@ trait VersionedIterable[A] { /** * Manages connections (ActorRefs) for a router. - * - * @author Jonas Bonér */ trait ConnectionManager { /** diff --git a/akka-actor/src/main/scala/akka/routing/ConsistentHash.scala b/akka-actor/src/main/scala/akka/routing/ConsistentHash.scala index 3abadd01d8..ead70b4b7a 100644 --- a/akka-actor/src/main/scala/akka/routing/ConsistentHash.scala +++ b/akka-actor/src/main/scala/akka/routing/ConsistentHash.scala @@ -15,8 +15,6 @@ import scala.collection.mutable.{ Buffer, Map } * Consistent Hashing node ring abstraction. * * Not thread-safe, to be used from within an Actor or protected some other way. - * - * @author Jonas Bonér */ class ConsistentHash[T](nodes: Seq[T], replicas: Int) { private val cluster = Buffer[T]() diff --git a/akka-actor/src/main/scala/akka/routing/Routing.scala b/akka-actor/src/main/scala/akka/routing/Routing.scala index 3060f1b847..a71f206959 100644 --- a/akka-actor/src/main/scala/akka/routing/Routing.scala +++ b/akka-actor/src/main/scala/akka/routing/Routing.scala @@ -19,8 +19,6 @@ sealed trait RouterType /** * Used for declarative configuration of Routing. - * - * @author Jonas Bonér */ object RouterType { @@ -92,8 +90,6 @@ object RoutedProps { /** * The Router is responsible for sending a message to one (or more) of its connections. Connections are stored in the * {@link FailureDetector} and each Router should be linked to only one {@link FailureDetector}. - * - * @author Jonas Bonér */ trait Router { @@ -296,8 +292,6 @@ class BroadcastRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeo /** * A DirectRouter a Router that only has a single connected actorRef and forwards all request to that actorRef. - * - * @author Jonas Bonér */ class DirectRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeout) extends BasicRouter { @@ -338,8 +332,6 @@ class DirectRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeout) /** * A Router that randomly selects one of the target connections to send a message to. - * - * @author Jonas Bonér */ class RandomRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeout) extends BasicRouter { import java.security.SecureRandom @@ -380,8 +372,6 @@ class RandomRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeout) /** * A Router that uses round-robin to select a connection. For concurrent calls, round robin is just a best effort. - * - * @author Jonas Bonér */ class RoundRobinRouter(implicit val dispatcher: MessageDispatcher, timeout: Timeout) extends BasicRouter { diff --git a/akka-actor/src/main/scala/akka/serialization/Format.scala b/akka-actor/src/main/scala/akka/serialization/Format.scala index 43177862d4..41f9e9ce73 100644 --- a/akka-actor/src/main/scala/akka/serialization/Format.scala +++ b/akka-actor/src/main/scala/akka/serialization/Format.scala @@ -7,7 +7,6 @@ package akka.serialization import akka.actor.Actor /** - * @author Jonas Bonér * trait Serializer extends scala.Serializable { * @volatile * var classLoader: Option[ClassLoader] = None diff --git a/akka-actor/src/main/scala/akka/util/Convert.scala b/akka-actor/src/main/scala/akka/util/Convert.scala index 278b94f422..42a98f3849 100644 --- a/akka-actor/src/main/scala/akka/util/Convert.scala +++ b/akka-actor/src/main/scala/akka/util/Convert.scala @@ -4,9 +4,6 @@ package akka.util -/** - * @author Jonas Bonér - */ object Convert { def intToBytes(value: Int): Array[Byte] = { diff --git a/akka-actor/src/main/scala/akka/util/Crypt.scala b/akka-actor/src/main/scala/akka/util/Crypt.scala index 2507b0e421..50e8c881a6 100644 --- a/akka-actor/src/main/scala/akka/util/Crypt.scala +++ b/akka-actor/src/main/scala/akka/util/Crypt.scala @@ -6,9 +6,6 @@ package akka.util import java.security.{ MessageDigest, SecureRandom } -/** - * @author Jonas Bonér - */ object Crypt { val hex = "0123456789ABCDEF" val lineSeparator = System.getProperty("line.separator") diff --git a/akka-actor/src/main/scala/akka/util/HashCode.scala b/akka-actor/src/main/scala/akka/util/HashCode.scala index d515a57ec5..40b740bfd6 100644 --- a/akka-actor/src/main/scala/akka/util/HashCode.scala +++ b/akka-actor/src/main/scala/akka/util/HashCode.scala @@ -21,8 +21,6 @@ import java.lang.{ Float ⇒ JFloat, Double ⇒ JDouble } * result * } * - * - * @author Jonas Bonér */ object HashCode { val SEED = 23 diff --git a/akka-actor/src/main/scala/akka/util/Helpers.scala b/akka-actor/src/main/scala/akka/util/Helpers.scala index 830ec28881..c656ab37b1 100644 --- a/akka-actor/src/main/scala/akka/util/Helpers.scala +++ b/akka-actor/src/main/scala/akka/util/Helpers.scala @@ -8,17 +8,14 @@ import java.util.Comparator import scala.annotation.tailrec import java.util.regex.Pattern -/** - * @author Jonas Bonér - */ object Helpers { def makePattern(s: String): Pattern = Pattern.compile("^\\Q" + s.replace("?", "\\E.\\Q").replace("*", "\\E.*\\Q") + "\\E$") def compareIdentityHash(a: AnyRef, b: AnyRef): Int = { /* - * make sure that there is no overflow or underflow in comparisons, so - * that the ordering is actually consistent and you cannot have a + * make sure that there is no overflow or underflow in comparisons, so + * that the ordering is actually consistent and you cannot have a * sequence which cyclically is monotone without end. */ val diff = ((System.identityHashCode(a) & 0xffffffffL) - (System.identityHashCode(b) & 0xffffffffL)) diff --git a/akka-actor/src/main/scala/akka/util/Index.scala b/akka-actor/src/main/scala/akka/util/Index.scala index 3b0f68eabe..b7cb1a74a4 100644 --- a/akka-actor/src/main/scala/akka/util/Index.scala +++ b/akka-actor/src/main/scala/akka/util/Index.scala @@ -13,8 +13,6 @@ import scala.collection.mutable * An implementation of a ConcurrentMultiMap * Adds/remove is serialized over the specified key * Reads are fully concurrent <-- el-cheapo - * - * @author Viktor Klang */ class Index[K, V](val mapSize: Int, val valueComparator: Comparator[V]) { @@ -192,7 +190,5 @@ class Index[K, V](val mapSize: Int, val valueComparator: Comparator[V]) { * An implementation of a ConcurrentMultiMap * Adds/remove is serialized over the specified key * Reads are fully concurrent <-- el-cheapo - * - * @author Viktor Klang */ class ConcurrentMultiMap[K, V](mapSize: Int, valueComparator: Comparator[V]) extends Index[K, V](mapSize, valueComparator) diff --git a/akka-actor/src/main/scala/akka/util/JMX.scala b/akka-actor/src/main/scala/akka/util/JMX.scala index 2c87524843..bcfd5d2477 100644 --- a/akka-actor/src/main/scala/akka/util/JMX.scala +++ b/akka-actor/src/main/scala/akka/util/JMX.scala @@ -9,9 +9,6 @@ import java.lang.management.ManagementFactory import javax.management.{ ObjectInstance, ObjectName, InstanceAlreadyExistsException, InstanceNotFoundException } import akka.actor.ActorSystem -/** - * @author Jonas Bonér - */ object JMX { private val mbeanServer = ManagementFactory.getPlatformMBeanServer diff --git a/akka-actor/src/main/scala/akka/util/ListenerManagement.scala b/akka-actor/src/main/scala/akka/util/ListenerManagement.scala index fad8f5b20a..3efbcbc902 100644 --- a/akka-actor/src/main/scala/akka/util/ListenerManagement.scala +++ b/akka-actor/src/main/scala/akka/util/ListenerManagement.scala @@ -9,8 +9,6 @@ import akka.actor.{ ActorInitializationException, ActorRef } /** * A manager for listener actors. Intended for mixin by observables. - * - * @author Martin Krasser */ trait ListenerManagement { diff --git a/akka-actor/src/main/scala/akka/util/LockUtil.scala b/akka-actor/src/main/scala/akka/util/LockUtil.scala index a31f4434d1..e17507d427 100644 --- a/akka-actor/src/main/scala/akka/util/LockUtil.scala +++ b/akka-actor/src/main/scala/akka/util/LockUtil.scala @@ -7,9 +7,6 @@ package akka.util import java.util.concurrent.locks.{ ReentrantLock } import java.util.concurrent.atomic.{ AtomicBoolean } -/** - * @author Jonas Bonér - */ final class ReentrantGuard { final val lock = new ReentrantLock diff --git a/akka-cluster/src/main/scala/akka/cluster/BookKeeperServer.scala b/akka-cluster/src/main/scala/akka/cluster/BookKeeperServer.scala index e546d2d9af..7c3b57969d 100644 --- a/akka-cluster/src/main/scala/akka/cluster/BookKeeperServer.scala +++ b/akka-cluster/src/main/scala/akka/cluster/BookKeeperServer.scala @@ -21,9 +21,6 @@ entry number it will use MAX_INTEGER). Once all the entries have been processed, new one for its use. */ -/** - * @author Jonas Bonér - */ object BookKeeperServer { val port = 3181 val zkServers = "localhost:2181" diff --git a/akka-cluster/src/main/scala/akka/cluster/Cluster.scala b/akka-cluster/src/main/scala/akka/cluster/Cluster.scala index 356a4461bd..5a3f115ef8 100644 --- a/akka-cluster/src/main/scala/akka/cluster/Cluster.scala +++ b/akka-cluster/src/main/scala/akka/cluster/Cluster.scala @@ -57,8 +57,6 @@ import com.google.protobuf.ByteString /** * JMX MBean for the cluster service. - * - * @author Jonas Bonér */ trait ClusterNodeMBean { @@ -140,8 +138,6 @@ trait ClusterNodeMBean { /** * Module for the Cluster. Also holds global state such as configuration data etc. - * - * @author Jonas Bonér */ object Cluster { val EMPTY_STRING = "".intern @@ -257,8 +253,6 @@ object Cluster { * * /clusterName/'actor-address-to-uuids'/actorAddress/actorUuid * - * - * @author Jonas Bonér */ class DefaultClusterNode private[akka] ( val nodeAddress: NodeAddress, @@ -1601,9 +1595,6 @@ class DefaultClusterNode private[akka] ( } } -/** - * @author Jonas Bonér - */ class MembershipChildListener(self: ClusterNode) extends IZkChildListener with ErrorHandler { def handleChildChange(parentPath: String, currentChilds: JList[String]) { withErrorHandler { @@ -1643,9 +1634,6 @@ class MembershipChildListener(self: ClusterNode) extends IZkChildListener with E } } -/** - * @author Jonas Bonér - */ class StateListener(self: ClusterNode) extends IZkStateListener { def handleStateChanged(state: KeeperState) { state match { @@ -1671,9 +1659,6 @@ class StateListener(self: ClusterNode) extends IZkStateListener { } } -/** - * @author Jonas Bonér - */ trait ErrorHandler { def withErrorHandler[T](body: ⇒ T) = { try { @@ -1686,9 +1671,6 @@ trait ErrorHandler { } } -/** - * @author Jonas Bonér - */ object RemoteClusterDaemon { val Address = "akka-cluster-daemon".intern @@ -1700,8 +1682,6 @@ object RemoteClusterDaemon { * Internal "daemon" actor for cluster internal communication. * * It acts as the brain of the cluster that responds to cluster events (messages) and undertakes action. - * - * @author Jonas Bonér */ class RemoteClusterDaemon(cluster: ClusterNode) extends Actor { diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterActorRef.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterActorRef.scala index a61ca3a6e1..84d23af736 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterActorRef.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterActorRef.scala @@ -21,8 +21,6 @@ import annotation.tailrec /** * ClusterActorRef factory and locator. - * - * @author Jonas Bonér */ object ClusterActorRef { import FailureDetectorType._ @@ -77,8 +75,6 @@ object ClusterActorRef { /** * ActorRef representing a one or many instances of a clustered, load-balanced and sometimes replicated actor * where the instances can reside on other nodes in the cluster. - * - * @author Jonas Bonér */ private[akka] class ClusterActorRef(props: RoutedProps, val address: String) extends AbstractRoutedActorRef(props) { diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterDeployer.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterDeployer.scala index c9ac211821..4cc791fd89 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterDeployer.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterDeployer.scala @@ -24,10 +24,6 @@ import java.util.concurrent.{ CountDownLatch, TimeUnit } /** * A ClusterDeployer is responsible for deploying a Deploy. - * - * FIXME Document: what does Deploy mean? - * - * @author Jonas Bonér */ object ClusterDeployer extends ActorDeployer { val clusterName = Cluster.name diff --git a/akka-cluster/src/main/scala/akka/cluster/TransactionLog.scala b/akka-cluster/src/main/scala/akka/cluster/TransactionLog.scala index 7643a0bd31..7d593437ae 100644 --- a/akka-cluster/src/main/scala/akka/cluster/TransactionLog.scala +++ b/akka-cluster/src/main/scala/akka/cluster/TransactionLog.scala @@ -26,19 +26,12 @@ import java.util.Enumeration // FIXME allow user to choose dynamically between 'async' and 'sync' tx logging (asyncAddEntry(byte[] data, AddCallback cb, Object ctx)) // FIXME clean up old entries in log after doing a snapshot -/** - * @author Jonas Bonér - */ class ReplicationException(message: String, cause: Throwable = null) extends AkkaException(message) { def this(msg: String) = this(msg, null) } /** - * TODO: Explain something about threadsafety. - * * A TransactionLog makes chunks of data durable. - * - * @author Jonas Bonér */ class TransactionLog private ( ledger: LedgerHandle, @@ -352,7 +345,7 @@ class TransactionLog private ( } /** - * @author Jonas Bonér + * TODO: Documentation. */ object TransactionLog { @@ -563,8 +556,6 @@ object TransactionLog { /** * TODO: Documentation. - * - * @author Jonas Bonér */ object LocalBookKeeperEnsemble { private val isRunning = new Switch(false) diff --git a/akka-cluster/src/test/scala/akka/cluster/sample/ComputeGridSample.scala b/akka-cluster/src/test/scala/akka/cluster/sample/ComputeGridSample.scala index 4cf7a7010f..7a3a9ca606 100644 --- a/akka-cluster/src/test/scala/akka/cluster/sample/ComputeGridSample.scala +++ b/akka-cluster/src/test/scala/akka/cluster/sample/ComputeGridSample.scala @@ -7,9 +7,6 @@ package akka.cluster.sample import akka.cluster._ import akka.dispatch.Futures -/** - * @author Jonas Bonér - */ object ComputeGridSample { //sample.cluster.ComputeGridSample.fun2 diff --git a/akka-durable-mailboxes/akka-mailboxes-common/src/main/scala/akka/actor/mailbox/DurableMailbox.scala b/akka-durable-mailboxes/akka-mailboxes-common/src/main/scala/akka/actor/mailbox/DurableMailbox.scala index 7bb01a06f0..96cb764615 100644 --- a/akka-durable-mailboxes/akka-mailboxes-common/src/main/scala/akka/actor/mailbox/DurableMailbox.scala +++ b/akka-durable-mailboxes/akka-mailboxes-common/src/main/scala/akka/actor/mailbox/DurableMailbox.scala @@ -33,9 +33,6 @@ class DurableMailboxException private[akka] (message: String, cause: Throwable) def this(message: String) = this(message, null) } -/** - * @author Jonas Bonér - */ abstract class DurableMailbox(owner: ActorCell) extends Mailbox(owner) with DefaultSystemMessageQueue { import DurableExecutableMailboxConfig._ @@ -76,9 +73,6 @@ trait DurableMessageSerialization { } -/** - * @author Jonas Bonér - */ abstract class DurableMailboxType(mailboxFQN: String) extends MailboxType { val constructorSignature = Array[Class[_]](classOf[ActorCell]) @@ -117,8 +111,6 @@ case class FqnDurableMailboxType(mailboxFQN: String) extends DurableMailboxType( * Configurator for the DurableMailbox * Do not forget to specify the "storage", valid values are "redis", "beanstalkd", "zookeeper", "mongodb", "file", * or a full class name of the Mailbox implementation. - * - * @author Jonas Bonér */ class DurableMailboxConfigurator { // TODO PN #896: when and how is this class supposed to be used? Can we remove it? diff --git a/akka-durable-mailboxes/akka-redis-mailbox/src/main/scala/akka/actor/mailbox/RedisBasedMailbox.scala b/akka-durable-mailboxes/akka-redis-mailbox/src/main/scala/akka/actor/mailbox/RedisBasedMailbox.scala index 7bb1c5a5dc..f937be09e0 100644 --- a/akka-durable-mailboxes/akka-redis-mailbox/src/main/scala/akka/actor/mailbox/RedisBasedMailbox.scala +++ b/akka-durable-mailboxes/akka-redis-mailbox/src/main/scala/akka/actor/mailbox/RedisBasedMailbox.scala @@ -13,9 +13,6 @@ import akka.actor.ActorRef class RedisBasedMailboxException(message: String) extends AkkaException(message) -/** - * @author Jonas Bonér - */ class RedisBasedMailbox(val owner: ActorCell) extends DurableMailbox(owner) with DurableMessageSerialization { private val settings = RedisBasedMailboxExtension(owner.system) diff --git a/akka-durable-mailboxes/akka-zookeeper-mailbox/src/main/scala/akka/actor/mailbox/ZooKeeperBasedMailbox.scala b/akka-durable-mailboxes/akka-zookeeper-mailbox/src/main/scala/akka/actor/mailbox/ZooKeeperBasedMailbox.scala index c5efa62358..3a50b93e93 100644 --- a/akka-durable-mailboxes/akka-zookeeper-mailbox/src/main/scala/akka/actor/mailbox/ZooKeeperBasedMailbox.scala +++ b/akka-durable-mailboxes/akka-zookeeper-mailbox/src/main/scala/akka/actor/mailbox/ZooKeeperBasedMailbox.scala @@ -17,9 +17,6 @@ import akka.actor.ActorRef class ZooKeeperBasedMailboxException(message: String) extends AkkaException(message) -/** - * @author Jonas Bonér - */ class ZooKeeperBasedMailbox(val owner: ActorCell) extends DurableMailbox(owner) with DurableMessageSerialization { private val settings = ZooKeeperBasedMailboxExtension(owner.system) diff --git a/akka-kernel/src/main/scala/akka/kernel/Kernel.scala b/akka-kernel/src/main/scala/akka/kernel/Kernel.scala index 8bb66acca4..74c90b47c7 100644 --- a/akka-kernel/src/main/scala/akka/kernel/Kernel.scala +++ b/akka-kernel/src/main/scala/akka/kernel/Kernel.scala @@ -23,8 +23,6 @@ object Main { /** * The Akka Kernel, is used to start And postStop Akka in standalone/kernel mode. - * - * @author Jonas Bonér */ object Kernel extends AkkaLoader { diff --git a/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala b/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala index 2cad35c948..23994337f1 100644 --- a/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala +++ b/akka-remote/src/main/scala/akka/remote/NetworkEventStream.scala @@ -12,8 +12,6 @@ import akka.actor.ActorSystemImpl /** * Stream of all kinds of network events, remote failure and connection events, cluster failure and connection events etc. * Also provides API for sender listener management. - * - * @author Jonas Bonér */ object NetworkEventStream { diff --git a/akka-remote/src/main/scala/akka/remote/Remote.scala b/akka-remote/src/main/scala/akka/remote/Remote.scala index 49d85c030f..072c45b4c4 100644 --- a/akka-remote/src/main/scala/akka/remote/Remote.scala +++ b/akka-remote/src/main/scala/akka/remote/Remote.scala @@ -25,8 +25,6 @@ import akka.serialization.SerializationExtension /** * Remote module - contains remote client and server config, remote server instance, remote daemon, remote dispatchers etc. - * - * @author Jonas Bonér */ class Remote(val system: ActorSystemImpl, val nodename: String) { @@ -101,8 +99,6 @@ class Remote(val system: ActorSystemImpl, val nodename: String) { * Internal system "daemon" actor for remote internal communication. * * It acts as the brain of the remote that responds to system remote events (messages) and undertakes action. - * - * @author Jonas Bonér */ class RemoteSystemDaemon(remote: Remote) extends Actor { diff --git a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala index 44b756dfba..2b1c1bb528 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala @@ -26,8 +26,6 @@ import akka.serialization.SerializationExtension /** * Remote ActorRefProvider. Starts up actor on remote node and creates a RemoteActorRef representing it. - * - * @author Jonas Bonér */ class RemoteActorRefProvider( val systemName: String, @@ -257,8 +255,6 @@ class RemoteActorRefProvider( /** * Remote ActorRef that is used when referencing the Actor on a different node than its "home" node. * This reference is network-aware (remembers its origin) and immutable. - * - * @author Jonas Bonér */ private[akka] case class RemoteActorRef private[akka] ( provider: ActorRefProvider, diff --git a/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala b/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala index 7b739b6199..aa3f577ba4 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteConnectionManager.scala @@ -16,8 +16,6 @@ import java.util.concurrent.atomic.AtomicReference /** * Remote connection manager, manages remote connections, e.g. RemoteActorRef's. - * - * @author Jonas Bonér */ class RemoteConnectionManager( system: ActorSystem, diff --git a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala index b412fcdf3e..04e2483345 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala @@ -112,9 +112,7 @@ class PassiveRemoteClient(val currentChannel: Channel, } /** - * RemoteClient represents a connection to an Akka node. Is used to send messages to remote actors on the node. - * - * @author Jonas Bonér + * RemoteClient represents a connection to an Akka node. Is used to send messages to remote actors on the node. */ class ActiveRemoteClient private[akka] ( remoteSupport: NettyRemoteSupport, @@ -241,9 +239,6 @@ class ActiveRemoteClient private[akka] ( private[akka] def resetReconnectionTimeWindow = reconnectionTimeWindowStart = 0L } -/** - * @author Jonas Bonér - */ class ActiveRemoteClientPipelineFactory( name: String, bootstrap: ClientBootstrap, @@ -264,9 +259,6 @@ class ActiveRemoteClientPipelineFactory( } } -/** - * @author Jonas Bonér - */ @ChannelHandler.Sharable class ActiveRemoteClientHandler( val name: String, @@ -536,9 +528,6 @@ class NettyRemoteServer(val remoteSupport: NettyRemoteSupport, val loader: Optio } } -/** - * @author Jonas Bonér - */ class RemoteServerPipelineFactory( val name: String, val openChannels: ChannelGroup, @@ -587,9 +576,6 @@ class RemoteServerAuthenticationHandler(secureCookie: Option[String]) extends Si } } -/** - * @author Jonas Bonér - */ @ChannelHandler.Sharable class RemoteServerHandler( val name: String, diff --git a/akka-remote/src/main/scala/akka/serialization/Compression.scala b/akka-remote/src/main/scala/akka/serialization/Compression.scala index 3602b81438..df79fe1f22 100644 --- a/akka-remote/src/main/scala/akka/serialization/Compression.scala +++ b/akka-remote/src/main/scala/akka/serialization/Compression.scala @@ -4,14 +4,8 @@ package akka.serialization -/** - * @author Jonas Bonér - */ object Compression { - /** - * @author Jonas Bonér - */ object LZF { import voldemort.store.compress.lzf._ def compress(bytes: Array[Byte]): Array[Byte] = LZFEncoder encode bytes diff --git a/akka-slf4j/src/main/scala/akka/event/slf4j/SLF4J.scala b/akka-slf4j/src/main/scala/akka/event/slf4j/SLF4J.scala index 73d37a838b..91f3123634 100644 --- a/akka-slf4j/src/main/scala/akka/event/slf4j/SLF4J.scala +++ b/akka-slf4j/src/main/scala/akka/event/slf4j/SLF4J.scala @@ -11,8 +11,6 @@ import akka.actor._ /** * Base trait for all classes that wants to be able use the SLF4J logging infrastructure. - * - * @author Jonas Bonér */ trait SLF4JLogging { @transient @@ -29,8 +27,6 @@ object Logger { * * The thread in which the logging was performed is captured in * Mapped Diagnostic Context (MDC) with attribute name "sourceThread". - * - * @author Jonas Bonér */ class Slf4jEventHandler extends Actor with SLF4JLogging { diff --git a/akka-spring/src/main/scala/akka/spring/ActorFactoryBean.scala b/akka-spring/src/main/scala/akka/spring/ActorFactoryBean.scala index 41d46a4118..84b3be952e 100644 --- a/akka-spring/src/main/scala/akka/spring/ActorFactoryBean.scala +++ b/akka-spring/src/main/scala/akka/spring/ActorFactoryBean.scala @@ -33,7 +33,6 @@ class AkkaBeansException(message: String, cause: Throwable) extends BeansExcepti * @author michaelkober * @author Johan Rask * @author Martin Krasser - * @author Jonas Bonér */ class ActorFactoryBean extends AbstractFactoryBean[AnyRef] with ApplicationContextAware { import AkkaSpringConfigurationTags._ diff --git a/scripts/generate_config_with_secure_cookie.sh b/scripts/generate_config_with_secure_cookie.sh index 6959697d0d..6ef3d06e91 100755 --- a/scripts/generate_config_with_secure_cookie.sh +++ b/scripts/generate_config_with_secure_cookie.sh @@ -7,9 +7,6 @@ exec scala "$0" "$@" */ import java.security.{MessageDigest, SecureRandom} -/** - * @author Jonas Bonér - */ object Crypt { val hex = "0123456789ABCDEF" val lineSeparator = System.getProperty("line.separator") @@ -19,8 +16,8 @@ object Crypt { def md5(text: String): String = md5(unifyLineSeparator(text).getBytes("ASCII")) def md5(bytes: Array[Byte]): String = digest(bytes, MessageDigest.getInstance("MD5")) - - def sha1(text: String): String = sha1(unifyLineSeparator(text).getBytes("ASCII")) + + def sha1(text: String): String = sha1(unifyLineSeparator(text).getBytes("ASCII")) def sha1(bytes: Array[Byte]): String = digest(bytes, MessageDigest.getInstance("SHA1")) @@ -33,8 +30,8 @@ object Crypt { def digest(bytes: Array[Byte], md: MessageDigest): String = { md.update(bytes) hexify(md.digest) - } - + } + def hexify(bytes: Array[Byte]): String = { val builder = new StringBuilder bytes.foreach { byte => builder.append(hex.charAt((byte & 0xF) >> 4)).append(hex.charAt(byte & 0xF)) }