org.jboss.messaging.core.distributed.queue
Class QueuePeer

java.lang.Object
  extended byorg.jboss.messaging.core.distributed.PeerSupport
      extended byorg.jboss.messaging.core.distributed.queue.QueuePeer
All Implemented Interfaces:
Peer, PeerFacade, QueueFacade, ServerFacade

public class QueuePeer
extends PeerSupport
implements QueueFacade

The class that mediates the access of a distributed queue instance to the group.

Version:
$Revision: 1019 $ $Id: QueuePeer.java 1019 2006-07-17 17:15:04Z timfox $
Author:
Ovidiu Feodorov

Field Summary
protected  java.io.Serializable pipeID
           
protected  DistributedQueue queue
           
 
Fields inherited from class org.jboss.messaging.core.distributed.PeerSupport
dispatcher, joined, peerID, rpcServer, TIMEOUT, viewKeeper
 
Constructor Summary
QueuePeer(DistributedQueue queue, RpcDispatcher dispatcher)
           
 
Method Summary
protected  RemotePeer createRemotePeer(RemotePeerInfo thatPeerInfo)
          Create a local representation of a remote peer.
protected  void doJoin()
           
protected  void doLeave()
           
 boolean forward(PeerIdentity targetID)
          TODO: experimental The originator requests the first undelivered message maintained by this queue peer to be forwared to it.
protected  RemotePeerInfo getRemotePeerInfo()
          Create a representation of myself to be returned to other peers that need this information.
 java.util.List remoteBrowse(PeerIdentity originator, Filter filter)
           
 java.lang.String toString()
           
 
Methods inherited from class org.jboss.messaging.core.distributed.PeerSupport
exclude, getDispatcher, getGroupID, getID, getPeerIdentity, getView, hasJoined, include, join, leave, ping, ping
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.jboss.messaging.core.distributed.PeerFacade
exclude, include, ping
 
Methods inherited from interface org.jboss.messaging.core.distributed.util.ServerFacade
getID
 

Field Detail

pipeID

protected java.io.Serializable pipeID

queue

protected DistributedQueue queue
Constructor Detail

QueuePeer

public QueuePeer(DistributedQueue queue,
                 RpcDispatcher dispatcher)
Method Detail

remoteBrowse

public java.util.List remoteBrowse(PeerIdentity originator,
                                   Filter filter)
Specified by:
remoteBrowse in interface QueueFacade

forward

public boolean forward(PeerIdentity targetID)
Description copied from interface: QueueFacade
TODO: experimental The originator requests the first undelivered message maintained by this queue peer to be forwared to it. This queue peer should return true if it has undelivered messages and it asynchronously initiated the forwarding process, or false otherwise.

Specified by:
forward in interface QueueFacade

toString

public java.lang.String toString()

doJoin

protected void doJoin()
               throws DistributedException
Specified by:
doJoin in class PeerSupport
Throws:
DistributedException

doLeave

protected void doLeave()
                throws DistributedException
Specified by:
doLeave in class PeerSupport
Throws:
DistributedException

createRemotePeer

protected RemotePeer createRemotePeer(RemotePeerInfo thatPeerInfo)
Description copied from class: PeerSupport
Create a local representation of a remote peer.

Specified by:
createRemotePeer in class PeerSupport

getRemotePeerInfo

protected RemotePeerInfo getRemotePeerInfo()
Description copied from class: PeerSupport
Create a representation of myself to be returned to other peers that need this information.

Specified by:
getRemotePeerInfo in class PeerSupport


Copyright © 2006 JBoss Inc. All Rights Reserved.