DiscoveryServiceImpl (Project JXTA J2SE Reference Implementation)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

Project JXTA

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

net.jxta.impl.discovery
Class DiscoveryServiceImpl

java.lang.Object
  net.jxta.impl.discovery.DiscoveryServiceImpl

All Implemented Interfaces:: EventListener, DiscoveryService, Srdi.SrdiInterface, Module, RendezvousListener, QueryHandler, SrdiHandler, Service

public class DiscoveryServiceImpl
extends Object
implements DiscoveryService, QueryHandler, RendezvousListener, SrdiHandler, Srdi.SrdiInterface
extends Object
implements DiscoveryService, QueryHandler, RendezvousListener, SrdiHandler, Srdi.SrdiInterface

This Discovery Service implementation provides a mechanism to discover peers within the horizon of the resolver service. The horizon is normally restricted to the group's boundaries but this is not an absolute requirement. Use of the Resolver service is not an absolute requirement either for a discovery service, but this is what this is part of the platform and default net peer group protocol set, which this code implements.

This implementation uses the standard JXTA Peer Discovery Protocol (PDP).

The DiscoveryService service also provides a way to obtain information from a specified peer and request other peer advertisements, this method is particularly useful in the case of a portal where new relationships may be established starting from a predetermined peer (perhaps described in address book, or through an invitation)

See Also:: DiscoveryService, DiscoveryQueryMsg, DiscoveryQuery, DiscoveryResponseMsg, DiscoveryResponse, ResolverService, JXTA Protocols Specification : Peer Discovery Protocol

Field Summary
`protected Cm`	`cm` The cache manager we're going to use to cache jxta advertisements
`protected static String[]`	`dirname` adv types

Fields inherited from interface net.jxta.discovery.DiscoveryService
`ADV, DEFAULT_EXPIRATION, DEFAULT_LIFETIME, GROUP, INFINITE_LIFETIME, NO_EXPIRATION, PEER`

Fields inherited from interface net.jxta.platform.Module
`START_AGAIN_PROGRESS, START_AGAIN_STALLED, START_OK`

Constructor Summary
`DiscoveryServiceImpl()`

Method Summary
`void`	`addDiscoveryListener(DiscoveryListener listener)`
`void`	`flushAdvertisement(Advertisement adv)`
`void`	`flushAdvertisements(String id, int type)`
`long`	`getAdvExpirationTime(Advertisement adv)`
`long`	`getAdvExpirationTime(ID id, int type)`
`long`	`getAdvLifeTime(Advertisement adv)`
`long`	`getAdvLifeTime(ID id, int type)`
`Advertisement`	`getImplAdvertisement()`
`Service`	`getInterface()`
`Enumeration`	`getLocalAdvertisements(int type, String attribute, String value)`
`int`	`getRemoteAdvertisements(String peer, int type, String attribute, String value, int threshold)`
`int`	`getRemoteAdvertisements(String peer, int type, String attribute, String value, int threshold, DiscoveryListener listener)`
`void`	`init(PeerGroup pg, ID assignedID, Advertisement impl)`
`void`	`messageSendFailed(PeerID peerid, OutgoingMessageEvent e)`
`int`	`processQuery(ResolverQueryMsg query)`
`void`	`processResponse(ResolverResponseMsg response)`
`boolean`	`processSrdi(ResolverSrdiMsg message)`
`void`	`publish(Advertisement adv)`
`void`	`publish(Advertisement adv, int type)`
`void`	`publish(Advertisement adv, int type, long lifetime, long expiration)`
`void`	`publish(Advertisement adv, long lifetime, long expiration)`
`void`	`pushEntries(boolean all)` Pushe SRDI entries.
`protected void`	`pushSrdi(ID peer, int type, boolean all)` push srdi entries
`void`	`remotePublish(Advertisement adv)`
`void`	`remotePublish(Advertisement adv, int type)`
`void`	`remotePublish(Advertisement adv, int type, long timeout)`
`void`	`remotePublish(Advertisement adv, long timeout)`
`void`	`remotePublish(String peerid, Advertisement adv)`
`void`	`remotePublish(String peerid, Advertisement adv, int type)`
`void`	`remotePublish(String peerid, Advertisement adv, int type, long timeout)`
`void`	`remotePublish(String peerid, Advertisement adv, long timeout)`
`boolean`	`removeDiscoveryListener(DiscoveryListener listener)`
`void`	`rendezvousEvent(RendezvousEvent event)`
`int`	`startApp(String[] arg)`
`void`	`stopApp()` dettach from the resolver

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Field Detail

cm

protected Cm cm

The cache manager we're going to use to cache jxta advertisements

dirname

protected static final String[] dirname

adv types

Constructor Detail