Class RabbitMQPublisherImpl
- java.lang.Object
-
- org.apache.nutch.publisher.rabbitmq.RabbitMQPublisherImpl
-
- All Implemented Interfaces:
Configurable,Pluggable,NutchPublisher
public class RabbitMQPublisherImpl extends Object implements NutchPublisher
-
-
Field Summary
-
Fields inherited from interface org.apache.nutch.publisher.NutchPublisher
X_POINT_ID
-
-
Constructor Summary
Constructors Constructor Description RabbitMQPublisherImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConfigurationgetConf()voidpublish(Object event, Configuration conf)This method publishes the event.voidsetConf(Configuration arg0)booleansetConfig(Configuration conf)Use implementation specific configurations
-
-
-
Method Detail
-
setConfig
public boolean setConfig(Configuration conf)
Description copied from interface:NutchPublisherUse implementation specific configurations- Specified by:
setConfigin interfaceNutchPublisher- Parameters:
conf-Configurationto be used- Returns:
- true if set, false otherwise
-
publish
public void publish(Object event, Configuration conf)
Description copied from interface:NutchPublisherThis method publishes the event. Make sure that the event is a Java POJO to avoid Jackson JSON conversion errors. Currently we use the FetcherThreadEvent- Specified by:
publishin interfaceNutchPublisher- Parameters:
event- theObject(event) to publishconf-Configurationto be used
-
setConf
public void setConf(Configuration arg0)
- Specified by:
setConfin interfaceConfigurable
-
getConf
public Configuration getConf()
- Specified by:
getConfin interfaceConfigurable
-
-