Skip to content

Commit

Permalink
DOC: Formatting issues, see #2723
Browse files Browse the repository at this point in the history
  • Loading branch information
patriknw committed Nov 22, 2012
1 parent 287aeac commit 15abee8
Show file tree
Hide file tree
Showing 13 changed files with 56 additions and 30 deletions.
7 changes: 5 additions & 2 deletions akka-actor/src/main/scala/akka/actor/Scheduler.scala
Expand Up @@ -15,6 +15,7 @@ import akka.util.internal._
import concurrent.ExecutionContext
import scala.concurrent.duration.FiniteDuration

// The Scheduler trait is included in the documentation. KEEP THE LINES SHORT!!!
//#scheduler
/**
* An Akka scheduler service. This one needs one special behavior: if
Expand Down Expand Up @@ -50,7 +51,8 @@ trait Scheduler {
*/
def schedule(
initialDelay: FiniteDuration,
interval: FiniteDuration)(f: Unit)(implicit executor: ExecutionContext): Cancellable
interval: FiniteDuration)(f: Unit)(
implicit executor: ExecutionContext): Cancellable

/**
* Schedules a function to be run repeatedly with an initial delay and
Expand Down Expand Up @@ -93,7 +95,8 @@ trait Scheduler {
* Scala API
*/
def scheduleOnce(
delay: FiniteDuration)(f: Unit)(implicit executor: ExecutionContext): Cancellable
delay: FiniteDuration)(f: Unit)(
implicit executor: ExecutionContext): Cancellable
}
//#scheduler

Expand Down
Expand Up @@ -46,7 +46,8 @@ class TimerBasedThrottlerSpec extends TestKit(ActorSystem("TimerBasedThrottlerSp
}
}))
// The throttler for this example, setting the rate
val throttler = system.actorOf(Props(new TimerBasedThrottler(3 msgsPer (1.second.dilated))))
val throttler = system.actorOf(Props(new TimerBasedThrottler(
3 msgsPer (1.second.dilated))))
// Set the target
throttler ! SetTarget(Some(printer))
// These three messages will be sent to the echoer immediately
Expand Down
3 changes: 2 additions & 1 deletion akka-docs/rst/cluster/cluster-usage-java.rst
Expand Up @@ -482,7 +482,8 @@ Run it without parameters to see instructions about how to use the script::
is-available - Checks if the member node is available
is-running - Checks if the member node is running
has-convergence - Checks if there is a cluster convergence
Where the <node-url> should be on the format of 'akka://actor-system-name@hostname:port'
Where the <node-url> should be on the format of
'akka://actor-system-name@hostname:port'

Examples: bin/akka-cluster localhost:9999 is-available
bin/akka-cluster localhost:9999 join akka://MySystem@darkstar:2552
Expand Down
3 changes: 2 additions & 1 deletion akka-docs/rst/cluster/cluster-usage-scala.rst
Expand Up @@ -496,7 +496,8 @@ Run it without parameters to see instructions about how to use the script::
is-available - Checks if the member node is available
is-running - Checks if the member node is running
has-convergence - Checks if there is a cluster convergence
Where the <node-url> should be on the format of 'akka://actor-system-name@hostname:port'
Where the <node-url> should be on the format of
'akka://actor-system-name@hostname:port'

Examples: bin/akka-cluster localhost:9999 is-available
bin/akka-cluster localhost:9999 join akka://MySystem@darkstar:2552
Expand Down
2 changes: 2 additions & 0 deletions akka-docs/rst/java/camel.rst
Expand Up @@ -388,6 +388,8 @@ URI options

The following URI options are supported:

.. tabularcolumns:: |l|l|l|L|

+--------------+----------+---------+------------------------------------------------+
| Name | Type | Default | Description |
+==============+==========+=========+================================================+
Expand Down
3 changes: 2 additions & 1 deletion akka-docs/rst/modules/durable-mailbox.rst
Expand Up @@ -96,7 +96,8 @@ added in concrete subclass like this:

To use ``DurableMailboxDocSpec`` add this dependency::

"com.typesafe.akka" %% "akka-mailboxes-common" % "@version@" classifier "test" @crossString@
"com.typesafe.akka" %% "akka-mailboxes-common" %
"@version@" classifier "test" @crossString@

For more inspiration you can look at the old implementations based on Redis, MongoDB, Beanstalk,
and ZooKeeper, which can be found in Akka git repository tag
Expand Down
3 changes: 2 additions & 1 deletion akka-docs/rst/project/links.rst
Expand Up @@ -73,7 +73,8 @@ Make sure that you add the repository to the sbt resolvers::

Define the library dependencies with the timestamp as version. For example::

libraryDependencies += "com.typesafe.akka" % "akka-remote_@binVersion@" % "2.1-20121016-001042"
libraryDependencies += "com.typesafe.akka" % "akka-remote_@binVersion@" %
"2.1-20121016-001042"

maven definition of snapshot repository
---------------------------------------
Expand Down
45 changes: 28 additions & 17 deletions akka-docs/rst/project/migration-guide-2.0.x-2.1.x.rst
Expand Up @@ -66,8 +66,9 @@ Java:
::
// Use this Actors' Dispatcher as ExecutionContext
getContext().system().scheduler().scheduleOnce(Duration.create(10, TimeUnit.SECONDS)",
getSelf(), new Reconnect(), getContext().getDispatcher());
getContext().system().scheduler().scheduleOnce(Duration.create(
10, TimeUnit.SECONDS), getSelf(), new Reconnect(),
getContext().getDispatcher());

