|
Project JXTA | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.impl.pipe.InputPipeImpl
net.jxta.impl.pipe.UnicastInputPipeImpl
net.jxta.impl.pipe.SecureInputPipeImpl
Implements the InputPipe
interface by listening on the
endpoint for messages to service "PipeService" and a param of the Pipe ID.
Field Summary | |
protected boolean |
closed
|
protected PipeMsgListener |
listener
|
protected PipeAdvertisement |
pipeAdv
|
protected PipeID |
pipeID
|
protected UnbiasedQueue |
queue
|
protected static int |
QUEUESIZE
|
protected PipeRegistrar |
registrar
|
Constructor Summary | |
(package private) |
SecureInputPipeImpl(PipeResolver r,
PipeAdvertisement adv)
Constructor for the SecureInputPipeImpl object |
(package private) |
SecureInputPipeImpl(PipeResolver r,
PipeAdvertisement adv,
PipeMsgListener listener)
Constructor for the SecureInputPipeImpl object |
Method Summary | |
void |
close()
|
protected void |
finalize()
Closes the pipe. |
PipeAdvertisement |
getAdvertisement()
Gets the pipe advertisement |
String |
getName()
Gets the pipe name |
ID |
getPipeID()
Gets the pipe id |
String |
getType()
Gets the pipe type |
Message |
poll(int timeout)
|
void |
processIncomingMessage(Message msg,
EndpointAddress srcAddr,
EndpointAddress dstAddr)
|
Message |
waitForMessage()
|
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static final int QUEUESIZE
protected PipeRegistrar registrar
protected PipeAdvertisement pipeAdv
protected PipeID pipeID
protected volatile boolean closed
protected PipeMsgListener listener
protected UnbiasedQueue queue
Constructor Detail |
SecureInputPipeImpl(PipeResolver r, PipeAdvertisement adv) throws IOException
r
- pipe resolveradv
- pipe advertisementSecureInputPipeImpl(PipeResolver r, PipeAdvertisement adv, PipeMsgListener listener) throws IOException
r
- pipe resolveradv
- pipe advertisementMethod Detail |
public void processIncomingMessage(Message msg, EndpointAddress srcAddr, EndpointAddress dstAddr)
processIncomingMessage
in interface EndpointListener
processIncomingMessage
in class InputPipeImpl
public void close()
close
in interface InputPipe
close
in class InputPipeImpl
protected void finalize() throws Throwable
Throwable
public Message waitForMessage() throws InterruptedException
waitForMessage
in interface InputPipe
InterruptedException
public Message poll(int timeout) throws InterruptedException
poll
in interface InputPipe
InterruptedException
public String getType()
getType
in interface InputPipe
public ID getPipeID()
getPipeID
in interface InputPipe
public String getName()
getName
in interface InputPipe
public PipeAdvertisement getAdvertisement()
getAdvertisement
in interface InputPipe
|
JXTA J2SE | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |