org.codehaus.wadi.group.vm
Class VMDispatcher

java.lang.Object
  extended by org.codehaus.wadi.group.impl.AbstractDispatcher
      extended by org.codehaus.wadi.group.vm.VMDispatcher
All Implemented Interfaces:
Dispatcher, EnvelopeListener

public class VMDispatcher
extends AbstractDispatcher

Version:
$Revision: 1603 $

Field Summary
 
Fields inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher
_executor, _factory, _log, _rvMap, interceptors
 
Constructor Summary
VMDispatcher(VMBroker cluster, java.lang.String nodeName, EndPoint endPoint)
           
 
Method Summary
 Envelope createEnvelope()
           
protected  void doSend(Address target, Envelope envelope)
           
 Cluster getCluster()
           
 java.lang.String getPeerName(Address address)
           
 void start()
           
 void stop()
           
 java.lang.String toString()
           
 
Methods inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher
addInterceptor, addRendezVousEnvelope, attemptMultiRendezVous, attemptRendezVous, doOnEnvelope, exchangeSend, exchangeSend, exchangeSend, exchangeSend, getContext, getExecutor, hook, newRendezVous, onEnvelope, onInboundEnvelope, onOutboundEnvelope, register, removeInterceptor, reply, reply, reply, send, send, send, send, setRendezVous, unregister
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

VMDispatcher

public VMDispatcher(VMBroker cluster,
                    java.lang.String nodeName,
                    EndPoint endPoint)
Method Detail

getCluster

public Cluster getCluster()

start

public void start()
           throws MessageExchangeException
Throws:
MessageExchangeException

stop

public void stop()
          throws MessageExchangeException
Throws:
MessageExchangeException

getPeerName

public java.lang.String getPeerName(Address address)

doSend

protected void doSend(Address target,
                      Envelope envelope)
               throws MessageExchangeException
Specified by:
doSend in class AbstractDispatcher
Throws:
MessageExchangeException

createEnvelope

public Envelope createEnvelope()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2010. All Rights Reserved.