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	executeInsert(GSInsertMessage insertMessage)
void	executeUpdate(GSUpdateMessage updateMessage)

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

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