com.gigaspaces.dih.consumer

Interface GSMessageExecutor

All Known Implementing Classes:

GSMessageExecutorImpl

public interface GSMessageExecutor

Method Summary

Modifier and Type	Method and 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 Detail

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)