Package com.gigaspaces.dih.consumer

Interface GSMessageExecutor

All Known Implementing Classes:

GSMessageExecutorImpl

public interface GSMessageExecutor

Method Summary

Modifier and Type	Method	Description
void	executeDelete(GSDeleteMessage deleteMessage)
void	executeDelete(GSDeleteMessage deleteMessage, ConsumerConfiguration consumerConfiguration, boolean populateDeletedObjectsTable)
void	executeFullSyncBatch(List<GSInsertMessage> insertMessages, ConsumerConfiguration consumerConfiguration)
void	executeFullSyncIndicator(GSFullSyncIndicatorMessage message, Callback triggerFullSyncConsumerGracefulShutdown)
void	executeInsert(GSInsertMessage insertMessage)
void	executeInsert(GSInsertMessage insertMessage, ConsumerConfiguration consumerConfiguration)
void	executeUpdate(GSUpdateMessage updateMessage)
void	executeUpdate(GSUpdateMessage updateMessage, ConsumerConfiguration consumerConfiguration)

Method Details

executeInsert

void executeInsert(GSInsertMessage insertMessage)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeUpdate

void executeUpdate(GSUpdateMessage updateMessage)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeDelete

void executeDelete(GSDeleteMessage deleteMessage)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeInsert

void executeInsert(GSInsertMessage insertMessage,
 ConsumerConfiguration consumerConfiguration)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeDelete

void executeDelete(GSDeleteMessage deleteMessage,
 ConsumerConfiguration consumerConfiguration,
 boolean populateDeletedObjectsTable)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeUpdate

void executeUpdate(GSUpdateMessage updateMessage,
 ConsumerConfiguration consumerConfiguration)
            throws NonRetriableMessageExecutionException,
RetriableMessageExecutionException

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeFullSyncBatch

void executeFullSyncBatch(List<GSInsertMessage> insertMessages,
 ConsumerConfiguration consumerConfiguration)
                   throws RetriableMessageExecutionException

Throws:

RetriableMessageExecutionException

executeFullSyncIndicator

void executeFullSyncIndicator(GSFullSyncIndicatorMessage message,
 Callback triggerFullSyncConsumerGracefulShutdown)