bt.peerexchange

Class PeerExchangePeerSourceFactory

java.lang.Object

bt.peerexchange.PeerExchangePeerSourceFactory

All Implemented Interfaces:

PeerSourceFactory

public class PeerExchangePeerSourceFactory
extends Object
implements PeerSourceFactory

Note that this class implements a service. Hence, is not a part of the public API and is a subject to change.

Constructor Summary

Constructors

Constructor and Description
PeerExchangePeerSourceFactory(EventSource eventSource, IRuntimeLifecycleBinder lifecycleBinder, PeerExchangeConfig pexConfig, Config config)

Method Summary

Modifier and Type	Method and Description
void	consume(ExtendedHandshake handshake, MessageContext messageContext)
void	consume(bt.peerexchange.PeerExchange message, MessageContext messageContext)
PeerSource	getPeerSource(TorrentId torrentId) Create a peer source for a given torrent.
void	produce(Consumer<Message> messageConsumer, MessageContext messageContext)

Methods inherited from class java.lang.Object

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

Methods inherited from interface bt.peer.PeerSourceFactory

getPeerSource

Constructor Detail

PeerExchangePeerSourceFactory

@Inject
public PeerExchangePeerSourceFactory(EventSource eventSource,
                                             IRuntimeLifecycleBinder lifecycleBinder,
                                             PeerExchangeConfig pexConfig,
                                             Config config)

Method Detail

getPeerSource

public PeerSource getPeerSource(TorrentId torrentId)

Description copied from interface: PeerSourceFactory

Create a peer source for a given torrent. Implementations are free to return the same instance for all torrents.

Specified by:

getPeerSource in interface PeerSourceFactory

consume

public void consume(ExtendedHandshake handshake,
                    MessageContext messageContext)

consume

public void consume(bt.peerexchange.PeerExchange message,
                    MessageContext messageContext)

produce

public void produce(Consumer<Message> messageConsumer,
                    MessageContext messageContext)