Project JXTA

net.jxta.impl.pipe
Class PipeResolver

java.lang.Object
  |
  +--net.jxta.impl.pipe.PipeResolver

public class PipeResolver
extends java.lang.Object
implements net.jxta.resolver.QueryHandler, JxtaTimerHandler

This class implements the PipeService ResolverService.


Inner Class Summary
protected  class PipeResolver.PendingQuery
           
 class PipeResolver.PipeEntry
           
 
Constructor Summary
PipeResolver(net.jxta.peergroup.PeerGroup g)
           
 
Method Summary
 java.lang.String find(java.lang.String ipId, long timeout, boolean nocache)
           
 java.lang.String findLocal(java.lang.String ipId)
           
 void forget(java.lang.String ipId)
           
 void forgetCached(java.lang.String ipId)
           
 net.jxta.protocol.ResolverResponseMsg processQuery(net.jxta.protocol.ResolverQueryMsg query)
          Process the Query, and genrate response
 void pushResponse(net.jxta.protocol.ResolverResponseMsg response)
           
 void register(java.lang.String ipId, net.jxta.pipe.InputPipe ip)
           
 void registerCached(java.lang.String ipId, java.lang.String peer)
           
 void sendVerify(java.lang.String peer, java.lang.String ipId)
           
 void signal(JxtaTimer timer)
          This method is invoked by the timer when it is set off.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PipeResolver

public PipeResolver(net.jxta.peergroup.PeerGroup g)
Method Detail

registerCached

public void registerCached(java.lang.String ipId,
                           java.lang.String peer)

register

public void register(java.lang.String ipId,
                     net.jxta.pipe.InputPipe ip)

forget

public void forget(java.lang.String ipId)

forgetCached

public void forgetCached(java.lang.String ipId)

findLocal

public java.lang.String findLocal(java.lang.String ipId)

find

public java.lang.String find(java.lang.String ipId,
                             long timeout,
                             boolean nocache)

sendVerify

public void sendVerify(java.lang.String peer,
                       java.lang.String ipId)

pushResponse

public void pushResponse(net.jxta.protocol.ResolverResponseMsg response)
Specified by:
pushResponse in interface net.jxta.resolver.QueryHandler

processQuery

public net.jxta.protocol.ResolverResponseMsg processQuery(net.jxta.protocol.ResolverQueryMsg query)
                                                   throws net.jxta.exception.NoResponseException,
                                                          net.jxta.exception.DiscardQueryException,
                                                          java.io.IOException,
                                                          net.jxta.exception.ResendQueryException
Process the Query, and genrate response
Specified by:
processQuery in interface net.jxta.resolver.QueryHandler
Parameters:
GenericResolverMsg - the query to process
Returns:
ResolverResponseMsg "Response"

signal

public void signal(JxtaTimer timer)
Description copied from interface: JxtaTimerHandler
This method is invoked by the timer when it is set off.
Specified by:
signal in interface JxtaTimerHandler
Tags copied from interface: JxtaTimerHandler
Parameters:
timer - a reference to the timer that has went off.

Project JXTA