Class DefaultPooledExchange

java.lang.Object
org.apache.camel.support.DefaultPooledExchange
All Implemented Interfaces:
org.apache.camel.Exchange, org.apache.camel.ExchangeExtension, org.apache.camel.PooledExchange, org.apache.camel.VariableAware
public final class DefaultPooledExchange extends Object implements org.apache.camel.PooledExchange
The default and only implementation of PooledExchange.

  • Field Details

    • internalProperties

      protected final EnumMap<org.apache.camel.ExchangePropertyKey, Object> internalProperties

    • properties

      protected Map<String,Object> properties

    • safeCopyProperties

      protected Map<String, org.apache.camel.SafeCopyProperty> safeCopyProperties

    • variableRepository

      protected org.apache.camel.support.ExchangeVariableRepository variableRepository

    • in

      protected org.apache.camel.Message in

    • out

      protected org.apache.camel.Message out

    • exception

      protected Exception exception

    • exchangeId

      protected String exchangeId

    • pattern

      protected org.apache.camel.ExchangePattern pattern

  • Constructor Details

    • DefaultPooledExchange

      public DefaultPooledExchange(org.apache.camel.CamelContext context)

    • DefaultPooledExchange

      public DefaultPooledExchange(org.apache.camel.Exchange parent)

    • DefaultPooledExchange

      public DefaultPooledExchange(org.apache.camel.CamelContext context, org.apache.camel.ExchangePattern pattern)

  • Method Details

    • isAutoRelease

      public boolean isAutoRelease()
      Specified by:
      isAutoRelease in interface org.apache.camel.PooledExchange

    • setAutoRelease

      public void setAutoRelease(boolean autoRelease)
      Specified by:
      setAutoRelease in interface org.apache.camel.PooledExchange

    • onDone

      public void onDone(org.apache.camel.PooledExchange.OnDoneTask task)
      Specified by:
      onDone in interface org.apache.camel.PooledExchange

    • done

      public void done()
      Specified by:
      done in interface org.apache.camel.PooledExchange

    • reset

      @Deprecated(since="4.4.0") public void reset(long created)
      Deprecated.
      Specified by:
      reset in interface org.apache.camel.PooledExchange

    • getIn

      public org.apache.camel.Message getIn()
      Specified by:
      getIn in interface org.apache.camel.Exchange

    • setIn

      public void setIn(org.apache.camel.Message in)
      Specified by:
      setIn in interface org.apache.camel.Exchange

    • getOut

      public org.apache.camel.Message getOut()
      Specified by:
      getOut in interface org.apache.camel.Exchange

    • setOut

      public void setOut(org.apache.camel.Message out)
      Specified by:
      setOut in interface org.apache.camel.Exchange

    • getClock

      public org.apache.camel.clock.Clock getClock()
      Specified by:
      getClock in interface org.apache.camel.Exchange

    • newFromEndpoint

      public static DefaultPooledExchange newFromEndpoint(org.apache.camel.Endpoint fromEndpoint)

    • newFromEndpoint

      public static DefaultPooledExchange newFromEndpoint(org.apache.camel.Endpoint fromEndpoint, org.apache.camel.ExchangePattern exchangePattern)

    • getCreated

      public long getCreated()
      Specified by:
      getCreated in interface org.apache.camel.Exchange

    • copy

      public org.apache.camel.Exchange copy()
      Specified by:
      copy in interface org.apache.camel.Exchange

    • getContext

      public org.apache.camel.CamelContext getContext()
      Specified by:
      getContext in interface org.apache.camel.Exchange

    • getProperty

      public Object getProperty(org.apache.camel.ExchangePropertyKey key)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • getProperty

      public <T> T getProperty(org.apache.camel.ExchangePropertyKey key, Class<T> type)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • getProperty

      public <T> T getProperty(org.apache.camel.ExchangePropertyKey key, Object defaultValue, Class<T> type)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • setProperty

      public void setProperty(org.apache.camel.ExchangePropertyKey key, Object value)
      Specified by:
      setProperty in interface org.apache.camel.Exchange

    • removeProperty

      public Object removeProperty(org.apache.camel.ExchangePropertyKey key)
      Specified by:
      removeProperty in interface org.apache.camel.Exchange

    • getProperty

      public Object getProperty(String name)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • getProperty

      public <T> T getProperty(String name, Class<T> type)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • getProperty

      public <T> T getProperty(String name, Object defaultValue, Class<T> type)
      Specified by:
      getProperty in interface org.apache.camel.Exchange

    • setProperty

      public void setProperty(String name, Object value)
      Specified by:
      setProperty in interface org.apache.camel.Exchange

    • removeProperty

      public Object removeProperty(String name)
      Specified by:
      removeProperty in interface org.apache.camel.Exchange

    • removeProperties

      public boolean removeProperties(String pattern)
      Specified by:
      removeProperties in interface org.apache.camel.Exchange

    • removeProperties

      public boolean removeProperties(String pattern, String... excludePatterns)
      Specified by:
      removeProperties in interface org.apache.camel.Exchange

    • getProperties

      public Map<String,Object> getProperties()
      Specified by:
      getProperties in interface org.apache.camel.Exchange

    • getAllProperties

      public Map<String,Object> getAllProperties()
      Specified by:
      getAllProperties in interface org.apache.camel.Exchange

    • hasProperties

      public boolean hasProperties()
      Specified by:
      hasProperties in interface org.apache.camel.Exchange

    • getVariable

      public Object getVariable(String name)
      Specified by:
      getVariable in interface org.apache.camel.Exchange
      Specified by:
      getVariable in interface org.apache.camel.VariableAware

    • getVariable

      public <T> T getVariable(String name, Class<T> type)
      Specified by:
      getVariable in interface org.apache.camel.Exchange

    • getVariable

      public <T> T getVariable(String name, Object defaultValue, Class<T> type)
      Specified by:
      getVariable in interface org.apache.camel.Exchange

    • setVariable

      public void setVariable(String name, Object value)
      Specified by:
      setVariable in interface org.apache.camel.Exchange
      Specified by:
      setVariable in interface org.apache.camel.VariableAware

    • removeVariable

      public Object removeVariable(String name)
      Specified by:
      removeVariable in interface org.apache.camel.Exchange

    • getVariables

      public Map<String,Object> getVariables()
      Specified by:
      getVariables in interface org.apache.camel.Exchange

    • hasVariables

      public boolean hasVariables()
      Specified by:
      hasVariables in interface org.apache.camel.Exchange

    • getIn

      public <T> T getIn(Class<T> type)
      Specified by:
      getIn in interface org.apache.camel.Exchange

    • getOut

      public <T> T getOut(Class<T> type)
      Specified by:
      getOut in interface org.apache.camel.Exchange

    • hasOut

      public boolean hasOut()
      Specified by:
      hasOut in interface org.apache.camel.Exchange

    • getMessage

      public org.apache.camel.Message getMessage()
      Specified by:
      getMessage in interface org.apache.camel.Exchange

    • getMessage

      public <T> T getMessage(Class<T> type)
      Specified by:
      getMessage in interface org.apache.camel.Exchange

    • setMessage

      public void setMessage(org.apache.camel.Message message)
      Specified by:
      setMessage in interface org.apache.camel.Exchange

    • getException

      public Exception getException()
      Specified by:
      getException in interface org.apache.camel.Exchange

    • getException

      public <T> T getException(Class<T> type)
      Specified by:
      getException in interface org.apache.camel.Exchange

    • setException

      public void setException(Throwable t)
      Specified by:
      setException in interface org.apache.camel.Exchange

    • getPattern

      public org.apache.camel.ExchangePattern getPattern()
      Specified by:
      getPattern in interface org.apache.camel.Exchange

    • setPattern

      public void setPattern(org.apache.camel.ExchangePattern pattern)
      Specified by:
      setPattern in interface org.apache.camel.Exchange

    • getFromEndpoint

      public org.apache.camel.Endpoint getFromEndpoint()
      Specified by:
      getFromEndpoint in interface org.apache.camel.Exchange
      Specified by:
      getFromEndpoint in interface org.apache.camel.ExchangeExtension

    • getFromRouteId

      public String getFromRouteId()
      Specified by:
      getFromRouteId in interface org.apache.camel.Exchange

    • getFromRouteGroup

      public String getFromRouteGroup()
      Specified by:
      getFromRouteGroup in interface org.apache.camel.Exchange

    • getExchangeId

      public String getExchangeId()
      Specified by:
      getExchangeId in interface org.apache.camel.Exchange

    • setExchangeId

      public void setExchangeId(String id)
      Specified by:
      setExchangeId in interface org.apache.camel.Exchange

    • isFailed

      public boolean isFailed()
      Specified by:
      isFailed in interface org.apache.camel.Exchange

    • isTransacted

      public boolean isTransacted()
      Specified by:
      isTransacted in interface org.apache.camel.Exchange

    • isRouteStop

      public boolean isRouteStop()
      Specified by:
      isRouteStop in interface org.apache.camel.Exchange
      Specified by:
      isRouteStop in interface org.apache.camel.ExchangeExtension

    • setRouteStop

      public void setRouteStop(boolean routeStop)
      Specified by:
      setRouteStop in interface org.apache.camel.Exchange
      Specified by:
      setRouteStop in interface org.apache.camel.ExchangeExtension

    • isExternalRedelivered

      public boolean isExternalRedelivered()
      Specified by:
      isExternalRedelivered in interface org.apache.camel.Exchange

    • isRollbackOnly

      public boolean isRollbackOnly()
      Specified by:
      isRollbackOnly in interface org.apache.camel.Exchange
      Specified by:
      isRollbackOnly in interface org.apache.camel.ExchangeExtension

    • setRollbackOnly

      public void setRollbackOnly(boolean rollbackOnly)
      Specified by:
      setRollbackOnly in interface org.apache.camel.Exchange
      Specified by:
      setRollbackOnly in interface org.apache.camel.ExchangeExtension

    • isRollbackOnlyLast

      public boolean isRollbackOnlyLast()
      Specified by:
      isRollbackOnlyLast in interface org.apache.camel.Exchange
      Specified by:
      isRollbackOnlyLast in interface org.apache.camel.ExchangeExtension

    • setRollbackOnlyLast

      public void setRollbackOnlyLast(boolean rollbackOnlyLast)
      Specified by:
      setRollbackOnlyLast in interface org.apache.camel.Exchange
      Specified by:
      setRollbackOnlyLast in interface org.apache.camel.ExchangeExtension

    • getUnitOfWork

      public org.apache.camel.spi.UnitOfWork getUnitOfWork()
      Specified by:
      getUnitOfWork in interface org.apache.camel.Exchange

    • configureMessage

      protected void configureMessage(org.apache.camel.Message message)
      Configures the message after it has been set on the exchange

    • createExchangeId

      protected String createExchangeId()

    • toString

      public final String toString()
      Overrides:
      toString in class Object

    • getExchangeExtension

      public org.apache.camel.ExchangeExtension getExchangeExtension()
      Specified by:
      getExchangeExtension in interface org.apache.camel.Exchange

    • setFromEndpoint

      public void setFromEndpoint(org.apache.camel.Endpoint fromEndpoint)
      Specified by:
      setFromEndpoint in interface org.apache.camel.ExchangeExtension

    • setFromRouteId

      public void setFromRouteId(String fromRouteId)
      Specified by:
      setFromRouteId in interface org.apache.camel.ExchangeExtension

    • isStreamCacheDisabled

      public boolean isStreamCacheDisabled()
      Specified by:
      isStreamCacheDisabled in interface org.apache.camel.ExchangeExtension

    • setStreamCacheDisabled

      public void setStreamCacheDisabled(boolean streamCacheDisabled)
      Specified by:
      setStreamCacheDisabled in interface org.apache.camel.ExchangeExtension

    • addOnCompletion

      public void addOnCompletion(org.apache.camel.spi.Synchronization onCompletion)
      Specified by:
      addOnCompletion in interface org.apache.camel.ExchangeExtension

    • isErrorHandlerHandledSet

      public boolean isErrorHandlerHandledSet()
      Specified by:
      isErrorHandlerHandledSet in interface org.apache.camel.ExchangeExtension

    • getErrorHandlerHandled

      public Boolean getErrorHandlerHandled()
      Specified by:
      getErrorHandlerHandled in interface org.apache.camel.ExchangeExtension

    • setErrorHandlerHandled

      public void setErrorHandlerHandled(Boolean errorHandlerHandled)
      Specified by:
      setErrorHandlerHandled in interface org.apache.camel.ExchangeExtension

    • isErrorHandlerHandled

      public boolean isErrorHandlerHandled()
      Specified by:
      isErrorHandlerHandled in interface org.apache.camel.ExchangeExtension

    • isRedeliveryExhausted

      public boolean isRedeliveryExhausted()
      Specified by:
      isRedeliveryExhausted in interface org.apache.camel.ExchangeExtension

    • setRedeliveryExhausted

      public void setRedeliveryExhausted(boolean redeliveryExhausted)
      Specified by:
      setRedeliveryExhausted in interface org.apache.camel.ExchangeExtension

    • getRedeliveryCounter

      public int getRedeliveryCounter()
      Specified by:
      getRedeliveryCounter in interface org.apache.camel.ExchangeExtension

    • setRedeliveryCounter

      public void setRedeliveryCounter(int redeliveryCounter)
      Specified by:
      setRedeliveryCounter in interface org.apache.camel.ExchangeExtension

    • getRedeliveryMaxCounter

      public int getRedeliveryMaxCounter()
      Specified by:
      getRedeliveryMaxCounter in interface org.apache.camel.ExchangeExtension

    • setRedeliveryMaxCounter

      public void setRedeliveryMaxCounter(int redeliveryMaxCounter)
      Specified by:
      setRedeliveryMaxCounter in interface org.apache.camel.ExchangeExtension

    • getSagaLongRunningAction

      public String getSagaLongRunningAction()
      Specified by:
      getSagaLongRunningAction in interface org.apache.camel.ExchangeExtension

    • setSagaLongRunningAction

      public void setSagaLongRunningAction(String sagaLongRunningAction)
      Specified by:
      setSagaLongRunningAction in interface org.apache.camel.ExchangeExtension

    • handoverCompletions

      public void handoverCompletions(org.apache.camel.Exchange target)
      Specified by:
      handoverCompletions in interface org.apache.camel.ExchangeExtension

    • handoverCompletions

      public List<org.apache.camel.spi.Synchronization> handoverCompletions()
      Specified by:
      handoverCompletions in interface org.apache.camel.ExchangeExtension

    • setUnitOfWork

      public void setUnitOfWork(org.apache.camel.spi.UnitOfWork unitOfWork)
      Specified by:
      setUnitOfWork in interface org.apache.camel.ExchangeExtension

    • setHistoryNodeId

      public void setHistoryNodeId(String historyNodeId)
      Specified by:
      setHistoryNodeId in interface org.apache.camel.ExchangeExtension

    • getHistoryNodeId

      public String getHistoryNodeId()
      Specified by:
      getHistoryNodeId in interface org.apache.camel.ExchangeExtension

    • getHistoryNodeSource

      public String getHistoryNodeSource()
      Specified by:
      getHistoryNodeSource in interface org.apache.camel.ExchangeExtension

    • setHistoryNodeSource

      public void setHistoryNodeSource(String historyNodeSource)
      Specified by:
      setHistoryNodeSource in interface org.apache.camel.ExchangeExtension

    • getHistoryNodeLabel

      public String getHistoryNodeLabel()
      Specified by:
      getHistoryNodeLabel in interface org.apache.camel.ExchangeExtension

    • setHistoryNodeLabel

      public void setHistoryNodeLabel(String historyNodeLabel)
      Specified by:
      setHistoryNodeLabel in interface org.apache.camel.ExchangeExtension

    • isNotifyEvent

      public boolean isNotifyEvent()
      Specified by:
      isNotifyEvent in interface org.apache.camel.ExchangeExtension

    • setNotifyEvent

      public void setNotifyEvent(boolean notifyEvent)
      Specified by:
      setNotifyEvent in interface org.apache.camel.ExchangeExtension

    • containsOnCompletion

      public boolean containsOnCompletion(org.apache.camel.spi.Synchronization onCompletion)
      Specified by:
      containsOnCompletion in interface org.apache.camel.ExchangeExtension

    • setTransacted

      public void setTransacted(boolean transacted)
      Specified by:
      setTransacted in interface org.apache.camel.ExchangeExtension

    • setInterruptable

      public void setInterruptable(boolean interruptable)
      Specified by:
      setInterruptable in interface org.apache.camel.ExchangeExtension

    • isInterrupted

      public boolean isInterrupted()
      Specified by:
      isInterrupted in interface org.apache.camel.ExchangeExtension

    • setInterrupted

      public void setInterrupted(boolean interrupted)
      Specified by:
      setInterrupted in interface org.apache.camel.ExchangeExtension

    • getInOrNull

      public <T> T getInOrNull(Class<T> type)
      Specified by:
      getInOrNull in interface org.apache.camel.ExchangeExtension

    • getDefaultConsumerCallback

      public org.apache.camel.AsyncCallback getDefaultConsumerCallback()
      Specified by:
      getDefaultConsumerCallback in interface org.apache.camel.ExchangeExtension

    • setDefaultConsumerCallback

      public void setDefaultConsumerCallback(org.apache.camel.AsyncCallback callback)
      Specified by:
      setDefaultConsumerCallback in interface org.apache.camel.ExchangeExtension

    • setSafeCopyProperty

      public void setSafeCopyProperty(String key, org.apache.camel.SafeCopyProperty value)
      Specified by:
      setSafeCopyProperty in interface org.apache.camel.ExchangeExtension

    • getSafeCopyProperty

      public <T> T getSafeCopyProperty(String key, Class<T> type)
      Specified by:
      getSafeCopyProperty in interface org.apache.camel.ExchangeExtension

    • copySafeCopyPropertiesTo

      public void copySafeCopyPropertiesTo(org.apache.camel.ExchangeExtension target)
      Specified by:
      copySafeCopyPropertiesTo in interface org.apache.camel.ExchangeExtension

    • isFailureHandled

      public boolean isFailureHandled()
      Specified by:
      isFailureHandled in interface org.apache.camel.ExchangeExtension

    • setFailureHandled

      public void setFailureHandled(boolean failureHandled)
      Specified by:
      setFailureHandled in interface org.apache.camel.ExchangeExtension

    • isExternalRedelivered

      public boolean isExternalRedelivered(org.apache.camel.Message message)
      Specified by:
      isExternalRedelivered in interface org.apache.camel.ExchangeExtension

    • copyInternalProperties

      public void copyInternalProperties(org.apache.camel.Exchange target)
      Specified by:
      copyInternalProperties in interface org.apache.camel.ExchangeExtension

    • setProperties

      public void setProperties(Map<String,Object> properties)
      Specified by:
      setProperties in interface org.apache.camel.ExchangeExtension

    • getInternalProperties

      public Map<String,Object> getInternalProperties()
      Specified by:
      getInternalProperties in interface org.apache.camel.ExchangeExtension

    • createCopyWithProperties

      public org.apache.camel.Exchange createCopyWithProperties(org.apache.camel.CamelContext context)
      Specified by:
      createCopyWithProperties in interface org.apache.camel.ExchangeExtension

    • resetExtension

      public void resetExtension()