Package akka.camel.internal

Class CamelExchangeAdapter

  • public class CamelExchangeAdapter
extends java.lang.Object
    Returns the exchange id

    • Constructor Summary

      Constructors 
      Constructor Description
      CamelExchangeAdapter​(org.apache.camel.Exchange exchange)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.camel.Exchange exchange()  
      java.lang.String getExchangeId()  
      boolean isOutCapable()
      Returns if the exchange is out capable.
      void setFailure​(FailureResult msg)
      Sets Exchange.getException from the given FailureResult message.
      void setRequest​(CamelMessage msg)
      Sets Exchange.getIn from the given CamelMessage object.
      void setResponse​(CamelMessage msg)
      Depending on the exchange pattern, sets Exchange.getIn or Exchange.getOut from the given CamelMessage object.
      AkkaCamelException toAkkaCamelException()
      Creates an AkkaCamelException object from the adapted Exchange.
      AkkaCamelException toAkkaCamelException​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
      Creates an AkkaCamelException object from the adapted Exchange.
      FailureResult toFailureMessage()
      Creates an immutable Failure object from the adapted Exchange so it can be used internally between Actors.
      FailureResult toFailureResult​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
      Creates an immutable FailureResult object from the adapted Exchange so it can be used internally between Actors.
      CamelMessage toRequestMessage()
      Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.
      CamelMessage toRequestMessage​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
      Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.
      CamelMessage toResponseMessage()
      Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors.
      CamelMessage toResponseMessage​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
      Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • CamelExchangeAdapter

        public CamelExchangeAdapter​(org.apache.camel.Exchange exchange)

    • Method Detail

      • exchange

        public org.apache.camel.Exchange exchange()

      • getExchangeId

        public java.lang.String getExchangeId()

      • isOutCapable

        public boolean isOutCapable()
        Returns if the exchange is out capable.
        Returns:
        (undocumented)

      • setFailure

        public void setFailure​(FailureResult msg)
        Sets Exchange.getException from the given FailureResult message. Headers of the FailureResult message are ignored.
        Parameters:
        msg - (undocumented)

      • setRequest

        public void setRequest​(CamelMessage msg)
        Sets Exchange.getIn from the given CamelMessage object.
        Parameters:
        msg - (undocumented)

      • setResponse

        public void setResponse​(CamelMessage msg)
        Depending on the exchange pattern, sets Exchange.getIn or Exchange.getOut from the given CamelMessage object. If the exchange is out-capable then the Exchange.getOut is set, otherwise Exchange.getIn.
        Parameters:
        msg - (undocumented)

      • toAkkaCamelException

        public AkkaCamelException toAkkaCamelException()
        Creates an AkkaCamelException object from the adapted Exchange. The cause of the AkkaCamelException is set to the exception on the adapted Exchange.

        Depending on the exchange pattern, puts the headers from Exchange.getIn or Exchange.getOut on the AkkaCamelException.

        If the exchange is out-capable then the headers of Exchange.getOut are used, otherwise the headers of Exchange.getIn are used.

        Returns:
        (undocumented)

      • toAkkaCamelException

        public AkkaCamelException toAkkaCamelException​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
        Creates an AkkaCamelException object from the adapted Exchange. The cause of the AkkaCamelException is set to the exception on the adapted Exchange.

        Depending on the exchange pattern, adds the supplied headers and the headers from Exchange.getIn or Exchange.getOut together and passes these to the AkkaCamelException.

        If the exchange is out-capable then the headers of Exchange.getOut are used, otherwise the headers of Exchange.getIn are used.

        Parameters:
        headers - additional headers to set on the exception in addition to those in the exchange.
        Returns:
        (undocumented)

      • toFailureMessage

        public FailureResult toFailureMessage()
        Creates an immutable Failure object from the adapted Exchange so it can be used internally between Actors.
        Returns:
        (undocumented)

      • toFailureResult

        public FailureResult toFailureResult​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
        Creates an immutable FailureResult object from the adapted Exchange so it can be used internally between Actors.

        Parameters:
        headers - additional headers to set on the created CamelMessage in addition to those in the Camel message.
        Returns:
        (undocumented)

      • toRequestMessage

        public CamelMessage toRequestMessage()
        Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.
        Returns:
        (undocumented)

      • toRequestMessage

        public CamelMessage toRequestMessage​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
        Creates an immutable CamelMessage object from Exchange.getIn so it can be used with Actors.

        Parameters:
        headers - additional headers to set on the created CamelMessage in addition to those in the Camel message.
        Returns:
        (undocumented)

      • toResponseMessage

        public CamelMessage toResponseMessage()
        Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors. If the exchange is out-capable then the Exchange.getOut is set, otherwise Exchange.getIn.
        Returns:
        (undocumented)

      • toResponseMessage

        public CamelMessage toResponseMessage​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> headers)
        Depending on the exchange pattern, creates an immutable CamelMessage object from Exchange.getIn or Exchange.getOut so it can be used with Actors. If the exchange is out-capable then the Exchange.getOut is set, otherwise Exchange.getIn.

        Parameters:
        headers - additional headers to set on the created CamelMessage in addition to those in the Camel message.
        Returns:
        (undocumented)