Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.mule.umo.impl
Class MuleProxy  view MuleProxy download MuleProxy.java

java.lang.Object
  extended byorg.mule.umo.impl.MuleProxy
All Implemented Interfaces:
java.lang.Runnable

public class MuleProxy
extends java.lang.Object
implements java.lang.Runnable

MuleProxy is a proxy to a MuleUMO. It is a poolable object that that can be executed in it's own thread.

Version:
$Revision: 1.11 $

Field Summary
private  org.mule.umo.UMOEvent event
          Holds the current event being processed
private static org.apache.commons.logging.Log log
          logger used by this class
private  MuleSession session
          A reference to the session for this proxy
private  boolean suspended
          Determines if the proxy is suspended
private  boolean synchronous
          Determines whether we are executing synchronously or not
private  org.mule.umo.UniversalMessageObject umo
          Holds the actual UMO
 
Constructor Summary
MuleProxy(MuleSession session, org.mule.umo.UniversalMessageObject umo)
          Constructs a Proxy using the UMO's Session and the UMO itself
 
Method Summary
 org.mule.umo.UMOEvent call(org.mule.umo.UMOEvent event)
          Makes a synchronous call on the UMO
 void destroy()
          Destroys the proxy by delegating the call to the UMO.
(package private)  void handleException(java.lang.Object source, java.lang.Throwable exception)
          When an exception occurs this method can be called to invoke the configured UMOExceptionStrategy on the UMO
 boolean isSuspended()
          Determines if the proxy is suspended
 void resume()
          Triggers the UMO to resume processing of events if it is suspended
 void run()
          This method will be called by whoever wishes to run your class implementing Runnable.
 void setEvent(org.mule.umo.UMOEvent event)
          Sets the current event being processed
 void start()
          Starts the proxy by delegating the call to the UMO.
 void stop()
          Stops the proxy by delegating the call to the UMO.
 void suspend()
          Controls the suspension of the UMO event processing
 java.lang.String toString()
          Convert this Object to a human-readable String.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

log

private static transient org.apache.commons.logging.Log log
logger used by this class


session

private MuleSession session
A reference to the session for this proxy


event

private org.mule.umo.UMOEvent event
Holds the current event being processed


umo

private org.mule.umo.UniversalMessageObject umo
Holds the actual UMO


synchronous

private boolean synchronous
Determines whether we are executing synchronously or not


suspended

private boolean suspended
Determines if the proxy is suspended

Constructor Detail

MuleProxy

public MuleProxy(MuleSession session,
                 org.mule.umo.UniversalMessageObject umo)
Constructs a Proxy using the UMO's Session and the UMO itself

Method Detail

destroy

public void destroy()
             throws org.mule.umo.UMOException
Destroys the proxy by delegating the call to the UMO. umo.destroy()


start

public void start()
           throws org.mule.umo.UMOException
Starts the proxy by delegating the call to the UMO. umo.start()


stop

public void stop()
          throws org.mule.umo.UMOException
Stops the proxy by delegating the call to the UMO. umo.stop()


setEvent

public void setEvent(org.mule.umo.UMOEvent event)
Sets the current event being processed


call

public org.mule.umo.UMOEvent call(org.mule.umo.UMOEvent event)
                           throws org.mule.umo.UMOException
Makes a synchronous call on the UMO


handleException

void handleException(java.lang.Object source,
                     java.lang.Throwable exception)
When an exception occurs this method can be called to invoke the configured UMOExceptionStrategy on the UMO


toString

public java.lang.String toString()
Description copied from class: java.lang.Object
Convert this Object to a human-readable String. There are no limits placed on how long this String should be or what it should contain. We suggest you make it as intuitive as possible to be able to place it into System.out.println() 55 and such.

It is typical, but not required, to ensure that this method never completes abruptly with a java.lang.RuntimeException.

This method will be called when performing string concatenation with this object. If the result is null, string concatenation will instead use "null".

The default implementation returns getClass().getName() + "@" + Integer.toHexString(hashCode()).


isSuspended

public boolean isSuspended()
Determines if the proxy is suspended


suspend

public void suspend()
Controls the suspension of the UMO event processing


resume

public void resume()
Triggers the UMO to resume processing of events if it is suspended


run

public void run()
Description copied from interface: java.lang.Runnable
This method will be called by whoever wishes to run your class implementing Runnable. Note that there are no restrictions on what you are allowed to do in the run method, except that you cannot throw a checked exception.

Specified by:
run in interface java.lang.Runnable