Package org.mule.jms.commons.internal.source

Class NullJmsListenerLock

java.lang.Object
org.mule.jms.commons.internal.source.NullJmsListenerLock
All Implemented Interfaces:
JmsListenerLock
public class NullJmsListenerLock extends Object implements JmsListenerLock
Null pattern implementation for JmsListenerLock which doesn't lock the listener waiting for the message processing. The usage of this lock will led to the JmsListenerLock work asynchronously.
Since:
1.0

  • Constructor Summary

    Constructors
    Constructor
    Description
    NullJmsListenerLock()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    executeOnListenerThread(Runnable runnable)
    Executes a runnable on the blocked Listener thread.
    void
    init()
    Configures the Lock to their initial state.
    void
    lock()
    Locks the listener waiting to the message to be processed through the flow
    void
    unlock()
    Unlocks the listener indicating that message has been processed correctly
    void
    unlockWithFailure()
    Unlocks the listener indicating that message has been processed with failures and the error should be propagated
    void
    unlockWithFailure(org.mule.runtime.api.message.Error error)
    Unlocks the listener indicating that message has been processed with failures and the error should be propagated

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • NullJmsListenerLock

      public NullJmsListenerLock()

  • Method Details

    • lock

      public void lock()
      Description copied from interface: JmsListenerLock
      Locks the listener waiting to the message to be processed through the flow
      Specified by:
      lock in interface JmsListenerLock

    • unlock

      public void unlock()
      Description copied from interface: JmsListenerLock
      Unlocks the listener indicating that message has been processed correctly
      Specified by:
      unlock in interface JmsListenerLock

    • unlockWithFailure

      public void unlockWithFailure()
      Description copied from interface: JmsListenerLock
      Unlocks the listener indicating that message has been processed with failures and the error should be propagated
      Specified by:
      unlockWithFailure in interface JmsListenerLock

    • unlockWithFailure

      public void unlockWithFailure(org.mule.runtime.api.message.Error error)
      Description copied from interface: JmsListenerLock
      Unlocks the listener indicating that message has been processed with failures and the error should be propagated
      Specified by:
      unlockWithFailure in interface JmsListenerLock
      Parameters:
      error - The error to propagate inside the message listener

    • executeOnListenerThread

      public void executeOnListenerThread(Runnable runnable)
      Description copied from interface: JmsListenerLock
      Executes a runnable on the blocked Listener thread.
      Specified by:
      executeOnListenerThread in interface JmsListenerLock
      Parameters:
      runnable - to execute

    • init

      public void init()
      Description copied from interface: JmsListenerLock
      Configures the Lock to their initial state.
      Specified by:
      init in interface JmsListenerLock