@@ -0,0 +1,1116 @@
+package eu.socialsensor.framework.streams.socialmedia.topsy;%0D%0A%0D%0Aimport org.apache.log4j.Logger;%0D%0A%0D%0Aimport eu.socialsensor.framework.common.domain.SocialNetworkSource;%0D%0Aimport eu.socialsensor.framework.retrievers.socialmedia.topsy.TopsyRetriever;%0D%0Aimport eu.socialsensor.framework.streams.Stream;%0D%0Aimport eu.socialsensor.framework.streams.StreamConfiguration;%0D%0Aimport eu.socialsensor.framework.streams.StreamException;%0D%0A%0D%0A%0D%0Apublic class TopsyStream extends Stream%7B%0D%0A%09private Logger logger = Logger.getLogger(TopsyStream.class);%0D%0A%09%0D%0A%09public static final SocialNetworkSource SOURCE = SocialNetworkSource.Topsy;%0D%0A%09%0D%0A%09private String key;%0D%0A%09%0D%0A%09@Override%0D%0A%09public void open(StreamConfiguration config) throws StreamException %7B%0D%0A%09%09logger.info(%22#Topsy : Open stream%22);%0D%0A%09%09%0D%0A%09%09if (config == null) %7B%0D%0A%09%09%09logger.error(%22#Topsy : Config file is null.%22);%0D%0A%09%09%09return;%0D%0A%09%09%7D%0D%0A%09%09%0D%0A%09%09key = config.getParameter(KEY);%0D%0A%09%09%0D%0A%09%09if (key == null) %7B%0D%0A%09%09%09logger.error(%22#Topsy : Stream requires authentication.%22);%0D%0A%09%09%09throw new StreamException(%22Stream requires authentication.%22);%0D%0A%09%09%7D%0D%0A%09%09%0D%0A%09%09retriever = new TopsyRetriever(key,this);%0D%0A%09%09%0D%0A%09%7D%0D%0A%7D%0D%0A

add topsy stream