org.apache.ignite.internal.processors.query.schema.message

Class SchemaFinishDiscoveryMessage

java.lang.Object

org.apache.ignite.internal.processors.query.schema.message.SchemaAbstractDiscoveryMessage

org.apache.ignite.internal.processors.query.schema.message.SchemaFinishDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

public class SchemaFinishDiscoveryMessage
extends SchemaAbstractDiscoveryMessage

Schema change finish discovery message.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.query.schema.message.SchemaAbstractDiscoveryMessage

op

Constructor Summary

Constructors

Constructor and Description
SchemaFinishDiscoveryMessage(SchemaAbstractOperation op, SchemaOperationException err, boolean nop) Constructor.

Method Summary

Modifier and Type	Method and Description
@Nullable DiscoveryCustomMessage	ackMessage() Called when custom message has been handled by all nodes.
@Nullable SchemaOperationException	error()
boolean	exchange()
boolean	hasError()
boolean	isMutable()
boolean	nop()
SchemaProposeDiscoveryMessage	proposeMessage()
void	proposeMessage(SchemaProposeDiscoveryMessage proposeMsg)
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.query.schema.message.SchemaAbstractDiscoveryMessage

createDiscoCache, id, operation

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage

stopProcess

Constructor Detail

SchemaFinishDiscoveryMessage

public SchemaFinishDiscoveryMessage(SchemaAbstractOperation op,
                                    SchemaOperationException err,
                                    boolean nop)

Constructor.

Parameters:

op - Original operation.

err - Error.

nop - No-op flag.

Method Detail

ackMessage

@Nullable
public @Nullable DiscoveryCustomMessage ackMessage()

Called when custom message has been handled by all nodes.

Returns:

Ack message or null if ack is not required.

isMutable

public boolean isMutable()

Returns:

True if message can be modified during listener notification. Changes will be sent to next nodes.

exchange

public boolean exchange()

Specified by:

exchange in class SchemaAbstractDiscoveryMessage

Returns:

Whether request must be propagated to exchange thread.

hasError

public boolean hasError()

Returns:

True if error was reported during init.

error

@Nullable
public @Nullable SchemaOperationException error()

Returns:

Error message (if any).

proposeMessage

public SchemaProposeDiscoveryMessage proposeMessage()

Returns:

Propose message.

proposeMessage

public void proposeMessage(SchemaProposeDiscoveryMessage proposeMsg)

Parameters:

proposeMsg - Propose message.

nop

public boolean nop()

Returns:

True if message in no-op.

toString

public String toString()

Overrides:

toString in class SchemaAbstractDiscoveryMessage