Package com.swiftmq.impl.streams

Class StreamContext

java.lang.Object
com.swiftmq.impl.streams.StreamContext
public class StreamContext extends Object

  • Field Details

    • ctx

      public SwiftletContext ctx

    • stream

      public Stream stream

    • streamProcessor

      public StreamProcessor streamProcessor

    • messageBuilder

      public MessageBuilder messageBuilder

    • bindings

      public Value bindings

    • entity

      public Entity entity

    • usage

      public Entity usage

    • msgIdPrefix

      public String msgIdPrefix

    • classLoader

      public ClassLoader classLoader

  • Constructor Details

    • StreamContext

      public StreamContext(SwiftletContext ctx, Entity entity)

  • Method Details

    • nextId

      public String nextId()

    • setLastException

      public void setLastException(Exception lastException)

    • getLastException

      public Exception getLastException()

    • logStackTrace

      public void logStackTrace(Exception e)

    • addTransactionFlushListener

      public void addTransactionFlushListener(TransactionFlushListener listener)

    • removeTransactionFlushListener

      public void removeTransactionFlushListener(TransactionFlushListener listener)

    • addTransaction

      public void addTransaction(QueueTransaction transaction, TransactionFinishListener finishedListener)

    • commitTransactions

      public void commitTransactions() throws Exception
      Throws:
      Exception

    • commitTransactionsGlobalLock

      public void commitTransactionsGlobalLock() throws Exception
      Throws:
      Exception

    • commitTransactionsNoGlobalLock

      public void commitTransactionsNoGlobalLock() throws Exception
      Throws:
      Exception

    • rollbackTransactions

      public void rollbackTransactions()