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.
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 |
PipeResolver
public PipeResolver(net.jxta.peergroup.PeerGroup g)
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.