com.gigaspaces.dih.consumer

Class GSMessageExecutorImpl

java.lang.Object

com.gigaspaces.dih.consumer.GSMessageExecutorImpl

All Implemented Interfaces:

GSMessageExecutor

public class GSMessageExecutorImpl
extends Object
implements GSMessageExecutor

Constructor Summary

Constructors

Constructor and Description
GSMessageExecutorImpl(ISpaceProxy gigaSpace)

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

GSMessageExecutorImpl

public GSMessageExecutorImpl(ISpaceProxy gigaSpace)

Method Detail

executeFullSyncBatch

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

Specified by:

executeFullSyncBatch in interface GSMessageExecutor

Throws:

RetriableMessageExecutionException

executeInsert

public void executeInsert(GSInsertMessage insertMessage)
                   throws NonRetriableMessageExecutionException,
                          RetriableMessageExecutionException

Specified by:

executeInsert in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeDelete

public void executeDelete(GSDeleteMessage deleteMessage)
                   throws NonRetriableMessageExecutionException,
                          RetriableMessageExecutionException

Specified by:

executeDelete in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeUpdate

public void executeUpdate(GSUpdateMessage updateMessage)
                   throws NonRetriableMessageExecutionException,
                          RetriableMessageExecutionException

Specified by:

executeUpdate in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeInsert

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

Specified by:

executeInsert in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeDelete

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

Specified by:

executeDelete in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeUpdate

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

Specified by:

executeUpdate in interface GSMessageExecutor

Throws:

NonRetriableMessageExecutionException

RetriableMessageExecutionException

executeFullSyncIndicator

public void executeFullSyncIndicator(GSFullSyncIndicatorMessage message,
                                     Callback triggerFullSyncConsumerGracefulShutdown)

Specified by:

executeFullSyncIndicator in interface GSMessageExecutor