Package com.gigaspaces.dih.consumer

Class DefaultMessageCleanser

java.lang.Object

com.gigaspaces.dih.consumer.DefaultMessageCleanser

All Implemented Interfaces:

GSMessageCleanser

public class DefaultMessageCleanser
extends Object
implements GSMessageCleanser

Constructor Summary

Constructors

Constructor	Description
DefaultMessageCleanser()
DefaultMessageCleanser(ISpaceProxy gigaSpace)

Method Summary

Modifier and Type	Method	Description
GSDeleteMessage	cleanseDelete(GSDeleteMessage deleteMessage)
GSInsertMessage	cleanseInsert(GSInsertMessage insertMessage)
GSUpdateMessage	cleanseUpdate(GSUpdateMessage updateMessage)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultMessageCleanser

public DefaultMessageCleanser()

DefaultMessageCleanser

public DefaultMessageCleanser(ISpaceProxy gigaSpace)

Method Details

cleanseInsert

public GSInsertMessage cleanseInsert(GSInsertMessage insertMessage)
                              throws MessageValidationException

Specified by:

cleanseInsert in interface GSMessageCleanser

Throws:

MessageValidationException

cleanseDelete

public GSDeleteMessage cleanseDelete(GSDeleteMessage deleteMessage)
                              throws MessageValidationException

Specified by:

cleanseDelete in interface GSMessageCleanser

Throws:

MessageValidationException

cleanseUpdate

public GSUpdateMessage cleanseUpdate(GSUpdateMessage updateMessage)
                              throws MessageValidationException

Specified by:

cleanseUpdate in interface GSMessageCleanser

Throws:

MessageValidationException