Class MessageCatcher

  • All Implemented Interfaces:
    Runnable

    public class MessageCatcher
    extends Object
    implements Runnable
    This is a support class uses to receive messages by test cases that are sending messages either to a queue or a topic.
    • Field Detail

      • logger

        private static final org.slf4j.Logger logger
      • ackMode

        private int ackMode
      • stop

        private boolean stop
      • stopped

        private boolean stopped
      • started

        private boolean started
    • Constructor Detail

      • MessageCatcher

        public MessageCatcher​(String name)
    • Method Detail

      • getName

        public String getName()
      • setDestination

        public void setDestination​(Destination destination)
      • getCount

        public int getCount()
      • clearMessages

        public void clearMessages()
      • stop

        public void stop()
      • isStopped

        public boolean isStopped()
      • isStarted

        public boolean isStarted()
      • run

        public void run()
        Specified by:
        run in interface Runnable