Class JmsState

java.lang.Object
org.apache.storm.jms.trident.JmsState
All Implemented Interfaces:
State

public class JmsState extends Object implements State
  • Constructor Details

  • Method Details

    • prepare

      protected void prepare()
    • beginCommit

      public void beginCommit(Long someLong)
      Specified by:
      beginCommit in interface State
    • commit

      public void commit(Long someLong)
      Specified by:
      commit in interface State
    • updateState

      public void updateState(List<TridentTuple> tuples, TridentCollector collector) throws javax.jms.JMSException
      Throws:
      javax.jms.JMSException