Package org.ikasan.testharness.flow.jms

Class BrowseMessagesOnQueueVerifier

  • All Implemented Interfaces:
    java.lang.Runnable
    public class BrowseMessagesOnQueueVerifier
extends java.lang.Object
implements java.lang.Runnable
    Similar to MessageListenerVerifier but does not create a JMS consumer instead only browses the contents of queues. This can only be used with queues NOT topics. Should be used when tests are run to share the same spring boot context as MessageListenerVerifier can block consumption by subsequent flows downstream of the destination it was listening on.

    • Constructor Summary

      Constructors 
      Constructor Description
      BrowseMessagesOnQueueVerifier​(java.lang.String brokerUrl, java.lang.String destinationName)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.List<java.lang.Object> getCaptureResults()  
      void run()  
      void start()  
      void stop()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • BrowseMessagesOnQueueVerifier

        public BrowseMessagesOnQueueVerifier​(java.lang.String brokerUrl,
                                     java.lang.String destinationName)
                              throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException

    • Method Detail

      • start

        public void start()

      • stop

        public void stop()

      • getCaptureResults

        public java.util.List<java.lang.Object> getCaptureResults()

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable