org.hypergraphdb.peer.jxta
Class DefaultJXTANetwork

java.lang.Object
  org.hypergraphdb.peer.jxta.DefaultJXTANetwork

All Implemented Interfaces:

JXTANetwork, PeerNetwork

public class DefaultJXTANetwork
extends java.lang.Object
implements JXTANetwork

Handles problems related to the JXTA network : intialize, stop, discovery, publishing, etc

Author:

Cipri Costa

Constructor Summary

DefaultJXTANetwork()

Method Summary

void	addOwnPipe(net.jxta.pipe.PipeID pipeId)
void	addPeerPresenceListener(PeerPresenceListener listener)
boolean	configure(java.util.Map<java.lang.String,java.lang.Object> config)
java.util.Set<net.jxta.document.Advertisement>	getAdvertisements()
HGAtomPredicate	getAtomInterests(java.lang.Object peerId)
RemotePeer	getConnectedPeer(java.lang.String peerName)
java.util.List<RemotePeer>	getConnectedPeers()
net.jxta.peergroup.PeerGroup	getPeerGroup()
java.lang.Object	getPeerId(java.lang.Object peer)
net.jxta.document.Advertisement	getPipeAdv()
boolean	hasRemotePipes()
void	join(java.util.concurrent.ExecutorService executorService)
void	publishAdv(net.jxta.document.Advertisement adv)
void	removePeerPresenceListener(PeerPresenceListener listener)
void	setAtomInterests(java.lang.Object peerId, HGAtomPredicate interest)
void	stop()
void	waitForRemotePipe()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJXTANetwork

public DefaultJXTANetwork()

Method Detail

configure

public boolean configure(java.util.Map<java.lang.String,java.lang.Object> config)

Specified by:

configure in interface PeerNetwork

stop

public void stop()

Specified by:

stop in interface PeerNetwork

join

public void join(java.util.concurrent.ExecutorService executorService)

Specified by:

join in interface PeerNetwork

getPeerGroup

public net.jxta.peergroup.PeerGroup getPeerGroup()

Specified by:

getPeerGroup in interface JXTANetwork

publishAdv

public void publishAdv(net.jxta.document.Advertisement adv)

Specified by:

publishAdv in interface JXTANetwork

getPipeAdv

public net.jxta.document.Advertisement getPipeAdv()

Specified by:

getPipeAdv in interface JXTANetwork

getAdvertisements

public java.util.Set<net.jxta.document.Advertisement> getAdvertisements()

Specified by:

getAdvertisements in interface JXTANetwork

hasRemotePipes

public boolean hasRemotePipes()

addOwnPipe

public void addOwnPipe(net.jxta.pipe.PipeID pipeId)

Specified by:

addOwnPipe in interface JXTANetwork

getAtomInterests

public HGAtomPredicate getAtomInterests(java.lang.Object peerId)

Specified by:

getAtomInterests in interface PeerNetwork

setAtomInterests

public void setAtomInterests(java.lang.Object peerId,
                             HGAtomPredicate interest)

Specified by:

setAtomInterests in interface PeerNetwork

getPeerId

public java.lang.Object getPeerId(java.lang.Object peer)

Specified by:

getPeerId in interface PeerNetwork

waitForRemotePipe

public void waitForRemotePipe()

Specified by:

waitForRemotePipe in interface PeerNetwork

getConnectedPeers

public java.util.List<RemotePeer> getConnectedPeers()

Specified by:

getConnectedPeers in interface PeerNetwork

getConnectedPeer

public RemotePeer getConnectedPeer(java.lang.String peerName)

Specified by:

getConnectedPeer in interface PeerNetwork

addPeerPresenceListener

public void addPeerPresenceListener(PeerPresenceListener listener)

Specified by:

addPeerPresenceListener in interface PeerNetwork

removePeerPresenceListener

public void removePeerPresenceListener(PeerPresenceListener listener)

Specified by:

removePeerPresenceListener in interface PeerNetwork