Class WrapperBufferOutput.VersionAwareBufferOutput

java.lang.Object

com.tangosol.util.Base

com.tangosol.io.WrapperBufferOutput

com.tangosol.io.WrapperBufferOutput.VersionAwareBufferOutput

All Implemented Interfaces:

com.oracle.coherence.common.io.OutputStreaming, OutputStreaming, WriteBuffer.BufferOutput, DataOutput

Enclosing class:

WrapperBufferOutput

public static class WrapperBufferOutput.VersionAwareBufferOutput
extends WrapperBufferOutput

A BufferOutput implementation that in addition to delegating to the given DataOutput provides an API to check whether the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.

Author:

jh 2007.11.17

Nested Class Summary

Nested classes/interfaces inherited from class WrapperBufferOutput

WrapperBufferOutput.VersionAwareBufferOutput

Nested classes/interfaces inherited from class Base

Base.LoggingWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected final com.tangosol.internal.net.MessageComponent	f_message	The associated message being sent.

Fields inherited from class Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Fields inherited from interface WriteBuffer.BufferOutput

MAX_PACKED_INT_SIZE, MAX_PACKED_LONG_SIZE

Constructor Summary

Constructors

Constructor	Description
VersionAwareBufferOutput(DataOutput out, com.tangosol.internal.net.MessageComponent message)	Construct a VersionAwareBufferOutput that will write to the specified object implementing the DataOutput interface.

Method Summary

Modifier and Type	Method	Description
boolean	isPatchCompatible(int nEncodedVersion)	Determine whether all the recipients of the content of this BufferOutput run versions that are the same as the encode version with the same or a higher patch level.
boolean	isVersionCompatible(int nEncodedVersion)	Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.
boolean	isVersionCompatible(int nYear, int nMonth, int nPatch)	Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.
boolean	isVersionCompatible(int nMajor, int nMinor, int nMicro, int nPatchSet, int nPatch)	Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.
boolean	isVersionCompatible(IntPredicate predicate)	Determine whether every recipient's encoded version satisfies the specified compatibility predicate.

Methods inherited from class WrapperBufferOutput

close, flush, getBuffer, getByteBuffer, getDataOutput, getOffset, setOffset, write, write, write, writeBoolean, writeBuffer, writeBuffer, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writePackedInt, writePackedLong, writeSafeUTF, writeShort, writeStream, writeStream, writeUTF

Methods inherited from class Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

f_message

protected final com.tangosol.internal.net.MessageComponent f_message

The associated message being sent.

Constructor Details

VersionAwareBufferOutput

public VersionAwareBufferOutput(DataOutput out,
 com.tangosol.internal.net.MessageComponent message)

Construct a VersionAwareBufferOutput that will write to the specified object implementing the DataOutput interface.

Parameters:

out - an object implementing DataOutput to write to

message - the associated message being sent

Method Details

isVersionCompatible

public boolean isVersionCompatible(int nMajor,
 int nMinor,
 int nMicro,
 int nPatchSet,
 int nPatch)

Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.

Returns:

true iff all the recipients' versions are greater or equal to the specified one

isVersionCompatible

public boolean isVersionCompatible(int nYear,
 int nMonth,
 int nPatch)

Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.

Returns:

true iff all the recipients' versions are greater or equal to the specified one

isVersionCompatible

public boolean isVersionCompatible(int nEncodedVersion)

Determine whether all the recipients of the content of this BufferOutput run versions that supersede (greater or equal to) the specified version.

Returns:

true iff all the recipients' versions are greater or equal to the specified one

isVersionCompatible

public boolean isVersionCompatible(IntPredicate predicate)

Determine whether every recipient's encoded version satisfies the specified compatibility predicate.

Parameters:

predicate - the compatibility predicate

Returns:

true iff every recipient's encoded version satisfies the specified predicate

isPatchCompatible

public boolean isPatchCompatible(int nEncodedVersion)

Determine whether all the recipients of the content of this BufferOutput run versions that are the same as the encode version with the same or a higher patch level.

Returns:

true iff all the recipients' versions are the same version with the same or a higher patch level to the specified one