raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

renamed 'nio' package to 'remote'

Browse source
This commit is contained in:
Jonas Bonér 2009-12-16 23:20:15 +01:00
parent 5cefd20104
commit 1508848916
30 changed files with 174 additions and 175 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actors/src/main/scala/actor/ActiveObject.scala
View file

@ -6,8 +6,8 @@ package se.scalablesolutions.akka.actor
import java.net.InetSocketAddress
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.nio.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.remote.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.serialization.Serializer
import se.scalablesolutions.akka.util._

7
akka-actors/src/main/scala/actor/Actor.scala
View file

@ -4,7 +4,6 @@
package se.scalablesolutions.akka.actor
import java.net.InetSocketAddress
import se.scalablesolutions.akka.Config._
import se.scalablesolutions.akka.dispatch._
import se.scalablesolutions.akka.config.{AllForOneStrategy, OneForOneStrategy, FaultHandlingStrategy}
@ -12,10 +11,9 @@ import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.stm.Transaction._
import se.scalablesolutions.akka.stm.TransactionManagement._
import se.scalablesolutions.akka.stm.{StmException, TransactionManagement}
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.nio.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.remote.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.serialization.Serializer
import se.scalablesolutions.akka.util.Helpers.ReadWriteLock
import se.scalablesolutions.akka.util.{HashCode, Logging}
import org.codehaus.aspectwerkz.proxy.Uuid
@ -24,6 +22,7 @@ import org.multiverse.api.ThreadLocalTransaction._
import java.util.{Queue, HashSet}
import java.util.concurrent.ConcurrentLinkedQueue
import java.net.InetSocketAddress
/**
* Implements the Transactor abstraction. E.g. a transactional actor.

2
akka-actors/src/main/scala/nio/LzfCompression.scala → akka-actors/src/main/scala/remote/LzfCompression.scala
View file

@ -2,7 +2,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import org.h2.compress.{LZFInputStream, LZFOutputStream}

4
akka-actors/src/main/scala/nio/RemoteClient.scala → akka-actors/src/main/scala/remote/RemoteClient.scala
View file

@ -2,11 +2,11 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import scala.collection.mutable.HashMap
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.{RemoteRequest, RemoteReply}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.{RemoteRequest, RemoteReply}
import se.scalablesolutions.akka.actor.{Exit, Actor}
import se.scalablesolutions.akka.dispatch.{DefaultCompletableFutureResult, CompletableFutureResult}
import se.scalablesolutions.akka.util.Logging

4
akka-actors/src/main/scala/nio/RemoteProtocolBuilder.scala → akka-actors/src/main/scala/remote/RemoteProtocolBuilder.scala
View file

@ -2,11 +2,11 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import se.scalablesolutions.akka.serialization.Serializable.SBinary
import se.scalablesolutions.akka.serialization.{Serializer, Serializable, SerializationProtocol}
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.{RemoteRequest, RemoteReply}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.{RemoteRequest, RemoteReply}
import com.google.protobuf.{Message, ByteString}

4
akka-actors/src/main/scala/nio/RemoteServer.scala → akka-actors/src/main/scala/remote/RemoteServer.scala
View file

@ -2,7 +2,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import java.lang.reflect.InvocationTargetException
import java.net.InetSocketAddress
@ -10,7 +10,7 @@ import java.util.concurrent.{ConcurrentHashMap, Executors}
import se.scalablesolutions.akka.actor._
import se.scalablesolutions.akka.util._
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.{RemoteReply, RemoteRequest}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.{RemoteReply, RemoteRequest}
import se.scalablesolutions.akka.Config.config
import org.jboss.netty.bootstrap.ServerBootstrap

2
akka-actors/src/main/scala/nio/RequestReply.scala → akka-actors/src/main/scala/remote/RequestReply.scala
View file

@ -2,7 +2,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import java.util.concurrent.atomic.AtomicLong
import stm.Transaction

2
akka-actors/src/test/scala/RemoteActorTest.scala
View file

@ -6,7 +6,7 @@ import junit.framework.TestCase
import org.scalatest.junit.JUnitSuite
import org.junit.{Test, Before, After}
import se.scalablesolutions.akka.nio.{RemoteServer, RemoteClient}
import se.scalablesolutions.akka.remote.{RemoteServer, RemoteClient}
import se.scalablesolutions.akka.dispatch.Dispatchers
object Global {

2
akka-actors/src/test/scala/RemoteSupervisorTest.scala
View file

@ -6,7 +6,7 @@ package se.scalablesolutions.akka.actor
import se.scalablesolutions.akka.serialization.BinaryString
import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.nio.{RemoteNode, RemoteServer}
import se.scalablesolutions.akka.remote.{RemoteNode, RemoteServer}
import se.scalablesolutions.akka.OneWay
import se.scalablesolutions.akka.dispatch.Dispatchers

2
akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/RemoteInMemoryStateTest.java
View file

@ -7,7 +7,7 @@ package se.scalablesolutions.akka.api;
import se.scalablesolutions.akka.Config;
import se.scalablesolutions.akka.actor.ActiveObject;
import se.scalablesolutions.akka.config.ActiveObjectConfigurator;
import se.scalablesolutions.akka.nio.RemoteNode;
import se.scalablesolutions.akka.remote.RemoteNode;
import junit.framework.TestCase;

2
akka-kernel/src/main/scala/Kernel.scala
View file

@ -12,7 +12,7 @@ import javax.ws.rs.core.UriBuilder
import java.io.File
import java.net.URLClassLoader
import se.scalablesolutions.akka.nio.RemoteNode
import se.scalablesolutions.akka.remote.RemoteNode
import se.scalablesolutions.akka.util.Logging
import se.scalablesolutions.akka.actor.ActorRegistry

184
akka-util-java/src/main/java/se/scalablesolutions/akka/nio/protobuf/RemoteProtocol.java → akka-util-java/src/main/java/se/scalablesolutions/akka/remote/protobuf/RemoteProtocol.java
View file

@ -1,6 +1,6 @@
// Generated by the protocol buffer compiler. DO NOT EDIT!
package se.scalablesolutions.akka.nio.protobuf;
package se.scalablesolutions.akka.remote.protobuf;
public final class RemoteProtocol {
private RemoteProtocol() {}
@ -23,12 +23,12 @@ public final class RemoteProtocol {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_descriptor;
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_fieldAccessorTable;
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_fieldAccessorTable;
}
// required uint64 id = 1;
@ -284,57 +284,57 @@ public final class RemoteProtocol {
return size;
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(byte[] data)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(java.io.InputStream input)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseDelimitedFrom(java.io.InputStream input)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeDelimitedFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseDelimitedFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeDelimitedFrom(input, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -344,25 +344,25 @@ public final class RemoteProtocol {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest prototype) {
public static Builder newBuilder(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder> {
private se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest result;
private se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest result;
// Construct using se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.newBuilder()
// Construct using se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest();
builder.result = new se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest();
return builder;
}
protected se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest internalGetResult() {
protected se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest internalGetResult() {
return result;
}
@ -371,7 +371,7 @@ public final class RemoteProtocol {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest();
result = new se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest();
return this;
}
@ -381,24 +381,24 @@ public final class RemoteProtocol {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.getDescriptor();
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.getDescriptor();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest getDefaultInstanceForType() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.getDefaultInstance();
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest getDefaultInstanceForType() {
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest build() {
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest buildParsed()
private se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
@ -407,27 +407,27 @@ public final class RemoteProtocol {
return buildPartial();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest buildPartial() {
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest returnMe = result;
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest) {
return mergeFrom((se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest)other);
if (other instanceof se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest) {
return mergeFrom((se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest other) {
if (other == se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.getDefaultInstance()) return this;
public Builder mergeFrom(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest other) {
if (other == se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.getDefaultInstance()) return this;
if (other.hasId()) {
setId(other.getId());
}
@ -887,11 +887,11 @@ public final class RemoteProtocol {
}
static {
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.getDescriptor();
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.getDescriptor();
}
static {
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internalForceInit();
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internalForceInit();
}
}
@ -911,12 +911,12 @@ public final class RemoteProtocol {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_descriptor;
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_fieldAccessorTable;
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_fieldAccessorTable;
}
// required uint64 id = 1;
@ -1054,57 +1054,57 @@ public final class RemoteProtocol {
return size;
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(byte[] data)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(java.io.InputStream input)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseDelimitedFrom(java.io.InputStream input)
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeDelimitedFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseDelimitedFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeDelimitedFrom(input, extensionRegistry)
.buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply parseFrom(
public static se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@ -1114,25 +1114,25 @@ public final class RemoteProtocol {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply prototype) {
public static Builder newBuilder(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder> {
private se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply result;
private se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply result;
// Construct using se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.newBuilder()
// Construct using se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply();
builder.result = new se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply();
return builder;
}
protected se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply internalGetResult() {
protected se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply internalGetResult() {
return result;
}
@ -1141,7 +1141,7 @@ public final class RemoteProtocol {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply();
result = new se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply();
return this;
}
@ -1151,24 +1151,24 @@ public final class RemoteProtocol {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.getDescriptor();
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.getDescriptor();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply getDefaultInstanceForType() {
return se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.getDefaultInstance();
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply getDefaultInstanceForType() {
return se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply build() {
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply buildParsed()
private se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
@ -1177,27 +1177,27 @@ public final class RemoteProtocol {
return buildPartial();
}
public se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply buildPartial() {
public se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply returnMe = result;
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply) {
return mergeFrom((se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply)other);
if (other instanceof se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply) {
return mergeFrom((se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply other) {
if (other == se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.getDefaultInstance()) return this;
public Builder mergeFrom(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply other) {
if (other == se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.getDefaultInstance()) return this;
if (other.hasId()) {
setId(other.getId());
}
@ -1442,24 +1442,24 @@ public final class RemoteProtocol {
}
static {
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.getDescriptor();
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.getDescriptor();
}
static {
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.internalForceInit();
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.internalForceInit();
}
}
private static com.google.protobuf.Descriptors.Descriptor
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_descriptor;
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_fieldAccessorTable;
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_descriptor;
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_fieldAccessorTable;
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() {
@ -1469,43 +1469,43 @@ public final class RemoteProtocol {
descriptor;
static {
java.lang.String[] descriptorData = {
"\n;se/scalablesolutions/akka/nio/protobuf" +
"/RemoteProtocol.proto\022&se.scalablesoluti" +
"ons.akka.nio.protobuf\"\272\002\n\rRemoteRequest\022" +
"\n\n\002id\030\001 \002(\004\022\020\n\010protocol\030\002 \002(\r\022\017\n\007message" +
"\030\003 \002(\014\022\027\n\017messageManifest\030\004 \001(\014\022\016\n\006metho" +
"d\030\005 \001(\t\022\016\n\006target\030\006 \002(\t\022\014\n\004uuid\030\007 \002(\t\022\017\n" +
"\007timeout\030\010 \002(\004\022\026\n\016supervisorUuid\030\t \001(\t\022\017" +
"\n\007isActor\030\n \002(\010\022\020\n\010isOneWay\030\013 \002(\010\022\021\n\tisE" +
"scaped\030\014 \002(\010\022\026\n\016sourceHostname\030\r \001(\t\022\022\n\n" +
"sourcePort\030\016 \001(\r\022\024\n\014sourceTarget\030\017 \001(\t\022\022",
"\n\nsourceUuid\030\020 \001(\t\"\247\001\n\013RemoteReply\022\n\n\002id" +
"\030\001 \002(\004\022\020\n\010protocol\030\002 \001(\r\022\017\n\007message\030\003 \001(" +
"\014\022\027\n\017messageManifest\030\004 \001(\014\022\021\n\texception\030" +
"\005 \001(\t\022\026\n\016supervisorUuid\030\006 \001(\t\022\017\n\007isActor" +
"\030\007 \002(\010\022\024\n\014isSuccessful\030\010 \002(\010"
"\n>se/scalablesolutions/akka/remote/proto" +
"buf/RemoteProtocol.proto\022)se.scalablesol" +
"utions.akka.remote.protobuf\"\272\002\n\rRemoteRe" +
"quest\022\n\n\002id\030\001 \002(\004\022\020\n\010protocol\030\002 \002(\r\022\017\n\007m" +
"essage\030\003 \002(\014\022\027\n\017messageManifest\030\004 \001(\014\022\016\n" +
"\006method\030\005 \001(\t\022\016\n\006target\030\006 \002(\t\022\014\n\004uuid\030\007 " +
"\002(\t\022\017\n\007timeout\030\010 \002(\004\022\026\n\016supervisorUuid\030\t" +
" \001(\t\022\017\n\007isActor\030\n \002(\010\022\020\n\010isOneWay\030\013 \002(\010\022" +
"\021\n\tisEscaped\030\014 \002(\010\022\026\n\016sourceHostname\030\r \001" +
"(\t\022\022\n\nsourcePort\030\016 \001(\r\022\024\n\014sourceTarget\030\017",
" \001(\t\022\022\n\nsourceUuid\030\020 \001(\t\"\247\001\n\013RemoteReply" +
"\022\n\n\002id\030\001 \002(\004\022\020\n\010protocol\030\002 \001(\r\022\017\n\007messag" +
"e\030\003 \001(\014\022\027\n\017messageManifest\030\004 \001(\014\022\021\n\texce" +
"ption\030\005 \001(\t\022\026\n\016supervisorUuid\030\006 \001(\t\022\017\n\007i" +
"sActor\030\007 \002(\010\022\024\n\014isSuccessful\030\010 \002(\010"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
public com.google.protobuf.ExtensionRegistry assignDescriptors(
com.google.protobuf.Descriptors.FileDescriptor root) {
descriptor = root;
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_descriptor =
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_descriptor =
getDescriptor().getMessageTypes().get(0);
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_fieldAccessorTable = new
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteRequest_descriptor,
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteRequest_descriptor,
new java.lang.String[] { "Id", "Protocol", "Message", "MessageManifest", "Method", "Target", "Uuid", "Timeout", "SupervisorUuid", "IsActor", "IsOneWay", "IsEscaped", "SourceHostname", "SourcePort", "SourceTarget", "SourceUuid", },
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.class,
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.Builder.class);
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_descriptor =
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.class,
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.Builder.class);
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_descriptor =
getDescriptor().getMessageTypes().get(1);
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_fieldAccessorTable = new
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_se_scalablesolutions_akka_nio_protobuf_RemoteReply_descriptor,
internal_static_se_scalablesolutions_akka_remote_protobuf_RemoteReply_descriptor,
new java.lang.String[] { "Id", "Protocol", "Message", "MessageManifest", "Exception", "SupervisorUuid", "IsActor", "IsSuccessful", },
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.class,
se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.Builder.class);
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.class,
se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.Builder.class);
return null;
}
};

4
akka-util-java/src/main/java/se/scalablesolutions/akka/nio/protobuf/RemoteProtocol.proto → akka-util-java/src/main/java/se/scalablesolutions/akka/remote/protobuf/RemoteProtocol.proto
View file

@ -2,12 +2,12 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio.protobuf;
package se.scalablesolutions.akka.remote.protobuf;
/*
Compile with:
cd ./akka-util-java/src/main/java
protoc se/scalablesolutions/akka/nio/protobuf/RemoteProtocol.proto --java_out .
protoc se/scalablesolutions/akka/remote/protobuf/RemoteProtocol.proto --java_out .
*/
message RemoteRequest {

4
docs/scaladocs-akka-actors/actor/ActiveObject.scala.html
View file

@ -15,8 +15,8 @@ package se.scalablesolutions.akka.actor
import java.net.InetSocketAddress
import se.scalablesolutions.akka.dispatch.{MessageDispatcher, FutureResult}
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.nio.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.remote.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.util._

4
docs/scaladocs-akka-actors/actor/Actor.scala.html
View file

@ -21,8 +21,8 @@ import se.scalablesolutions.akka.config.ScalaConfig._
import se.scalablesolutions.akka.stm.Transaction._
import se.scalablesolutions.akka.stm.TransactionManagement._
import se.scalablesolutions.akka.stm.{StmException, TransactionManagement}
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.nio.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest
import se.scalablesolutions.akka.remote.{RemoteProtocolBuilder, RemoteClient, RemoteRequestIdFactory}
import se.scalablesolutions.akka.serialization.Serializer
import se.scalablesolutions.akka.util.Helpers.ReadWriteLock
import se.scalablesolutions.akka.util.Logging

4
docs/scaladocs-akka-actors/all-classes.html
View file

File diff suppressed because one or more lines are too long

2
docs/scaladocs-akka-actors/nio/RemoteClient.scala.html
View file

@ -10,7 +10,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import scala.collection.mutable.HashMap

2
docs/scaladocs-akka-actors/nio/RemoteProtocolBuilder.scala.html
View file

@ -10,7 +10,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import akka.serialization.Serializable.SBinary
import com.google.protobuf.{Message, ByteString}

4
docs/scaladocs-akka-actors/nio/RemoteServer.scala.html
View file

@ -10,7 +10,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import java.lang.reflect.InvocationTargetException
import java.net.InetSocketAddress
@ -18,7 +18,7 @@ import java.util.concurrent.{ConcurrentHashMap, Executors}
import se.scalablesolutions.akka.actor._
import se.scalablesolutions.akka.util._
import se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.{RemoteReply, RemoteRequest}
import se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.{RemoteReply, RemoteRequest}
import se.scalablesolutions.akka.Config.config
import org.jboss.netty.bootstrap.ServerBootstrap

2
docs/scaladocs-akka-actors/nio/RequestReply.scala.html
View file

@ -10,7 +10,7 @@
* Copyright (C) 2009 Scalable Solutions.
*/
package se.scalablesolutions.akka.nio
package se.scalablesolutions.akka.remote
import java.util.concurrent.atomic.AtomicLong
import stm.Transaction

2
docs/scaladocs-akka-actors/overview.html
View file

@ -64,7 +64,7 @@
</dd>
<dt><a href="javascript:selectPackage('se.scalablesolutions.akka.nio')">se.scalablesolutions.akka.nio</a></dt>
<dt><a href="javascript:selectPackage('se.scalablesolutions.akka.remote')">se.scalablesolutions.akka.remote</a></dt>
<dd>

12
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteClient$object.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteClient</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteClient</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteClient</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteClient</span>
<br></br>
object RemoteClient
</h2>
@ -59,7 +59,7 @@
</dl>
</div>
<br></br>
Companion: <a href="./RemoteClient.html" title="se.scalablesolutions.akka.nio.RemoteClient" >RemoteClient</a><br></br>
Companion: <a href="./RemoteClient.html" title="se.scalablesolutions.akka.remote.RemoteClient" >RemoteClient</a><br></br>
Source: <a href="./../../../../nio/RemoteClient.scala.html#Some(29)">RemoteClient.scala(29)</a>
</div>
@ -213,7 +213,7 @@
</td>
<td class="type"><a href="./RemoteClient.html" title="se.scalablesolutions.akka.nio.RemoteClient" >RemoteClient</a></td>
<td class="type"><a href="./RemoteClient.html" title="se.scalablesolutions.akka.remote.RemoteClient" >RemoteClient</a></td>
<td class="remarks">
@ -440,7 +440,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

14
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteClient.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteClient</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteClient</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteClient</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteClient</span>
<br></br>
class RemoteClient
</h2>
@ -59,7 +59,7 @@
</dl>
</div>
<br></br>
Companion: <a href="./RemoteClient$object.html" title="se.scalablesolutions.akka.nio.RemoteClient" >RemoteClient</a><br></br>
Companion: <a href="./RemoteClient$object.html" title="se.scalablesolutions.akka.remote.RemoteClient" >RemoteClient</a><br></br>
Source: <a href="./../../../../nio/RemoteClient.scala.html#Some(54)">RemoteClient.scala(54)</a>
</div>
@ -388,10 +388,10 @@
</td>
</tr><tr class="">
<td class="name">
<b>send</b>..<a name="send(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest)"></a>
<b>send</b>..<a name="send(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest)"></a>
</td>
<td class="signature">
<code class="signature">def send(request : <a href="./protobuf/RemoteProtocol/RemoteRequest.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest" >RemoteRequest</a>)</code>
<code class="signature">def send(request : <a href="./protobuf/RemoteProtocol/RemoteRequest.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest" >RemoteRequest</a>)</code>
</td>
@ -496,7 +496,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteClientHandler.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteClientHandler</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteClientHandler</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteClientHandler</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteClientHandler</span>
<br></br>
class RemoteClientHandler
</h2>
@ -580,7 +580,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteClientPipelineFactory.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteClientPipelineFactory</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteClientPipelineFactory</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteClientPipelineFactory</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteClientPipelineFactory</span>
<br></br>
class RemoteClientPipelineFactory
</h2>
@ -390,7 +390,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

28
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteProtocolBuilder$object.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteProtocolBuilder</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteProtocolBuilder</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteProtocolBuilder</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteProtocolBuilder</span>
<br></br>
object RemoteProtocolBuilder
</h2>
@ -224,10 +224,10 @@
</td>
</tr><tr class="">
<td class="name">
<b>getMessage</b>..<a name="getMessage(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply)"></a>
<b>getMessage</b>..<a name="getMessage(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply)"></a>
</td>
<td class="signature">
<code class="signature">def getMessage(reply : <a href="./protobuf/RemoteProtocol/RemoteReply.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply" >RemoteReply</a>)</code>
<code class="signature">def getMessage(reply : <a href="./protobuf/RemoteProtocol/RemoteReply.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply" >RemoteReply</a>)</code>
</td>
@ -238,10 +238,10 @@
</td>
</tr><tr class="">
<td class="name">
<b>getMessage</b>..<a name="getMessage(se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest)"></a>
<b>getMessage</b>..<a name="getMessage(se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest)"></a>
</td>
<td class="signature">
<code class="signature">def getMessage(request : <a href="./protobuf/RemoteProtocol/RemoteRequest.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest" >RemoteRequest</a>)</code>
<code class="signature">def getMessage(request : <a href="./protobuf/RemoteProtocol/RemoteRequest.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest" >RemoteRequest</a>)</code>
</td>
@ -322,28 +322,28 @@
</td>
</tr><tr class="">
<td class="name">
<b>setMessage</b>..<a name="setMessage(java.lang.Object,se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.Builder)"></a>
<b>setMessage</b>..<a name="setMessage(java.lang.Object,se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.Builder)"></a>
</td>
<td class="signature">
<code class="signature">def setMessage(message : <a href="http://java.sun.com/javase/6/docs/api/java/lang/Object.html" title="java.lang.Object" >Object</a>, builder : <a href="./protobuf/RemoteProtocol/RemoteReply/Builder.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.Builder" >Builder</a>)</code>
<code class="signature">def setMessage(message : <a href="http://java.sun.com/javase/6/docs/api/java/lang/Object.html" title="java.lang.Object" >Object</a>, builder : <a href="./protobuf/RemoteProtocol/RemoteReply/Builder.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.Builder" >Builder</a>)</code>
</td>
<td class="type"><a href="./protobuf/RemoteProtocol/RemoteReply/Builder.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteReply.Builder" >Builder</a></td>
<td class="type"><a href="./protobuf/RemoteProtocol/RemoteReply/Builder.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteReply.Builder" >Builder</a></td>
<td class="remarks">
</td>
</tr><tr class="">
<td class="name">
<b>setMessage</b>..<a name="setMessage(java.lang.Object,se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.Builder)"></a>
<b>setMessage</b>..<a name="setMessage(java.lang.Object,se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.Builder)"></a>
</td>
<td class="signature">
<code class="signature">def setMessage(message : <a href="http://java.sun.com/javase/6/docs/api/java/lang/Object.html" title="java.lang.Object" >Object</a>, builder : <a href="./protobuf/RemoteProtocol/RemoteRequest/Builder.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.Builder" >Builder</a>)</code>
<code class="signature">def setMessage(message : <a href="http://java.sun.com/javase/6/docs/api/java/lang/Object.html" title="java.lang.Object" >Object</a>, builder : <a href="./protobuf/RemoteProtocol/RemoteRequest/Builder.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.Builder" >Builder</a>)</code>
</td>
<td class="type"><a href="./protobuf/RemoteProtocol/RemoteRequest/Builder.html" title="se.scalablesolutions.akka.nio.protobuf.RemoteProtocol.RemoteRequest.Builder" >Builder</a></td>
<td class="type"><a href="./protobuf/RemoteProtocol/RemoteRequest/Builder.html" title="se.scalablesolutions.akka.remote.protobuf.RemoteProtocol.RemoteRequest.Builder" >Builder</a></td>
<td class="remarks">
@ -430,7 +430,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteRequestIdFactory$object.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteRequestIdFactory</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteRequestIdFactory</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteRequestIdFactory</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteRequestIdFactory</span>
<br></br>
object RemoteRequestIdFactory
</h2>
@ -392,7 +392,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteServer$object.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteServer</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteServer</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteServer</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteServer</span>
<br></br>
object RemoteServer
</h2>
@ -510,7 +510,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteServerHandler.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteServerHandler</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteServerHandler</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteServerHandler</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteServerHandler</span>
<br></br>
class RemoteServerHandler
</h2>
@ -580,7 +580,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>

8
docs/scaladocs-akka-actors/se/scalablesolutions/akka/nio/RemoteServerPipelineFactory.html
View file

@ -2,7 +2,7 @@
<html>
<head>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.nio.RemoteServerPipelineFactory</title>
<title>Akka Actors Module 0.6 API : se.scalablesolutions.akka.remote.RemoteServerPipelineFactory</title>
<meta http-equiv="content-type" content="text/html; charset=UTF-8"></meta>
<meta content="scaladoc (1.2)" name="generator"></meta>
<script type="text/javascript" src="./../../../../jquery-1.3.2.js"></script>
@ -23,7 +23,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>
@ -40,7 +40,7 @@
<!-- ======== START OF CLASS DATA ======== -->
<h2>
<span style="font-size:80%">se.scalablesolutions.akka.nio.RemoteServerPipelineFactory</span>
<span style="font-size:80%">se.scalablesolutions.akka.remote.RemoteServerPipelineFactory</span>
<br></br>
class RemoteServerPipelineFactory
</h2>
@ -390,7 +390,7 @@
<tr>
<td class="NavBarCell1">
<a href="./../../../../overview.html">OVERVIEW</a>&nbsp;|&nbsp;
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.nio" >PACKAGE</a> |
<a href="./../../../../overview.html" title="se.scalablesolutions.akka.remote" >PACKAGE</a> |
<a href="#Constructors">CONSTR</a>&nbsp;|&nbsp;
<a href="#Fields">FIELDS</a>&nbsp;|&nbsp;
<a href="#Methods">METHODS</a>