package com.test;

import org.openspaces.core.GigaSpace;
import org.openspaces.core.context.GigaSpaceLateContext;
import org.openspaces.core.space.filter.AfterAllNotifyTrigger;
import org.openspaces.core.space.filter.AfterNotifyTrigger;
import org.openspaces.core.space.filter.AfterReadMultiple;
import org.openspaces.core.space.filter.AfterRemoveByLease;
import org.openspaces.core.space.filter.AfterTakeMultiple;
import org.openspaces.core.space.filter.AfterWrite;
import org.openspaces.core.space.filter.BeforeAllNotifyTrigger;
import org.openspaces.core.space.filter.BeforeExecute;
import org.openspaces.core.space.filter.BeforeNotify;
import org.openspaces.core.space.filter.BeforeNotifyTrigger;
import org.openspaces.core.space.filter.BeforeRead;
import org.openspaces.core.space.filter.BeforeReadMultiple;
import org.openspaces.core.space.filter.BeforeTake;
import org.openspaces.core.space.filter.BeforeTakeMultiple;
import org.openspaces.core.space.filter.BeforeWrite;
import org.openspaces.core.space.filter.OnFilterClose;
import org.openspaces.core.space.filter.OnFilterInit;
import org.springframework.beans.factory.InitializingBean;

public class MySpaceFilter implements InitializingBean{

    //late context is needed since there's a circular dependency between the filter bean and the space itself
    @GigaSpaceLateContext
    GigaSpace space;

    @OnFilterInit
    void init() {
        System.out.println("MySpaceFilter Space Filter initialized");
    }

    @OnFilterClose
    void close() {
        System.out.println("Closing Space Filter");
    }

    @BeforeWrite
    public void beforeWrite(Object spaceObject) {
        System.out.println("beforeWrite called" + spaceObject);
    }

    @AfterWrite
    public void afterWrite(Object echo) {
        System.out.println("afterWrite called" + echo);
    }

    @BeforeRead
    public void beforeRead(Object spaceTemplate) {
        System.out.println("beforeRead called" + spaceTemplate);
    }

    @AfterRemoveByLease
    public void afterRemoveByLease(Object spaceObject) {
        System.out.println("afterRemoveByLease called" + spaceObject);
    }

    @BeforeTake
    public void beforeTake(Object spaceTemplate) {
        System.out.println("beforeTake called " + spaceTemplate);
    }

    @BeforeReadMultiple
    public void beforeReadMultiple(Object spaceTemplate) {
        System.out.println("beforeReadMultiple called - Template:" + spaceTemplate);
    }

    @AfterReadMultiple
    public void afterReadMultiple(Object spaceObject) {
        System.out.println("afterReadMultiple called - Space Object:" + spaceObject);
    }

    @BeforeTakeMultiple
    public void beforeTakeMultiple(Object spaceTemplate) {
        System.out.println("beforeTakeMultiple called - Template:" + spaceTemplate);
    }

    @AfterTakeMultiple
    public void afterTakeMultiple(Object spaceObject) {
        System.out.println("afterTakeMultiple called - Space Object:" + spaceObject);
    }

    @BeforeExecute
    public void beforeExecute(Object task) {
        System.out.println("beforeExecute called " + task);
    }

    @BeforeNotify
    public void beforeNotify(Object spaceObject) {
        System.out.println("beforeNotify called " + spaceObject);
    }

    @AfterAllNotifyTrigger
    public void afterAllNotifyTrigger(Object spaceObject) {
        System.out.println("afterAllNotifyTrigger called " + spaceObject);
    }

    @BeforeAllNotifyTrigger
    public void beforeAllNotifyTrigger(Object spaceObject) {
        System.out.println("beforeAllNotifyTrigger called " + spaceObject);
    }

    @AfterNotifyTrigger
    public void AfterNotifyTrigger(Object spaceTemplate) {
        System.out.println("afterNotifyTrigger called " + spaceTemplate);
    }

    @BeforeNotifyTrigger
    public void beforeNotifyTrigger(Object spaceTemplate) {
        System.out.println("beforeNotifyTrigger called " + spaceTemplate);
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        System.out.println("space "+space);
    }
}

package com.test;

import org.openspaces.core.GigaSpace;
import org.openspaces.core.context.GigaSpaceContext;
import org.openspaces.events.adapter.SpaceDataEvent;
import org.openspaces.events.notify.SimpleNotifyContainerConfigurer;
import org.openspaces.events.notify.SimpleNotifyEventListenerContainer;
import org.springframework.beans.factory.InitializingBean;
import com.j_spaces.core.LeaseContext;

public class MyBean implements InitializingBean{
    @GigaSpaceContext
    GigaSpace space;

    @Override
    public void afterPropertiesSet() throws Exception {
        Message m = new Message();
        m.setId("1");
        m.setData("AAAA");

        System.out.println("Calling write");
        LeaseContext<Message> lc = space.write(m);
        line();
        System.out.println("Calling read");
        Message m1 = space.read(new Message());
        line();
        System.out.println("Calling lease cancel");
        lc.cancel();
        line();
        System.out.println("Calling write");
        space.write(m);
        line();
        System.out.println("Calling readMultiple");
        Message m1Array[] =space.readMultiple(new Message(), Integer.MAX_VALUE);
        line();
        System.out.println("Calling take");
        Message m2 = space.take(new Message());
        line();
        System.out.println("Calling write");
        space.write(m);
        line();
        System.out.println("Calling takeMultiple");
        Message m2Array[] =space.takeMultiple(new Message(), Integer.MAX_VALUE);
        line();
        System.out.println("Calling execute");
        space.execute(new MyTask());

        Thread.sleep(1000);

        line();
        System.out.println("Calling Notify Registration");
        SimpleNotifyEventListenerContainer notifyEventListenerContainer =
            new SimpleNotifyContainerConfigurer(space)
            .template(new Message())
            .notifyWrite(true)
            .eventListenerAnnotation(new Object() {
                @SpaceDataEvent
                public void eventHappened() {
                    System.out.println("SpaceDataEvent event called");
                }
            }).notifyContainer();

        notifyEventListenerContainer.start();
        Thread.sleep(1000);
        line();
        System.out.println("Calling write");
        space.write(m);
        Thread.sleep(2000);

    }

    static void line()
    {
        System.out.println("-------------------------");
    }

}

<bean id="mySpaceFilter" class="com.test.MySpaceFilter" />
<bean id="myBean" class="com.test.MyBean" />

<os-core:embedded-space id="space" space-name="space" >
    <os-core:annotation-adapter-filter priority="2">
        <os-core:filter ref="mySpaceFilter" />
    </os-core:annotation-adapter-filter>
</os-core:embedded-space>

<os-core:giga-space id="gigaSpace" space="space"/>
<os-core:giga-space-context/>
<os-core:giga-space-late-context />

package com.test;

import com.gigaspaces.annotation.pojo.SpaceClass;
import com.gigaspaces.annotation.pojo.SpaceId;

@SpaceClass
public class Message {
    String id;
    String data;

    public Message (){}

    @SpaceId
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getData() {
        return data;
    }
    public void setData(String data) {
        this.data = data;
    }

    public String toString() {
        return " Class Message - Object ID:" + id + " data:" + data;
    }
}

package com.test;

import java.io.Serializable;
import org.openspaces.core.executor.Task;

public class MyTask implements Task<Serializable>{

    @Override
    public Serializable execute() throws Exception {
        return null;
    }
}