Package com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Class MultiSourceProcessLogMultiParticipantPacket

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceProcessLogPacket

com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceProcessLogMultiParticipantPacket

public class MultiSourceProcessLogMultiParticipantPacket
extends MultiSourceProcessLogPacket

Since:

9.1

Author:

idan

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceProcessLogPacket

MultiSourceProcessLogPacket.MultiSourcePacketState

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceProcessLogPacket

_dependencies, _packet, _state

Constructor Summary

Constructors

Constructor	Description
MultiSourceProcessLogMultiParticipantPacket(IReplicationOrderedPacket packet, IReplicationParticipantsMediator participantsMediator, IReplicationParticipantsMetadata participantsMetadata)

Method Summary

Modifier and Type	Method	Description
long	getCreationTime()
IReplicationPacketData<?>	getData()
IReplicationParticipantsMetadata	getParticipantsMetadata()
boolean	hasDependencies()
boolean	isConsolidatedByThisParticipant()
boolean	isConsumedByOtherParticipant()
boolean	isMultiParticipant()
boolean	isRegisteredInMediator()
void	setData(IReplicationPacketData<?> mergedData)
void	setRegisteredInMediator()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile.MultiSourceProcessLogPacket

addDependency, getKey, getReplicationPacket, isBeingConsumed, isConsumed, setBeingConsumed, setConsumed, setUnconsumed, toString

Methods inherited from class java.lang.Object

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

Constructor Details

MultiSourceProcessLogMultiParticipantPacket

public MultiSourceProcessLogMultiParticipantPacket(IReplicationOrderedPacket packet,
 IReplicationParticipantsMediator participantsMediator,
 IReplicationParticipantsMetadata participantsMetadata)

Method Details

setData

public void setData(IReplicationPacketData<?> mergedData)

Overrides:

setData in class MultiSourceProcessLogPacket

getData

public IReplicationPacketData<?> getData()

Overrides:

getData in class MultiSourceProcessLogPacket

hasDependencies

public boolean hasDependencies()

Overrides:

hasDependencies in class MultiSourceProcessLogPacket

isConsolidatedByThisParticipant

public boolean isConsolidatedByThisParticipant()

Overrides:

isConsolidatedByThisParticipant in class MultiSourceProcessLogPacket

isMultiParticipant

public boolean isMultiParticipant()

Overrides:

isMultiParticipant in class MultiSourceProcessLogPacket

isRegisteredInMediator

public boolean isRegisteredInMediator()

Overrides:

isRegisteredInMediator in class MultiSourceProcessLogPacket

setRegisteredInMediator

public void setRegisteredInMediator()

Overrides:

setRegisteredInMediator in class MultiSourceProcessLogPacket

getParticipantsMetadata

public IReplicationParticipantsMetadata getParticipantsMetadata()

Overrides:

getParticipantsMetadata in class MultiSourceProcessLogPacket

getCreationTime

public long getCreationTime()

Overrides:

getCreationTime in class MultiSourceProcessLogPacket

isConsumedByOtherParticipant

public boolean isConsumedByOtherParticipant()

Overrides:

isConsumedByOtherParticipant in class MultiSourceProcessLogPacket