Package org.sonews.feed

Klasse PullFeeder

java.lang.Object

org.sonews.daemon.DaemonRunner

org.sonews.feed.PullFeeder

Alle implementierten Schnittstellen:

Runnable, DaemonRunnable

class PullFeeder
extends DaemonRunner

The PullFeeder class regularily checks another Newsserver for new messages.

Seit:

sonews/0.5.0

Autor:

Christian Lins

Feldübersicht

Felder

Modifizierer und Typ	Feld	Beschreibung
private final Map<Subscription,Integer>	highMarks
private BufferedReader	in
private final org.slf4j.Logger	log
private PrintWriter	out
private Socket	socket
private final Set<Subscription>	subscriptions

Von Klasse geerbte Felder org.sonews.daemon.DaemonRunner

daemon

Konstruktorübersicht

Konstruktoren

Konstruktor	Beschreibung
PullFeeder()

Methodenübersicht

Modifizierer und Typ	Methode	Beschreibung
private void	addSubscription(Subscription sub)
private int	changeGroup(String groupName)	Changes to the given group and returns its high mark.
private void	connectTo(String host, int port)
private void	disconnect()
private void	getAndRepostArticle(Storage storage, Subscription sub, String messageID)
private List<String>	over(int start, int end)	Uses the OVER or XOVER command to get a list of message overviews that may be unknown to this feeder and are about to be peered.
protected void	pull(Subscription sub)
void	run()

Von Klasse geerbte Methoden org.sonews.daemon.DaemonRunner

setDaemon

Von Klasse geerbte Methoden java.lang.Object

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

Von Schnittstelle geerbte Methoden org.sonews.daemon.DaemonRunnable

dispose

Felddetails

highMarks

private final Map<Subscription,Integer> highMarks

in

private BufferedReader in

out

private PrintWriter out

socket

private Socket socket

subscriptions

private final Set<Subscription> subscriptions

log

private final org.slf4j.Logger log

Konstruktordetails

PullFeeder

PullFeeder()

Methodendetails

addSubscription

private void addSubscription(Subscription sub)

changeGroup

private int changeGroup(String groupName)
                 throws IOException

Changes to the given group and returns its high mark.

Parameter:

groupName -

Gibt zurück:

Löst aus:

IOException

connectTo

private void connectTo(String host,
 int port)
                throws IOException,
UnknownHostException

Löst aus:

IOException

UnknownHostException

disconnect

private void disconnect()
                 throws IOException

Löst aus:

IOException

getAndRepostArticle

private void getAndRepostArticle(Storage storage,
 Subscription sub,
 String messageID)

over

private List<String> over(int start,
 int end)
                   throws IOException

Uses the OVER or XOVER command to get a list of message overviews that may be unknown to this feeder and are about to be peered.

Parameter:

start -

end -

Gibt zurück:

A list of message ids with potentially interesting messages.

Löst aus:

IOException

pull

protected void pull(Subscription sub)

run

public void run()