// Use ActorSystem's default Dispatcher as ExecutionContext
system.scheduler().scheduleOnce(Duration.create(50, TimeUnit.MILLISECONDS),
Expand Down Expand Up @@ -394,13 +395,17 @@ This has been done to enable OSGi bundles that don't have conflicting package na

Change the following import statements. Please note that the serializers are often referenced from configuration.

================================================ =======================================================
Search Replace with
================================================ =======================================================
``akka.routing.RemoteRouterConfig`` ``akka.remote.routing.RemoteRouterConfig``
``akka.serialization.ProtobufSerializer`` ``akka.remote.serialization.ProtobufSerializer``
``akka.serialization.DaemonMsgCreateSerializer`` ``akka.remote.serialization.DaemonMsgCreateSerializer``
================================================ =======================================================
Search -> Replace with::

akka.routing.RemoteRouterConfig ->
akka.remote.routing.RemoteRouterConfig

akka.serialization.ProtobufSerializer ->
akka.remote.serialization.ProtobufSerializer

akka.serialization.DaemonMsgCreateSerializer ->
akka.remote.serialization.DaemonMsgCreateSerializer


Package Name Changes in Durable Mailboxes
=========================================
Expand All @@ -410,14 +415,20 @@ This has been done to enable OSGi bundles that don't have conflicting package na

Change the following import statements. Please note that the ``FileBasedMailboxType`` is often referenced from configuration.

================================================ =========================================================
Search Replace with
================================================ =========================================================
``akka.actor.mailbox.FileBasedMailboxType`` ``akka.actor.mailbox.filebased.FileBasedMailboxType``
``akka.actor.mailbox.FileBasedMailboxSettings`` ``akka.actor.mailbox.filebased.FileBasedMailboxSettings``
``akka.actor.mailbox.FileBasedMessageQueue`` ``akka.actor.mailbox.filebased.FileBasedMessageQueue``
``akka.actor.mailbox.filequeue.*`` ``akka.actor.mailbox.filebased.filequeue.*``
================================================ =========================================================
Search -> Replace with::

akka.actor.mailbox.FileBasedMailboxType ->
akka.actor.mailbox.filebased.FileBasedMailboxType

akka.actor.mailbox.FileBasedMailboxSettings ->
akka.actor.mailbox.filebased.FileBasedMailboxSettings

akka.actor.mailbox.FileBasedMessageQueue ->
akka.actor.mailbox.filebased.FileBasedMessageQueue

akka.actor.mailbox.filequeue.* ->
akka.actor.mailbox.filebased.filequeue.*

Actor Receive Timeout
=====================
Expand Down
2 changes: 2 additions & 0 deletions akka-docs/rst/scala/camel.rst
Expand Up @@ -384,6 +384,8 @@ URI options

The following URI options are supported:

.. tabularcolumns:: |l|l|l|L|

+--------------+----------+---------+-------------------------------------------+
| Name | Type | Default | Description |
+==============+==========+=========+===========================================+
Expand Down
3 changes: 2 additions & 1 deletion akka-docs/rst/scala/code/docs/zeromq/ZeromqDocSpec.scala
Expand Up @@ -29,7 +29,8 @@ object ZeromqDocSpec {

class HealthProbe extends Actor {

val pubSocket = ZeroMQExtension(context.system).newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:1235"))
val pubSocket = ZeroMQExtension(context.system).newSocket(SocketType.Pub,
Bind("tcp://127.0.0.1:1235"))
val memory = ManagementFactory.getMemoryMXBean
val os = ManagementFactory.getOperatingSystemMXBean
val ser = SerializationExtension(context.system)
Expand Down
3 changes: 2 additions & 1 deletion akka-remote/src/main/resources/reference.conf
Expand Up @@ -218,7 +218,8 @@ akka {
# Example: ["TLS_RSA_WITH_AES_128_CBC_SHA", "TLS_RSA_WITH_AES_256_CBC_SHA"]
# You need to install the JCE Unlimited Strength Jurisdiction Policy
# Files to use AES 256.
# More info here: http://docs.oracle.com/javase/7/docs/technotes/guides/security/SunProviders.html#SunJCEProvider
# More info here:
# http://docs.oracle.com/javase/7/docs/technotes/guides/security/SunProviders.html#SunJCEProvider
enabled-algorithms = ["TLS_RSA_WITH_AES_128_CBC_SHA"]

# Using /dev/./urandom is only necessary when using SHA1PRNG on Linux to
Expand Down
6 changes: 3 additions & 3 deletions akka-sbt-plugin/sample/project/Build.scala
Expand Up @@ -52,7 +52,7 @@ object Dependency {
val Akka = "2.1-SNAPSHOT"
}

val akkaKernel = "com.typesafe.akka" %% "akka-kernel" % V.Akka cross CrossVersion.full
val akkaSlf4j = "com.typesafe.akka" %% "akka-slf4j" % V.Akka cross CrossVersion.full
val logback = "ch.qos.logback" % "logback-classic" % "1.0.0"
val akkaKernel = "com.typesafe.akka" %% "akka-kernel" % V.Akka cross CrossVersion.full
val akkaSlf4j = "com.typesafe.akka" %% "akka-slf4j" % V.Akka cross CrossVersion.full
val logback = "ch.qos.logback" % "logback-classic" % "1.0.0"
}
3 changes: 2 additions & 1 deletion akka-testkit/src/main/resources/reference.conf
Expand Up @@ -15,7 +15,8 @@ akka {
# all required messages are received
filter-leeway = 3s

# duration to wait in expectMsg and friends outside of within() block by default
# duration to wait in expectMsg and friends outside of within() block
# by default
single-expect-default = 3s

# The timeout that is added as an implicit by DefaultTimeout trait
Expand Down

0 comments on commit 15abee8

Please sign in to comment.