org.jboss.messaging.core.distributed.pipe
Class DistributedPipeOutput
java.lang.Object
org.jboss.messaging.core.distributed.pipe.DistributedPipeOutput
- All Implemented Interfaces:
- PipeOutputFacade, ServerFacade
- public class DistributedPipeOutput
- extends java.lang.Object
- implements PipeOutputFacade
The "receiving end" of a distributed pipe.
Listens on a RpcDispatcher and synchronously handles messages sent by the input end of the
distributed pipe. Multiple distributed pipes can share the same DistributedPipeOutput instance
(and implicitly the pipeID), as long input instances are different.
- Version:
- $Revision: 461 $
$Id: DistributedPipeOutput.java 461 2005-11-20 00:07:53Z ovidiu $
- Author:
- Ovidiu Feodorov
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
pipeID
protected java.io.Serializable pipeID
receiver
protected Receiver receiver
DistributedPipeOutput
public DistributedPipeOutput(java.io.Serializable pipeID,
Receiver receiver)
- Parameters:
pipeID
- - the id of the distributed pipe. It must match the id used to instantiate the
input end of the pipe.
getID
public java.io.Serializable getID()
- Description copied from interface:
ServerFacade
- Return the ID under which server object is registered with the RpcServer.
- Specified by:
getID
in interface ServerFacade
handle
public Delivery handle(Routable r)
- Specified by:
handle
in interface PipeOutputFacade
getReceiver
public Receiver getReceiver()
toString
public java.lang.String toString()
Copyright © 2006 JBoss Inc. All Rights Reserved.