modules/core/src/main/java/org/apache/savan/atom/AtomSubscriber.java

package org.apache.savan.atom;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URI;
import java.util.Date;

import javax.xml.stream.XMLStreamException;

import org.apache.axiom.om.OMElement;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.savan.SavanException;
import org.apache.savan.filters.Filter;
import org.apache.savan.subscribers.Subscriber;
import org.apache.savan.subscription.ExpirationBean;
import org.w3.x2005.x08.addressing.EndpointReferenceType;

public class AtomSubscriber implements Subscriber{
	private static final Log log = LogFactory.getLog(AtomSubscriber.class);
	private Date subscriptionEndingTime = null;
	private Feed feed; 
	private Filter filter = null;
	private File atomFile;
	private String feedUrl;
	
	private URI id;
	private String title;
	private String author;
	public URI getId() {
		return id;
	}
	public void renewSubscription(ExpirationBean bean) {
		throw new UnsupportedOperationException();
	}
	public void sendEventData(OMElement eventData) throws SavanException {
		try {
			Date date = new Date ();
			
			boolean expired = false;
			if (subscriptionEndingTime!=null && date.after(subscriptionEndingTime))
				expired = true;
			
			if (expired) {
				String message = "Cant notify the listner since the subscription has been expired";
				log.debug(message);
			}
			if(feed == null){
				feed = new Feed(title,id.toString(),author);
			}
			feed.addEntry(eventData);
			
			if(!atomFile.getParentFile().exists()){
				atomFile.getParentFile().mkdir();
			}
			FileOutputStream out = new FileOutputStream(atomFile);
			feed.write(out);
			out.close();
			System.out.println("Atom file at "+ atomFile + " is updated");
		} catch (FileNotFoundException e) {
			throw new SavanException(e);
		} catch (XMLStreamException e) {
			throw new SavanException(e);
		} catch (IOException e) {
			throw new SavanException(e);
		}
	}
	public void setId(URI id) {
		this.id = id;
	}
	
	
	
	


	public void setSubscriptionEndingTime(Date subscriptionEndingTime) {
		this.subscriptionEndingTime = subscriptionEndingTime;
	}

	public void setEndToEPr(EndpointReferenceType endToEPR) {
		throw new UnsupportedOperationException();
	}

	public String getAuthor() {
		return author;
	}

	public void setAuthor(String author) {
		this.author = author;
	}


	public String getTitle() {
		return title;
	}

	public void setTitle(String title) {
		this.title = title;
	}
	
	
	public String getFeedUrl(){
		return feedUrl;
	}

	public Date getSubscriptionEndingTime() {
		return subscriptionEndingTime;
	}
	public Filter getFilter() {
		return filter;
	}
	public void setFilter(Filter filter) {
		this.filter = filter;
	}
	public void setAtomFile(File atomFile) {
		this.atomFile = atomFile;
	}
	public void setFeedUrl(String feedUrl) {
		this.feedUrl = feedUrl;
	}
	
	
}