Package com.onenetwork.platform.integ.msg

Class MessageTransform

java.lang.Object
com.onenetwork.platform.integ.msg.MessageTransform
Direct Known Subclasses:
DelimiterTransform, SplitPayloadTransform
public abstract class MessageTransform
extends java.lang.Object
Extend this base class to transform a message payload during enqueue or dequeue of a Message.

  • Constructor Summary

    Constructors 
    Constructor Description
    MessageTransform()  

  • Method Summary

    Modifier and Type Method Description
    abstract void transform​(java.io.InputStream in, java.io.OutputStream out, MessageTransformContext transformContext)
    Implementor should read the payload from the InputStream and write it to the OutputStream.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • transform

      public abstract void transform​(java.io.InputStream in, java.io.OutputStream out, MessageTransformContext transformContext) throws java.lang.Exception
      Implementor should read the payload from the InputStream and write it to the OutputStream. It is not necessary to close the streams (the caller will close them explicitly).
      Parameters:
      in - InputStream of the orginal payload
      out - OutputStream of the transformed payload
      transformContext - Context contains user information who is performing this transformation
      Throws:
      java.lang.Exception - any exception to retry the transform, or MessageTransformFailedException to fail without retry