Package org.apache.nutch.publisher.rabbitmq

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

Modifier and Type	Method	Description
Configuration	getConf()
void	publish(Object event, Configuration conf)	This method publishes the event.
void	setConf(Configuration arg0)
boolean	setConfig(Configuration conf)	Use implementation specific configurations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RabbitMQPublisherImpl

public RabbitMQPublisherImpl()

Method Details

setConfig

public boolean setConfig(Configuration conf)

Description copied from interface: NutchPublisher

Use implementation specific configurations

Specified by:

setConfig in interface NutchPublisher

Parameters:

conf - Configuration to be used

Returns:

true if set, false otherwise

publish

public void publish(Object event,
 Configuration conf)

Description copied from interface: NutchPublisher

This 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:

publish in interface NutchPublisher

Parameters:

event - the Object (event) to publish

conf - Configuration to be used

setConf

public void setConf(Configuration arg0)

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Specified by:

getConf in interface Configurable