package com.uc.cep.examples;

import java.util.ArrayList;
import java.util.List;

import com.bea.wlevs.ede.api.EventRejectedException;
import com.bea.wlevs.ede.api.StreamSink;

public class CQLTestEventSink implements StreamSink
{
	private String name;
	private List<MyEvent> goodEvents = new ArrayList<MyEvent>();
	private List<Object> badEvents = new ArrayList<Object>();
	
	public CQLTestEventSink(final String name)
	{
		super();
		this.name = name;
	}
	
	@Override
	public void onInsertEvent(Object event) throws EventRejectedException
	{
		if (event.getClass().isAssignableFrom(MyEvent.class))
		{
			goodEvents.add((MyEvent)event);
		}
		else
		{
			badEvents.add(event);
		}
	}

	public void clearAllEvents()
	{
		goodEvents.clear();
		badEvents.clear();
	}

	public List<MyEvent> getGoodEvents()
	{
		return new ArrayList<MyEvent>(goodEvents);
	}
	
	public List<Object> getBadEvents()
	{
		return new ArrayList<Object>(badEvents);
	}
}