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

Removed trailing whitespace

Browse source
This commit is contained in:
Jonas Bonér 2011-10-28 15:55:15 +02:00
parent e9dfaf7ed8
commit 9bf9cea0d9
35 changed files with 1008 additions and 1008 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/java/akka/dispatch/JavaFutureTests.java
View file

@ -18,7 +18,7 @@ import scala.Some;
import scala.Right; import scala.Right;
public class JavaFutureTests { public class JavaFutureTests {
private final AkkaApplication app = new AkkaApplication(); private final AkkaApplication app = new AkkaApplication();
private final Timeout t = app.AkkaConfig().ActorTimeout(); private final Timeout t = app.AkkaConfig().ActorTimeout();
private final FutureFactory ff = new FutureFactory(app.dispatcher(), t); private final FutureFactory ff = new FutureFactory(app.dispatcher(), t);

10
akka-actor/src/main/java/com/eaio/uuid/UUIDGen.java
View file

@ -74,7 +74,7 @@ public final class UUIDGen {
* The last time value. Used to remove duplicate UUIDs. * The last time value. Used to remove duplicate UUIDs.
*/ */
private final static AtomicLong lastTime = new AtomicLong(Long.MIN_VALUE); private final static AtomicLong lastTime = new AtomicLong(Long.MIN_VALUE);
/** /**
* The cached MAC address. * The cached MAC address.
*/ */
@ -233,11 +233,11 @@ public final class UUIDGen {
public static long newTime() { public static long newTime() {
return createTime(System.currentTimeMillis()); return createTime(System.currentTimeMillis());
} }
/** /**
* Creates a new time field from the given timestamp. Note that even identical * Creates a new time field from the given timestamp. Note that even identical
* values of <code>currentTimeMillis</code> will produce different time fields. * values of <code>currentTimeMillis</code> will produce different time fields.
* *
* @param currentTimeMillis the timestamp * @param currentTimeMillis the timestamp
* @return a new time value * @return a new time value
* @see UUID#getTime() * @see UUID#getTime()
@ -275,10 +275,10 @@ public final class UUIDGen {
return time; return time;
} }
/** /**
* Returns the MAC address. Not guaranteed to return anything. * Returns the MAC address. Not guaranteed to return anything.
* *
* @return the MAC address, may be <code>null</code> * @return the MAC address, may be <code>null</code>
*/ */
public static String getMACAddress() { public static String getMACAddress() {

8
akka-actor/src/main/scala/akka/actor/FaultHandling.scala
View file

@ -21,8 +21,8 @@ case class ChildRestartStats(var maxNrOfRetriesCount: Int = 0, var restartTimeWi
private def retriesInWindowOkay(retries: Int, window: Int): Boolean = { private def retriesInWindowOkay(retries: Int, window: Int): Boolean = {
/* /*
* Simple window algorithm: window is kept open for a certain time * Simple window algorithm: window is kept open for a certain time
* after a restart and if enough restarts happen during this time, it * after a restart and if enough restarts happen during this time, it
* denies. Otherwise window closes and the scheme starts over. * denies. Otherwise window closes and the scheme starts over.
*/ */
val retriesDone = maxNrOfRetriesCount + 1 val retriesDone = maxNrOfRetriesCount + 1
@ -181,7 +181,7 @@ case class AllForOneStrategy(decider: FaultHandlingStrategy.Decider,
if (withinTimeRange < 0) None else Some(withinTimeRange)) if (withinTimeRange < 0) None else Some(withinTimeRange))
/* /*
* this is a performance optimization to avoid re-allocating the pairs upon * this is a performance optimization to avoid re-allocating the pairs upon
* every call to requestRestartPermission, assuming that strategies are shared * every call to requestRestartPermission, assuming that strategies are shared
* across actors and thus this field does not take up much space * across actors and thus this field does not take up much space
*/ */
@ -238,7 +238,7 @@ case class OneForOneStrategy(decider: FaultHandlingStrategy.Decider,
if (withinTimeRange < 0) None else Some(withinTimeRange)) if (withinTimeRange < 0) None else Some(withinTimeRange))
/* /*
* this is a performance optimization to avoid re-allocating the pairs upon * this is a performance optimization to avoid re-allocating the pairs upon
* every call to requestRestartPermission, assuming that strategies are shared * every call to requestRestartPermission, assuming that strategies are shared
* across actors and thus this field does not take up much space * across actors and thus this field does not take up much space
*/ */

2
akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala
View file

@ -153,4 +153,4 @@ abstract class PriorityGenerator extends java.util.Comparator[Envelope] {
final def compare(thisMessage: Envelope, thatMessage: Envelope): Int = final def compare(thisMessage: Envelope, thatMessage: Envelope): Int =
gen(thisMessage.message) - gen(thatMessage.message) gen(thisMessage.message) - gen(thatMessage.message)
} }

2
akka-actor/src/main/scala/akka/event/DeathWatch.scala
View file

@ -16,4 +16,4 @@ trait DeathWatch extends ActorEventBus with ActorClassifier {
type Event = Terminated type Event = Terminated
protected final def classify(event: Event): Classifier = event.actor protected final def classify(event: Event): Classifier = event.actor
} }

2
akka-actor/src/main/scala/akka/event/EventBus.scala
View file

@ -262,4 +262,4 @@ trait ActorClassification { self: ActorEventBus with ActorClassifier ⇒
def subscribe(subscriber: Subscriber, to: Classifier): Boolean = associate(to, subscriber) def subscribe(subscriber: Subscriber, to: Classifier): Boolean = associate(to, subscriber)
def unsubscribe(subscriber: Subscriber, from: Classifier): Boolean = dissociate(from, subscriber) def unsubscribe(subscriber: Subscriber, from: Classifier): Boolean = dissociate(from, subscriber)
def unsubscribe(subscriber: Subscriber): Unit = dissociate(subscriber) def unsubscribe(subscriber: Subscriber): Unit = dissociate(subscriber)
} }

2
akka-actor/src/main/scala/akka/event/EventBusJavaAPI.scala
View file

@ -35,4 +35,4 @@ abstract class ScanningEventBus[E, S, C] extends EventBus with ScanningClassific
abstract class ActorEventBus[E] extends akka.event.ActorEventBus with ActorClassification with ActorClassifier { abstract class ActorEventBus[E] extends akka.event.ActorEventBus with ActorClassification with ActorClassifier {
} }

6
akka-actor/src/main/scala/akka/event/Logging.scala
View file

@ -11,7 +11,7 @@ import akka.actor.Actor
trait Logging { trait Logging {
/* /*
* implement these as precisely as needed/possible: always returning true * implement these as precisely as needed/possible: always returning true
* just makes the notify... methods be called every time. * just makes the notify... methods be called every time.
*/ */
def isErrorEnabled: Boolean def isErrorEnabled: Boolean
@ -20,7 +20,7 @@ trait Logging {
def isDebugEnabled: Boolean def isDebugEnabled: Boolean
/* /*
* These actually implement the passing on of the messages to be logged. * These actually implement the passing on of the messages to be logged.
* Will not be called if is...Enabled returned false. * Will not be called if is...Enabled returned false.
*/ */
protected def notifyError(cause: Throwable, message: String) protected def notifyError(cause: Throwable, message: String)
@ -105,4 +105,4 @@ class EventHandlerLogging(val eventHandler: EventHandler, val loggingInstance: A
protected def notifyDebug(message: String) { eventHandler.notifyListeners(Debug(loggingInstance, message)) } protected def notifyDebug(message: String) { eventHandler.notifyListeners(Debug(loggingInstance, message)) }
} }

2
akka-cluster/src/multi-jvm/scala/akka/cluster/reflogic/ClusterActorRefCleanupMultiJvmNode3.conf
View file

@ -3,4 +3,4 @@ akka.event-handler-level = "WARNING"
akka.actor.deployment.service-test.router = "round-robin" akka.actor.deployment.service-test.router = "round-robin"
akka.actor.deployment.service-test.cluster.preferred-nodes = ["node:node2","node:node3"] akka.actor.deployment.service-test.cluster.preferred-nodes = ["node:node2","node:node3"]
akka.actor.deployment.service-test.nr-of-instances = 2 akka.actor.deployment.service-test.nr-of-instances = 2
akka.remote.client.buffering.retry-message-send-on-failure = false akka.remote.client.buffering.retry-message-send-on-failure = false

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/direct/failover/DirectRoutingFailoverMultiJvmNode1.conf
View file

@ -2,4 +2,4 @@ akka.enabled-modules = ["cluster"]
akka.event-handlers = ["akka.testkit.TestEventListener"] akka.event-handlers = ["akka.testkit.TestEventListener"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "direct" akka.actor.deployment.service-hello.router = "direct"
akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node2"] akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node2"]

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/random/homenode/HomeNodeMultiJvmNode1.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-node1.cluster.preferred-nodes = ["node:node1"]
akka.actor.deployment.service-node1.nr-of-instances = 1 akka.actor.deployment.service-node1.nr-of-instances = 1
akka.actor.deployment.service-node2.router = "random" akka.actor.deployment.service-node2.router = "random"
akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"] akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"]
akka.actor.deployment.service-node2.nr-of-instances = 1 akka.actor.deployment.service-node2.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/random/homenode/HomeNodeMultiJvmNode2.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-node1.cluster.preferred-nodes = ["node:node1"]
akka.actor.deployment.service-node1.nr-of-instances = 1 akka.actor.deployment.service-node1.nr-of-instances = 1
akka.actor.deployment.service-node2.router = "random" akka.actor.deployment.service-node2.router = "random"
akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"] akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"]
akka.actor.deployment.service-node2.nr-of-instances = 1 akka.actor.deployment.service-node2.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/random/replicationfactor_1/Random1ReplicaMultiJvmNode1.conf
View file

@ -1,4 +1,4 @@
akka.enabled-modules = ["cluster"] akka.enabled-modules = ["cluster"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "random" akka.actor.deployment.service-hello.router = "random"
akka.actor.deployment.service-hello.nr-of-instances = 1 akka.actor.deployment.service-hello.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/failover/RoundRobinFailoverMultiJvmNode1.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-hello.router = "round-robin"
akka.actor.deployment.service-hello.nr-of-instances = 2 akka.actor.deployment.service-hello.nr-of-instances = 2
akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"] akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"]
akka.cluster.include-ref-node-in-replica-set = on akka.cluster.include-ref-node-in-replica-set = on
akka.actor.timeout = 30 akka.actor.timeout = 30

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/failover/RoundRobinFailoverMultiJvmNode2.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-hello.router = "round-robin"
akka.actor.deployment.service-hello.nr-of-instances = 2 akka.actor.deployment.service-hello.nr-of-instances = 2
akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"] akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"]
akka.cluster.include-ref-node-in-replica-set = on akka.cluster.include-ref-node-in-replica-set = on
akka.actor.timeout = 30 akka.actor.timeout = 30

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/failover/RoundRobinFailoverMultiJvmNode3.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-hello.router = "round-robin"
akka.actor.deployment.service-hello.nr-of-instances = 2 akka.actor.deployment.service-hello.nr-of-instances = 2
akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"] akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1","node:node3"]
akka.cluster.include-ref-node-in-replica-set = on akka.cluster.include-ref-node-in-replica-set = on
akka.actor.timeout = 30 akka.actor.timeout = 30

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/homenode/HomeNodeMultiJvmNode1.conf
View file

@ -5,4 +5,4 @@ akka.actor.deployment.service-node1.cluster.preferred-nodes = ["node:node1"]
akka.actor.deployment.service-node1.nr-of-instances = 1 akka.actor.deployment.service-node1.nr-of-instances = 1
akka.actor.deployment.service-node2.router = "round-robin" akka.actor.deployment.service-node2.router = "round-robin"
akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"] akka.actor.deployment.service-node2.cluster.preferred-nodes = ["node:node2"]
akka.actor.deployment.service-node2.nr-of-instances = 1 akka.actor.deployment.service-node2.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/homenode/HomeNodeMultiJvmNode2.conf
View file

@ -2,4 +2,4 @@ akka.enabled-modules = ["cluster"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "round-robin" akka.actor.deployment.service-hello.router = "round-robin"
akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1"] akka.actor.deployment.service-hello.cluster.preferred-nodes = ["node:node1"]
akka.actor.deployment.service-hello.nr-of-instances = 1 akka.actor.deployment.service-hello.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/roundrobin/replicationfactor_1/RoundRobin1ReplicaMultiJvmNode1.conf
View file

@ -1,4 +1,4 @@
akka.enabled-modules = ["cluster"] akka.enabled-modules = ["cluster"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "round-robin" akka.actor.deployment.service-hello.router = "round-robin"
akka.actor.deployment.service-hello.nr-of-instances = 1 akka.actor.deployment.service-hello.nr-of-instances = 1

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/scattergather/failover/ScatterGatherFailoverMultiJvmNode1.conf
View file

@ -3,4 +3,4 @@ akka.event-handlers = ["akka.testkit.TestEventListener"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "akka.routing.ScatterGatherFirstCompletedRouter" akka.actor.deployment.service-hello.router = "akka.routing.ScatterGatherFirstCompletedRouter"
akka.actor.deployment.service-hello.nr-of-instances = 2 akka.actor.deployment.service-hello.nr-of-instances = 2
akka.actor.timeout = 30 akka.actor.timeout = 30

2
akka-cluster/src/multi-jvm/scala/akka/cluster/routing/scattergather/failover/ScatterGatherFailoverMultiJvmNode2.conf
View file

@ -3,4 +3,4 @@ akka.event-handlers = ["akka.testkit.TestEventListener"]
akka.event-handler-level = "WARNING" akka.event-handler-level = "WARNING"
akka.actor.deployment.service-hello.router = "akka.routing.ScatterGatherFirstCompletedRouter" akka.actor.deployment.service-hello.router = "akka.routing.ScatterGatherFirstCompletedRouter"
akka.actor.deployment.service-hello.nr-of-instances = 2 akka.actor.deployment.service-hello.nr-of-instances = 2
akka.actor.timeout = 30 akka.actor.timeout = 30

188
akka-durable-mailboxes/akka-mailboxes-common/src/main/java/akka/actor/mailbox/MailboxProtocol.java
View file

@ -10,20 +10,20 @@ public final class MailboxProtocol {
} }
public interface DurableMailboxMessageProtocolOrBuilder public interface DurableMailboxMessageProtocolOrBuilder
extends com.google.protobuf.MessageOrBuilder { extends com.google.protobuf.MessageOrBuilder {
// required string ownerAddress = 1; // required string ownerAddress = 1;
boolean hasOwnerAddress(); boolean hasOwnerAddress();
String getOwnerAddress(); String getOwnerAddress();
// optional string senderAddress = 2; // optional string senderAddress = 2;
boolean hasSenderAddress(); boolean hasSenderAddress();
String getSenderAddress(); String getSenderAddress();
// optional .UuidProtocol futureUuid = 3; // optional .UuidProtocol futureUuid = 3;
boolean hasFutureUuid(); boolean hasFutureUuid();
akka.actor.mailbox.MailboxProtocol.UuidProtocol getFutureUuid(); akka.actor.mailbox.MailboxProtocol.UuidProtocol getFutureUuid();
akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder getFutureUuidOrBuilder(); akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder getFutureUuidOrBuilder();
// required bytes message = 4; // required bytes message = 4;
boolean hasMessage(); boolean hasMessage();
com.google.protobuf.ByteString getMessage(); com.google.protobuf.ByteString getMessage();
@ -36,26 +36,26 @@ public final class MailboxProtocol {
super(builder); super(builder);
} }
private DurableMailboxMessageProtocol(boolean noInit) {} private DurableMailboxMessageProtocol(boolean noInit) {}
private static final DurableMailboxMessageProtocol defaultInstance; private static final DurableMailboxMessageProtocol defaultInstance;
public static DurableMailboxMessageProtocol getDefaultInstance() { public static DurableMailboxMessageProtocol getDefaultInstance() {
return defaultInstance; return defaultInstance;
} }
public DurableMailboxMessageProtocol getDefaultInstanceForType() { public DurableMailboxMessageProtocol getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_descriptor; return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_fieldAccessorTable; return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_fieldAccessorTable;
} }
private int bitField0_; private int bitField0_;
// required string ownerAddress = 1; // required string ownerAddress = 1;
public static final int OWNERADDRESS_FIELD_NUMBER = 1; public static final int OWNERADDRESS_FIELD_NUMBER = 1;
@ -68,7 +68,7 @@ public final class MailboxProtocol {
if (ref instanceof String) { if (ref instanceof String) {
return (String) ref; return (String) ref;
} else { } else {
com.google.protobuf.ByteString bs = com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref; (com.google.protobuf.ByteString) ref;
String s = bs.toStringUtf8(); String s = bs.toStringUtf8();
if (com.google.protobuf.Internal.isValidUtf8(bs)) { if (com.google.protobuf.Internal.isValidUtf8(bs)) {
@ -80,7 +80,7 @@ public final class MailboxProtocol {
private com.google.protobuf.ByteString getOwnerAddressBytes() { private com.google.protobuf.ByteString getOwnerAddressBytes() {
java.lang.Object ref = ownerAddress_; java.lang.Object ref = ownerAddress_;
if (ref instanceof String) { if (ref instanceof String) {
com.google.protobuf.ByteString b = com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((String) ref); com.google.protobuf.ByteString.copyFromUtf8((String) ref);
ownerAddress_ = b; ownerAddress_ = b;
return b; return b;
@ -88,7 +88,7 @@ public final class MailboxProtocol {
return (com.google.protobuf.ByteString) ref; return (com.google.protobuf.ByteString) ref;
} }
} }
// optional string senderAddress = 2; // optional string senderAddress = 2;
public static final int SENDERADDRESS_FIELD_NUMBER = 2; public static final int SENDERADDRESS_FIELD_NUMBER = 2;
private java.lang.Object senderAddress_; private java.lang.Object senderAddress_;
@ -100,7 +100,7 @@ public final class MailboxProtocol {
if (ref instanceof String) { if (ref instanceof String) {
return (String) ref; return (String) ref;
} else { } else {
com.google.protobuf.ByteString bs = com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref; (com.google.protobuf.ByteString) ref;
String s = bs.toStringUtf8(); String s = bs.toStringUtf8();
if (com.google.protobuf.Internal.isValidUtf8(bs)) { if (com.google.protobuf.Internal.isValidUtf8(bs)) {
@ -112,7 +112,7 @@ public final class MailboxProtocol {
private com.google.protobuf.ByteString getSenderAddressBytes() { private com.google.protobuf.ByteString getSenderAddressBytes() {
java.lang.Object ref = senderAddress_; java.lang.Object ref = senderAddress_;
if (ref instanceof String) { if (ref instanceof String) {
com.google.protobuf.ByteString b = com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((String) ref); com.google.protobuf.ByteString.copyFromUtf8((String) ref);
senderAddress_ = b; senderAddress_ = b;
return b; return b;
@ -120,7 +120,7 @@ public final class MailboxProtocol {
return (com.google.protobuf.ByteString) ref; return (com.google.protobuf.ByteString) ref;
} }
} }
// optional .UuidProtocol futureUuid = 3; // optional .UuidProtocol futureUuid = 3;
public static final int FUTUREUUID_FIELD_NUMBER = 3; public static final int FUTUREUUID_FIELD_NUMBER = 3;
private akka.actor.mailbox.MailboxProtocol.UuidProtocol futureUuid_; private akka.actor.mailbox.MailboxProtocol.UuidProtocol futureUuid_;
@ -133,7 +133,7 @@ public final class MailboxProtocol {
public akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder getFutureUuidOrBuilder() { public akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder getFutureUuidOrBuilder() {
return futureUuid_; return futureUuid_;
} }
// required bytes message = 4; // required bytes message = 4;
public static final int MESSAGE_FIELD_NUMBER = 4; public static final int MESSAGE_FIELD_NUMBER = 4;
private com.google.protobuf.ByteString message_; private com.google.protobuf.ByteString message_;
@ -143,7 +143,7 @@ public final class MailboxProtocol {
public com.google.protobuf.ByteString getMessage() { public com.google.protobuf.ByteString getMessage() {
return message_; return message_;
} }
private void initFields() { private void initFields() {
ownerAddress_ = ""; ownerAddress_ = "";
senderAddress_ = ""; senderAddress_ = "";
@ -154,7 +154,7 @@ public final class MailboxProtocol {
public final boolean isInitialized() { public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized; byte isInitialized = memoizedIsInitialized;
if (isInitialized != -1) return isInitialized == 1; if (isInitialized != -1) return isInitialized == 1;
if (!hasOwnerAddress()) { if (!hasOwnerAddress()) {
memoizedIsInitialized = 0; memoizedIsInitialized = 0;
return false; return false;
@ -172,7 +172,7 @@ public final class MailboxProtocol {
memoizedIsInitialized = 1; memoizedIsInitialized = 1;
return true; return true;
} }
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -190,12 +190,12 @@ public final class MailboxProtocol {
} }
getUnknownFields().writeTo(output); getUnknownFields().writeTo(output);
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) return size; if (size != -1) return size;
size = 0; size = 0;
if (((bitField0_ & 0x00000001) == 0x00000001)) { if (((bitField0_ & 0x00000001) == 0x00000001)) {
size += com.google.protobuf.CodedOutputStream size += com.google.protobuf.CodedOutputStream
@ -217,14 +217,14 @@ public final class MailboxProtocol {
memoizedSerializedSize = size; memoizedSerializedSize = size;
return size; return size;
} }
private static final long serialVersionUID = 0L; private static final long serialVersionUID = 0L;
@java.lang.Override @java.lang.Override
protected java.lang.Object writeReplace() protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException { throws java.io.ObjectStreamException {
return super.writeReplace(); return super.writeReplace();
} }
public static akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol parseFrom( public static akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol parseFrom(
com.google.protobuf.ByteString data) com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
@ -291,14 +291,14 @@ public final class MailboxProtocol {
return newBuilder().mergeFrom(input, extensionRegistry) return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed(); .buildParsed();
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol prototype) { public static Builder newBuilder(akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
@java.lang.Override @java.lang.Override
protected Builder newBuilderForType( protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessage.BuilderParent parent) { com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@ -312,17 +312,17 @@ public final class MailboxProtocol {
getDescriptor() { getDescriptor() {
return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_descriptor; return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_fieldAccessorTable; return akka.actor.mailbox.MailboxProtocol.internal_static_DurableMailboxMessageProtocol_fieldAccessorTable;
} }
// Construct using akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.newBuilder() // Construct using akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.newBuilder()
private Builder() { private Builder() {
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
} }
private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) { private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) {
super(parent); super(parent);
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
@ -335,7 +335,7 @@ public final class MailboxProtocol {
private static Builder create() { private static Builder create() {
return new Builder(); return new Builder();
} }
public Builder clear() { public Builder clear() {
super.clear(); super.clear();
ownerAddress_ = ""; ownerAddress_ = "";
@ -352,20 +352,20 @@ public final class MailboxProtocol {
bitField0_ = (bitField0_ & ~0x00000008); bitField0_ = (bitField0_ & ~0x00000008);
return this; return this;
} }
public Builder clone() { public Builder clone() {
return create().mergeFrom(buildPartial()); return create().mergeFrom(buildPartial());
} }
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDescriptor(); return akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDescriptor();
} }
public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol getDefaultInstanceForType() { public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol getDefaultInstanceForType() {
return akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDefaultInstance(); return akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDefaultInstance();
} }
public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol build() { public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol build() {
akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = buildPartial(); akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = buildPartial();
if (!result.isInitialized()) { if (!result.isInitialized()) {
@ -373,7 +373,7 @@ public final class MailboxProtocol {
} }
return result; return result;
} }
private akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol buildParsed() private akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = buildPartial(); akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = buildPartial();
@ -383,7 +383,7 @@ public final class MailboxProtocol {
} }
return result; return result;
} }
public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol buildPartial() { public akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol buildPartial() {
akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = new akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol(this); akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol result = new akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol(this);
int from_bitField0_ = bitField0_; int from_bitField0_ = bitField0_;
@ -412,7 +412,7 @@ public final class MailboxProtocol {
onBuilt(); onBuilt();
return result; return result;
} }
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol) { if (other instanceof akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol) {
return mergeFrom((akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol)other); return mergeFrom((akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol)other);
@ -421,7 +421,7 @@ public final class MailboxProtocol {
return this; return this;
} }
} }
public Builder mergeFrom(akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol other) { public Builder mergeFrom(akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol other) {
if (other == akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDefaultInstance()) return this; if (other == akka.actor.mailbox.MailboxProtocol.DurableMailboxMessageProtocol.getDefaultInstance()) return this;
if (other.hasOwnerAddress()) { if (other.hasOwnerAddress()) {
@ -439,25 +439,25 @@ public final class MailboxProtocol {
this.mergeUnknownFields(other.getUnknownFields()); this.mergeUnknownFields(other.getUnknownFields());
return this; return this;
} }
public final boolean isInitialized() { public final boolean isInitialized() {
if (!hasOwnerAddress()) { if (!hasOwnerAddress()) {
return false; return false;
} }
if (!hasMessage()) { if (!hasMessage()) {
return false; return false;
} }
if (hasFutureUuid()) { if (hasFutureUuid()) {
if (!getFutureUuid().isInitialized()) { if (!getFutureUuid().isInitialized()) {
return false; return false;
} }
} }
return true; return true;
} }
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -508,9 +508,9 @@ public final class MailboxProtocol {
} }
} }
} }
private int bitField0_; private int bitField0_;
// required string ownerAddress = 1; // required string ownerAddress = 1;
private java.lang.Object ownerAddress_ = ""; private java.lang.Object ownerAddress_ = "";
public boolean hasOwnerAddress() { public boolean hasOwnerAddress() {
@ -546,7 +546,7 @@ public final class MailboxProtocol {
ownerAddress_ = value; ownerAddress_ = value;
onChanged(); onChanged();
} }
// optional string senderAddress = 2; // optional string senderAddress = 2;
private java.lang.Object senderAddress_ = ""; private java.lang.Object senderAddress_ = "";
public boolean hasSenderAddress() { public boolean hasSenderAddress() {
@ -582,7 +582,7 @@ public final class MailboxProtocol {
senderAddress_ = value; senderAddress_ = value;
onChanged(); onChanged();
} }
// optional .UuidProtocol futureUuid = 3; // optional .UuidProtocol futureUuid = 3;
private akka.actor.mailbox.MailboxProtocol.UuidProtocol futureUuid_ = akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance(); private akka.actor.mailbox.MailboxProtocol.UuidProtocol futureUuid_ = akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance();
private com.google.protobuf.SingleFieldBuilder< private com.google.protobuf.SingleFieldBuilder<
@ -660,7 +660,7 @@ public final class MailboxProtocol {
} }
} }
private com.google.protobuf.SingleFieldBuilder< private com.google.protobuf.SingleFieldBuilder<
akka.actor.mailbox.MailboxProtocol.UuidProtocol, akka.actor.mailbox.MailboxProtocol.UuidProtocol.Builder, akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder> akka.actor.mailbox.MailboxProtocol.UuidProtocol, akka.actor.mailbox.MailboxProtocol.UuidProtocol.Builder, akka.actor.mailbox.MailboxProtocol.UuidProtocolOrBuilder>
getFutureUuidFieldBuilder() { getFutureUuidFieldBuilder() {
if (futureUuidBuilder_ == null) { if (futureUuidBuilder_ == null) {
futureUuidBuilder_ = new com.google.protobuf.SingleFieldBuilder< futureUuidBuilder_ = new com.google.protobuf.SingleFieldBuilder<
@ -672,7 +672,7 @@ public final class MailboxProtocol {
} }
return futureUuidBuilder_; return futureUuidBuilder_;
} }
// required bytes message = 4; // required bytes message = 4;
private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY; private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasMessage() { public boolean hasMessage() {
@ -696,25 +696,25 @@ public final class MailboxProtocol {
onChanged(); onChanged();
return this; return this;
} }
// @@protoc_insertion_point(builder_scope:DurableMailboxMessageProtocol) // @@protoc_insertion_point(builder_scope:DurableMailboxMessageProtocol)
} }
static { static {
defaultInstance = new DurableMailboxMessageProtocol(true); defaultInstance = new DurableMailboxMessageProtocol(true);
defaultInstance.initFields(); defaultInstance.initFields();
} }
// @@protoc_insertion_point(class_scope:DurableMailboxMessageProtocol) // @@protoc_insertion_point(class_scope:DurableMailboxMessageProtocol)
} }
public interface UuidProtocolOrBuilder public interface UuidProtocolOrBuilder
extends com.google.protobuf.MessageOrBuilder { extends com.google.protobuf.MessageOrBuilder {
// required uint64 high = 1; // required uint64 high = 1;
boolean hasHigh(); boolean hasHigh();
long getHigh(); long getHigh();
// required uint64 low = 2; // required uint64 low = 2;
boolean hasLow(); boolean hasLow();
long getLow(); long getLow();
@ -727,26 +727,26 @@ public final class MailboxProtocol {
super(builder); super(builder);
} }
private UuidProtocol(boolean noInit) {} private UuidProtocol(boolean noInit) {}
private static final UuidProtocol defaultInstance; private static final UuidProtocol defaultInstance;
public static UuidProtocol getDefaultInstance() { public static UuidProtocol getDefaultInstance() {
return defaultInstance; return defaultInstance;
} }
public UuidProtocol getDefaultInstanceForType() { public UuidProtocol getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_descriptor; return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_fieldAccessorTable; return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_fieldAccessorTable;
} }
private int bitField0_; private int bitField0_;
// required uint64 high = 1; // required uint64 high = 1;
public static final int HIGH_FIELD_NUMBER = 1; public static final int HIGH_FIELD_NUMBER = 1;
@ -757,7 +757,7 @@ public final class MailboxProtocol {
public long getHigh() { public long getHigh() {
return high_; return high_;
} }
// required uint64 low = 2; // required uint64 low = 2;
public static final int LOW_FIELD_NUMBER = 2; public static final int LOW_FIELD_NUMBER = 2;
private long low_; private long low_;
@ -767,7 +767,7 @@ public final class MailboxProtocol {
public long getLow() { public long getLow() {
return low_; return low_;
} }
private void initFields() { private void initFields() {
high_ = 0L; high_ = 0L;
low_ = 0L; low_ = 0L;
@ -776,7 +776,7 @@ public final class MailboxProtocol {
public final boolean isInitialized() { public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized; byte isInitialized = memoizedIsInitialized;
if (isInitialized != -1) return isInitialized == 1; if (isInitialized != -1) return isInitialized == 1;
if (!hasHigh()) { if (!hasHigh()) {
memoizedIsInitialized = 0; memoizedIsInitialized = 0;
return false; return false;
@ -788,7 +788,7 @@ public final class MailboxProtocol {
memoizedIsInitialized = 1; memoizedIsInitialized = 1;
return true; return true;
} }
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -800,12 +800,12 @@ public final class MailboxProtocol {
} }
getUnknownFields().writeTo(output); getUnknownFields().writeTo(output);
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) return size; if (size != -1) return size;
size = 0; size = 0;
if (((bitField0_ & 0x00000001) == 0x00000001)) { if (((bitField0_ & 0x00000001) == 0x00000001)) {
size += com.google.protobuf.CodedOutputStream size += com.google.protobuf.CodedOutputStream
@ -819,14 +819,14 @@ public final class MailboxProtocol {
memoizedSerializedSize = size; memoizedSerializedSize = size;
return size; return size;
} }
private static final long serialVersionUID = 0L; private static final long serialVersionUID = 0L;
@java.lang.Override @java.lang.Override
protected java.lang.Object writeReplace() protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException { throws java.io.ObjectStreamException {
return super.writeReplace(); return super.writeReplace();
} }
public static akka.actor.mailbox.MailboxProtocol.UuidProtocol parseFrom( public static akka.actor.mailbox.MailboxProtocol.UuidProtocol parseFrom(
com.google.protobuf.ByteString data) com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
@ -893,14 +893,14 @@ public final class MailboxProtocol {
return newBuilder().mergeFrom(input, extensionRegistry) return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed(); .buildParsed();
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(akka.actor.mailbox.MailboxProtocol.UuidProtocol prototype) { public static Builder newBuilder(akka.actor.mailbox.MailboxProtocol.UuidProtocol prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
@java.lang.Override @java.lang.Override
protected Builder newBuilderForType( protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessage.BuilderParent parent) { com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@ -914,17 +914,17 @@ public final class MailboxProtocol {
getDescriptor() { getDescriptor() {
return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_descriptor; return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_fieldAccessorTable; return akka.actor.mailbox.MailboxProtocol.internal_static_UuidProtocol_fieldAccessorTable;
} }
// Construct using akka.actor.mailbox.MailboxProtocol.UuidProtocol.newBuilder() // Construct using akka.actor.mailbox.MailboxProtocol.UuidProtocol.newBuilder()
private Builder() { private Builder() {
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
} }
private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) { private Builder(com.google.protobuf.GeneratedMessage.BuilderParent parent) {
super(parent); super(parent);
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
@ -936,7 +936,7 @@ public final class MailboxProtocol {
private static Builder create() { private static Builder create() {
return new Builder(); return new Builder();
} }
public Builder clear() { public Builder clear() {
super.clear(); super.clear();
high_ = 0L; high_ = 0L;
@ -945,20 +945,20 @@ public final class MailboxProtocol {
bitField0_ = (bitField0_ & ~0x00000002); bitField0_ = (bitField0_ & ~0x00000002);
return this; return this;
} }
public Builder clone() { public Builder clone() {
return create().mergeFrom(buildPartial()); return create().mergeFrom(buildPartial());
} }
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDescriptor(); return akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDescriptor();
} }
public akka.actor.mailbox.MailboxProtocol.UuidProtocol getDefaultInstanceForType() { public akka.actor.mailbox.MailboxProtocol.UuidProtocol getDefaultInstanceForType() {
return akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance(); return akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance();
} }
public akka.actor.mailbox.MailboxProtocol.UuidProtocol build() { public akka.actor.mailbox.MailboxProtocol.UuidProtocol build() {
akka.actor.mailbox.MailboxProtocol.UuidProtocol result = buildPartial(); akka.actor.mailbox.MailboxProtocol.UuidProtocol result = buildPartial();
if (!result.isInitialized()) { if (!result.isInitialized()) {
@ -966,7 +966,7 @@ public final class MailboxProtocol {
} }
return result; return result;
} }
private akka.actor.mailbox.MailboxProtocol.UuidProtocol buildParsed() private akka.actor.mailbox.MailboxProtocol.UuidProtocol buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
akka.actor.mailbox.MailboxProtocol.UuidProtocol result = buildPartial(); akka.actor.mailbox.MailboxProtocol.UuidProtocol result = buildPartial();
@ -976,7 +976,7 @@ public final class MailboxProtocol {
} }
return result; return result;
} }
public akka.actor.mailbox.MailboxProtocol.UuidProtocol buildPartial() { public akka.actor.mailbox.MailboxProtocol.UuidProtocol buildPartial() {
akka.actor.mailbox.MailboxProtocol.UuidProtocol result = new akka.actor.mailbox.MailboxProtocol.UuidProtocol(this); akka.actor.mailbox.MailboxProtocol.UuidProtocol result = new akka.actor.mailbox.MailboxProtocol.UuidProtocol(this);
int from_bitField0_ = bitField0_; int from_bitField0_ = bitField0_;
@ -993,7 +993,7 @@ public final class MailboxProtocol {
onBuilt(); onBuilt();
return result; return result;
} }
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof akka.actor.mailbox.MailboxProtocol.UuidProtocol) { if (other instanceof akka.actor.mailbox.MailboxProtocol.UuidProtocol) {
return mergeFrom((akka.actor.mailbox.MailboxProtocol.UuidProtocol)other); return mergeFrom((akka.actor.mailbox.MailboxProtocol.UuidProtocol)other);
@ -1002,7 +1002,7 @@ public final class MailboxProtocol {
return this; return this;
} }
} }
public Builder mergeFrom(akka.actor.mailbox.MailboxProtocol.UuidProtocol other) { public Builder mergeFrom(akka.actor.mailbox.MailboxProtocol.UuidProtocol other) {
if (other == akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance()) return this; if (other == akka.actor.mailbox.MailboxProtocol.UuidProtocol.getDefaultInstance()) return this;
if (other.hasHigh()) { if (other.hasHigh()) {
@ -1014,19 +1014,19 @@ public final class MailboxProtocol {
this.mergeUnknownFields(other.getUnknownFields()); this.mergeUnknownFields(other.getUnknownFields());
return this; return this;
} }
public final boolean isInitialized() { public final boolean isInitialized() {
if (!hasHigh()) { if (!hasHigh()) {
return false; return false;
} }
if (!hasLow()) { if (!hasLow()) {
return false; return false;
} }
return true; return true;
} }
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -1063,9 +1063,9 @@ public final class MailboxProtocol {
} }
} }
} }
private int bitField0_; private int bitField0_;
// required uint64 high = 1; // required uint64 high = 1;
private long high_ ; private long high_ ;
public boolean hasHigh() { public boolean hasHigh() {
@ -1086,7 +1086,7 @@ public final class MailboxProtocol {
onChanged(); onChanged();
return this; return this;
} }
// required uint64 low = 2; // required uint64 low = 2;
private long low_ ; private long low_ ;
public boolean hasLow() { public boolean hasLow() {
@ -1107,18 +1107,18 @@ public final class MailboxProtocol {
onChanged(); onChanged();
return this; return this;
} }
// @@protoc_insertion_point(builder_scope:UuidProtocol) // @@protoc_insertion_point(builder_scope:UuidProtocol)
} }
static { static {
defaultInstance = new UuidProtocol(true); defaultInstance = new UuidProtocol(true);
defaultInstance.initFields(); defaultInstance.initFields();
} }
// @@protoc_insertion_point(class_scope:UuidProtocol) // @@protoc_insertion_point(class_scope:UuidProtocol)
} }
private static com.google.protobuf.Descriptors.Descriptor private static com.google.protobuf.Descriptors.Descriptor
internal_static_DurableMailboxMessageProtocol_descriptor; internal_static_DurableMailboxMessageProtocol_descriptor;
private static private static
@ -1129,7 +1129,7 @@ public final class MailboxProtocol {
private static private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_UuidProtocol_fieldAccessorTable; internal_static_UuidProtocol_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() { getDescriptor() {
return descriptor; return descriptor;
@ -1174,6 +1174,6 @@ public final class MailboxProtocol {
new com.google.protobuf.Descriptors.FileDescriptor[] { new com.google.protobuf.Descriptors.FileDescriptor[] {
}, assigner); }, assigner);
} }
// @@protoc_insertion_point(outer_class_scope) // @@protoc_insertion_point(outer_class_scope)
} }

1650
akka-remote/src/main/java/akka/remote/RemoteProtocol.java
View file

File diff suppressed because it is too large Load diff

2
akka-remote/src/multi-jvm/scala/akka/remote/FileBasedBarrier.scala
View file

@ -88,4 +88,4 @@ class FileBasedBarrier(
def expire(barrier: String) = { def expire(barrier: String) = {
throw new BarrierTimeoutException("Timeout (%s) waiting for %s barrier" format (timeout, barrier)) throw new BarrierTimeoutException("Timeout (%s) waiting for %s barrier" format (timeout, barrier))
} }
} }

96
akka-remote/src/test/java/akka/actor/ProtobufProtocol.java
View file

@ -10,15 +10,15 @@ public final class ProtobufProtocol {
} }
public interface MyMessageOrBuilder public interface MyMessageOrBuilder
extends com.google.protobuf.MessageOrBuilder { extends com.google.protobuf.MessageOrBuilder {
// required uint64 id = 1; // required uint64 id = 1;
boolean hasId(); boolean hasId();
long getId(); long getId();
// required string name = 2; // required string name = 2;
boolean hasName(); boolean hasName();
String getName(); String getName();
// required bool status = 3; // required bool status = 3;
boolean hasStatus(); boolean hasStatus();
boolean getStatus(); boolean getStatus();
@ -31,26 +31,26 @@ public final class ProtobufProtocol {
super(builder); super(builder);
} }
private MyMessage(boolean noInit) {} private MyMessage(boolean noInit) {}
private static final MyMessage defaultInstance; private static final MyMessage defaultInstance;
public static MyMessage getDefaultInstance() { public static MyMessage getDefaultInstance() {
return defaultInstance; return defaultInstance;
} }
public MyMessage getDefaultInstanceForType() { public MyMessage getDefaultInstanceForType() {
return defaultInstance; return defaultInstance;
} }
public static final com.google.protobuf.Descriptors.Descriptor public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() { getDescriptor() {
return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_descriptor; return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_fieldAccessorTable; return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_fieldAccessorTable;
} }
private int bitField0_; private int bitField0_;
// required uint64 id = 1; // required uint64 id = 1;
public static final int ID_FIELD_NUMBER = 1; public static final int ID_FIELD_NUMBER = 1;
@ -61,7 +61,7 @@ public final class ProtobufProtocol {
public long getId() { public long getId() {
return id_; return id_;
} }
// required string name = 2; // required string name = 2;
public static final int NAME_FIELD_NUMBER = 2; public static final int NAME_FIELD_NUMBER = 2;
private java.lang.Object name_; private java.lang.Object name_;
@ -73,7 +73,7 @@ public final class ProtobufProtocol {
if (ref instanceof String) { if (ref instanceof String) {
return (String) ref; return (String) ref;
} else { } else {
com.google.protobuf.ByteString bs = com.google.protobuf.ByteString bs =
(com.google.protobuf.ByteString) ref; (com.google.protobuf.ByteString) ref;
String s = bs.toStringUtf8(); String s = bs.toStringUtf8();
if (com.google.protobuf.Internal.isValidUtf8(bs)) { if (com.google.protobuf.Internal.isValidUtf8(bs)) {
@ -85,7 +85,7 @@ public final class ProtobufProtocol {
private com.google.protobuf.ByteString getNameBytes() { private com.google.protobuf.ByteString getNameBytes() {
java.lang.Object ref = name_; java.lang.Object ref = name_;
if (ref instanceof String) { if (ref instanceof String) {
com.google.protobuf.ByteString b = com.google.protobuf.ByteString b =
com.google.protobuf.ByteString.copyFromUtf8((String) ref); com.google.protobuf.ByteString.copyFromUtf8((String) ref);
name_ = b; name_ = b;
return b; return b;
@ -93,7 +93,7 @@ public final class ProtobufProtocol {
return (com.google.protobuf.ByteString) ref; return (com.google.protobuf.ByteString) ref;
} }
} }
// required bool status = 3; // required bool status = 3;
public static final int STATUS_FIELD_NUMBER = 3; public static final int STATUS_FIELD_NUMBER = 3;
private boolean status_; private boolean status_;
@ -103,7 +103,7 @@ public final class ProtobufProtocol {
public boolean getStatus() { public boolean getStatus() {
return status_; return status_;
} }
private void initFields() { private void initFields() {
id_ = 0L; id_ = 0L;
name_ = ""; name_ = "";
@ -113,7 +113,7 @@ public final class ProtobufProtocol {
public final boolean isInitialized() { public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized; byte isInitialized = memoizedIsInitialized;
if (isInitialized != -1) return isInitialized == 1; if (isInitialized != -1) return isInitialized == 1;
if (!hasId()) { if (!hasId()) {
memoizedIsInitialized = 0; memoizedIsInitialized = 0;
return false; return false;
@ -129,7 +129,7 @@ public final class ProtobufProtocol {
memoizedIsInitialized = 1; memoizedIsInitialized = 1;
return true; return true;
} }
public void writeTo(com.google.protobuf.CodedOutputStream output) public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException { throws java.io.IOException {
getSerializedSize(); getSerializedSize();
@ -144,12 +144,12 @@ public final class ProtobufProtocol {
} }
getUnknownFields().writeTo(output); getUnknownFields().writeTo(output);
} }
private int memoizedSerializedSize = -1; private int memoizedSerializedSize = -1;
public int getSerializedSize() { public int getSerializedSize() {
int size = memoizedSerializedSize; int size = memoizedSerializedSize;
if (size != -1) return size; if (size != -1) return size;
size = 0; size = 0;
if (((bitField0_ & 0x00000001) == 0x00000001)) { if (((bitField0_ & 0x00000001) == 0x00000001)) {
size += com.google.protobuf.CodedOutputStream size += com.google.protobuf.CodedOutputStream
@ -167,14 +167,14 @@ public final class ProtobufProtocol {
memoizedSerializedSize = size; memoizedSerializedSize = size;
return size; return size;
} }
private static final long serialVersionUID = 0L; private static final long serialVersionUID = 0L;
@java.lang.Override @java.lang.Override
protected java.lang.Object writeReplace() protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException { throws java.io.ObjectStreamException {
return super.writeReplace(); return super.writeReplace();
} }
public static akka.actor.ProtobufProtocol.MyMessage parseFrom( public static akka.actor.ProtobufProtocol.MyMessage parseFrom(
com.google.protobuf.ByteString data) com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
@ -241,14 +241,14 @@ public final class ProtobufProtocol {
return newBuilder().mergeFrom(input, extensionRegistry) return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed(); .buildParsed();
} }
public static Builder newBuilder() { return Builder.create(); } public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); } public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(akka.actor.ProtobufProtocol.MyMessage prototype) { public static Builder newBuilder(akka.actor.ProtobufProtocol.MyMessage prototype) {
return newBuilder().mergeFrom(prototype); return newBuilder().mergeFrom(prototype);
} }
public Builder toBuilder() { return newBuilder(this); } public Builder toBuilder() { return newBuilder(this); }
@java.lang.Override @java.lang.Override
protected Builder newBuilderForType( protected Builder newBuilderForType(
com.google.protobuf.GeneratedMessage.BuilderParent parent) { com.google.protobuf.GeneratedMessage.BuilderParent parent) {
@ -262,17 +262,17 @@ public final class ProtobufProtocol {
getDescriptor() { getDescriptor() {
return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_descriptor; return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_descriptor;
} }
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() { internalGetFieldAccessorTable() {
return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_fieldAccessorTable; return akka.actor.ProtobufProtocol.internal_static_akka_actor_MyMessage_fieldAccessorTable;
} }
// Construct using akka.actor.ProtobufProtocol.MyMessage.newBuilder() // Construct using akka.actor.ProtobufProtocol.MyMessage.newBuilder()
private Builder() { private Builder() {
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
} }
private Builder(BuilderParent parent) { private Builder(BuilderParent parent) {
super(parent); super(parent);
maybeForceBuilderInitialization(); maybeForceBuilderInitialization();
@ -284,7 +284,7 @@ public final class ProtobufProtocol {
private static Builder create() { private static Builder create() {
return new Builder(); return new Builder();
} }
public Builder clear() { public Builder clear() {
super.clear(); super.clear();
id_ = 0L; id_ = 0L;
@ -295,20 +295,20 @@ public final class ProtobufProtocol {
bitField0_ = (bitField0_ & ~0x00000004); bitField0_ = (bitField0_ & ~0x00000004);
return this; return this;
} }
public Builder clone() { public Builder clone() {
return create().mergeFrom(buildPartial()); return create().mergeFrom(buildPartial());
} }
public com.google.protobuf.Descriptors.Descriptor public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() { getDescriptorForType() {
return akka.actor.ProtobufProtocol.MyMessage.getDescriptor(); return akka.actor.ProtobufProtocol.MyMessage.getDescriptor();
} }
public akka.actor.ProtobufProtocol.MyMessage getDefaultInstanceForType() { public akka.actor.ProtobufProtocol.MyMessage getDefaultInstanceForType() {
return akka.actor.ProtobufProtocol.MyMessage.getDefaultInstance(); return akka.actor.ProtobufProtocol.MyMessage.getDefaultInstance();
} }
public akka.actor.ProtobufProtocol.MyMessage build() { public akka.actor.ProtobufProtocol.MyMessage build() {
akka.actor.ProtobufProtocol.MyMessage result = buildPartial(); akka.actor.ProtobufProtocol.MyMessage result = buildPartial();
if (!result.isInitialized()) { if (!result.isInitialized()) {
@ -316,7 +316,7 @@ public final class ProtobufProtocol {
} }
return result; return result;
} }
private akka.actor.ProtobufProtocol.MyMessage buildParsed() private akka.actor.ProtobufProtocol.MyMessage buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException { throws com.google.protobuf.InvalidProtocolBufferException {
akka.actor.ProtobufProtocol.MyMessage result = buildPartial(); akka.actor.ProtobufProtocol.MyMessage result = buildPartial();
@ -326,7 +326,7 @@ public final class ProtobufProtocol {
} }
return result; return result;
} }
public akka.actor.ProtobufProtocol.MyMessage buildPartial() { public akka.actor.ProtobufProtocol.MyMessage buildPartial() {
akka.actor.ProtobufProtocol.MyMessage result = new akka.actor.ProtobufProtocol.MyMessage(this); akka.actor.ProtobufProtocol.MyMessage result = new akka.actor.ProtobufProtocol.MyMessage(this);
int from_bitField0_ = bitField0_; int from_bitField0_ = bitField0_;
@ -347,7 +347,7 @@ public final class ProtobufProtocol {
onBuilt(); onBuilt();
return result; return result;
} }
public Builder mergeFrom(com.google.protobuf.Message other) { public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof akka.actor.ProtobufProtocol.MyMessage) { if (other instanceof akka.actor.ProtobufProtocol.MyMessage) {
return mergeFrom((akka.actor.ProtobufProtocol.MyMessage)other); return mergeFrom((akka.actor.ProtobufProtocol.MyMessage)other);
@ -356,7 +356,7 @@ public final class ProtobufProtocol {
return this; return this;
} }
} }
public Builder mergeFrom(akka.actor.ProtobufProtocol.MyMessage other) { public Builder mergeFrom(akka.actor.ProtobufProtocol.MyMessage other) {
if (other == akka.actor.ProtobufProtocol.MyMessage.getDefaultInstance()) return this; if (other == akka.actor.ProtobufProtocol.MyMessage.getDefaultInstance()) return this;
if (other.hasId()) { if (other.hasId()) {
@ -371,23 +371,23 @@ public final class ProtobufProtocol {
this.mergeUnknownFields(other.getUnknownFields()); this.mergeUnknownFields(other.getUnknownFields());
return this; return this;
} }
public final boolean isInitialized() { public final boolean isInitialized() {
if (!hasId()) { if (!hasId()) {
return false; return false;
} }
if (!hasName()) { if (!hasName()) {
return false; return false;
} }
if (!hasStatus()) { if (!hasStatus()) {
return false; return false;
} }
return true; return true;
} }
public Builder mergeFrom( public Builder mergeFrom(
com.google.protobuf.CodedInputStream input, com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) com.google.protobuf.ExtensionRegistryLite extensionRegistry)
@ -429,9 +429,9 @@ public final class ProtobufProtocol {
} }
} }
} }
private int bitField0_; private int bitField0_;
// required uint64 id = 1; // required uint64 id = 1;
private long id_ ; private long id_ ;
public boolean hasId() { public boolean hasId() {
@ -452,7 +452,7 @@ public final class ProtobufProtocol {
onChanged(); onChanged();
return this; return this;
} }
// required string name = 2; // required string name = 2;
private java.lang.Object name_ = ""; private java.lang.Object name_ = "";
public boolean hasName() { public boolean hasName() {
@ -488,7 +488,7 @@ public final class ProtobufProtocol {
name_ = value; name_ = value;
onChanged(); onChanged();
} }
// required bool status = 3; // required bool status = 3;
private boolean status_ ; private boolean status_ ;
public boolean hasStatus() { public boolean hasStatus() {
@ -509,24 +509,24 @@ public final class ProtobufProtocol {
onChanged(); onChanged();
return this; return this;
} }
// @@protoc_insertion_point(builder_scope:akka.actor.MyMessage) // @@protoc_insertion_point(builder_scope:akka.actor.MyMessage)
} }
static { static {
defaultInstance = new MyMessage(true); defaultInstance = new MyMessage(true);
defaultInstance.initFields(); defaultInstance.initFields();
} }
// @@protoc_insertion_point(class_scope:akka.actor.MyMessage) // @@protoc_insertion_point(class_scope:akka.actor.MyMessage)
} }
private static com.google.protobuf.Descriptors.Descriptor private static com.google.protobuf.Descriptors.Descriptor
internal_static_akka_actor_MyMessage_descriptor; internal_static_akka_actor_MyMessage_descriptor;
private static private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_akka_actor_MyMessage_fieldAccessorTable; internal_static_akka_actor_MyMessage_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() { getDescriptor() {
return descriptor; return descriptor;
@ -560,6 +560,6 @@ public final class ProtobufProtocol {
new com.google.protobuf.Descriptors.FileDescriptor[] { new com.google.protobuf.Descriptors.FileDescriptor[] {
}, assigner); }, assigner);
} }
// @@protoc_insertion_point(outer_class_scope) // @@protoc_insertion_point(outer_class_scope)
} }

2
akka-remote/src/test/scala/akka/remote/AccrualFailureDetectorSpec.scala
View file

@ -91,4 +91,4 @@ class AccrualFailureDetectorSpec extends WordSpec with MustMatchers {
fd.isAvailable(conn) must be(true) fd.isAvailable(conn) must be(true)
} }
} }
} }

2
akka-remote/src/test/scala/akka/remote/GossiperSpec.scala
View file

@ -12,4 +12,4 @@ class GossiperSpec extends WordSpec with MustMatchers {
"..." in { "..." in {
} }
} }
} }

2
akka-remote/src/test/scala/akka/remote/VectorClockSpec.scala
View file

@ -123,4 +123,4 @@ class VectorClockSpec extends WordSpec with MustMatchers {
clock5_1.compare(clock3_2) must be(After) clock5_1.compare(clock3_2) must be(After)
} }
} }
} }

2
akka-samples/akka-sample-camel/config/akka.conf
View file

@ -8,7 +8,7 @@ akka {
enabled-modules = ["camel", "http"] enabled-modules = ["camel", "http"]
time-unit = "seconds" time-unit = "seconds"
event-handlers = ["akka.event.EventHandler$DefaultListener"] event-handlers = ["akka.event.EventHandler$DefaultListener"]
boot = ["sample.camel.Boot"] boot = ["sample.camel.Boot"]

2
akka-samples/akka-sample-hello/config/akka.conf
View file

@ -8,7 +8,7 @@ akka {
enabled-modules = ["http"] enabled-modules = ["http"]
time-unit = "seconds" time-unit = "seconds"
event-handlers = ["akka.event.EventHandler$DefaultListener"] event-handlers = ["akka.event.EventHandler$DefaultListener"]
boot = ["sample.hello.Boot"] boot = ["sample.hello.Boot"]

2
akka-spring/src/test/java/akka/spring/RemoteTypedSessionActorImpl.java
View file

@ -26,7 +26,7 @@ public class RemoteTypedSessionActorImpl extends TypedActor implements RemoteTyp
instantiatedSessionActors.remove(this); instantiatedSessionActors.remove(this);
} }
private String user="anonymous"; private String user="anonymous";
@Override @Override

2
akka-spring/src/test/java/akka/spring/foo/StatefulPojo.java
View file

@ -53,4 +53,4 @@ public class StatefulPojo extends TypedActor {
return isInitialized; return isInitialized;
} }
} }
*/ */

2
akka-spring/src/test/resources/akka-test.conf
View file

@ -11,7 +11,7 @@ akka {
enabled-modules = ["remote"] # Comma separated list of the enabled modules. Options: ["remote", "camel", "http"] enabled-modules = ["remote"] # Comma separated list of the enabled modules. Options: ["remote", "camel", "http"]
time-unit = "seconds" # Time unit for all timeout properties throughout the config time-unit = "seconds" # Time unit for all timeout properties throughout the config
event-handlers = ["akka.event.EventHandler$DefaultListener"] # event handlers to register at boot time (EventHandler$DefaultListener logs to STDOUT) event-handlers = ["akka.event.EventHandler$DefaultListener"] # event handlers to register at boot time (EventHandler$DefaultListener logs to STDOUT)
# These boot classes are loaded (and created) automatically when the Akka Microkernel boots up # These boot classes are loaded (and created) automatically when the Akka Microkernel boots up

2
akka-stm/src/test/java/akka/transactor/test/Increment.java
View file

@ -20,4 +20,4 @@ public class Increment {
public CountDownLatch getLatch() { public CountDownLatch getLatch() {
return latch; return latch;
} }
} }

2
akka-testkit/src/test/scala/akka/testkit/AkkaSpec.scala
View file

@ -39,4 +39,4 @@ abstract class AkkaSpec(_application: AkkaApplication = AkkaApplication())
def spawn(body: ⇒ Unit)(implicit dispatcher: MessageDispatcher) { def spawn(body: ⇒ Unit)(implicit dispatcher: MessageDispatcher) {
actorOf(Props(ctx ⇒ { case "go" ⇒ try body finally ctx.self.stop() }).withDispatcher(dispatcher)) ! "go" actorOf(Props(ctx ⇒ { case "go" ⇒ try body finally ctx.self.stop() }).withDispatcher(dispatcher)) ! "go"
} }
} }