Class AMQPNativeInboundTransformer

java.lang.Object
com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.InboundTransformer
com.swiftmq.impl.amqp.amqp.v01_00_00.transformer.AMQPNativeInboundTransformer

public class AMQPNativeInboundTransformer extends InboundTransformer
  • Constructor Details

    • AMQPNativeInboundTransformer

      public AMQPNativeInboundTransformer()
  • Method Details

    • setConfiguration

      public void setConfiguration(Map config) throws Exception
      Overrides:
      setConfiguration in class InboundTransformer
      Throws:
      Exception
    • transform

      public com.swiftmq.jms.MessageImpl transform(com.swiftmq.amqp.v100.generated.transport.performatives.TransferFrame frame, DestinationFactory destinationFactory) throws com.swiftmq.amqp.v100.client.AMQPException, javax.jms.JMSException
      Specified by:
      transform in class InboundTransformer
      Throws:
      com.swiftmq.amqp.v100.client.AMQPException
      javax.jms.JMSException