Class EnvelopeBuffer$
- java.lang.Object
-
- akka.remote.artery.EnvelopeBuffer$
-
public class EnvelopeBuffer$ extends java.lang.Object
INTERNAL APIThe strategy if the header format must be changed in an incompatible way is: - In the end we only want to support one header format, the latest, but during a rolling upgrade period we must support two versions in at least one Akka patch release. - When supporting two version the outbound messages must still be encoded with old version. The Decoder on the receiving side must understand both versions. - Create a new copy of the header encoding/decoding logic (issue #24553: we should refactor to make that easier). - Bump
ArteryTransport.HighestVersion
and keepArterySettings.Version
as the old version. - Make sureDecoder
picks the right parsing logic based on the version field in the incoming frame. - Release Akka, e.g. 2.5.13 - Later, remove the old header parsing logic and bump theArterySettings.Version
to the same asArteryTransport.HighestVersion
again. - Release Akka, e.g. 2.5.14, and announce that all nodes in the cluster must first be on version 2.5.13 before upgrading to 2.5.14. That means that it is not supported to do a rolling upgrade from 2.5.12 directly to 2.5.14.
-
-
Field Summary
Fields Modifier and Type Field Description static EnvelopeBuffer$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description EnvelopeBuffer$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
ActorRefCompressionTableVersionOffset()
int
ClassManifestCompressionTableVersionOffset()
int
ClassManifestTagOffset()
int
FlagsOffset()
int
MetadataContainerAndLiteralSectionOffset()
akka.remote.artery.ByteFlag
MetadataPresentFlag()
int
RecipientActorRefTagOffset()
int
SenderActorRefTagOffset()
int
SerializerOffset()
int
TagTypeMask()
int
TagValueMask()
int
UidOffset()
int
VersionOffset()
-
-
-
Field Detail
-
MODULE$
public static final EnvelopeBuffer$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
TagTypeMask
public int TagTypeMask()
-
TagValueMask
public int TagValueMask()
-
MetadataPresentFlag
public akka.remote.artery.ByteFlag MetadataPresentFlag()
-
VersionOffset
public int VersionOffset()
-
FlagsOffset
public int FlagsOffset()
-
ActorRefCompressionTableVersionOffset
public int ActorRefCompressionTableVersionOffset()
-
ClassManifestCompressionTableVersionOffset
public int ClassManifestCompressionTableVersionOffset()
-
UidOffset
public int UidOffset()
-
SerializerOffset
public int SerializerOffset()
-
SenderActorRefTagOffset
public int SenderActorRefTagOffset()
-
RecipientActorRefTagOffset
public int RecipientActorRefTagOffset()
-
ClassManifestTagOffset
public int ClassManifestTagOffset()
-
MetadataContainerAndLiteralSectionOffset
public int MetadataContainerAndLiteralSectionOffset()
-
-