Package org.openwms.common.comm.app

Class TenantInterception

java.lang.Object
org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
org.openwms.common.comm.app.TenantInterception
All Implemented Interfaces:
Runnable, org.springframework.integration.ip.tcp.connection.TcpConnection, org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptor, org.springframework.integration.ip.tcp.connection.TcpListener, org.springframework.integration.ip.tcp.connection.TcpSender
class TenantInterception extends org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
A TenantInterception initializes a context to propagate tenant and identity information.
Author:
Heiko Scherrer

  • Field Summary

    Fields inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    TenantInterception(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    onMessage(org.springframework.messaging.Message<?> message)
    Enrich the processing context of the incoming message with the information we get from the message.

    Methods inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport

    addNewConnection, close, getConnectionFactoryName, getConnectionId, getDeserializer, getDeserializerStateKey, getHostAddress, getHostName, getListener, getPayload, getPort, getSender, getSenders, getSerializer, getSocketInfo, getSslSession, getTheConnection, hasRealSender, incrementAndGetConnectionSequence, isOpen, isServer, registerListener, registerSender, registerSenders, removeDeadConnection, run, send, setDeserializer, setMapper, setSerializer, setTheConnection

    Methods inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport

    closeConnection, enableManualListenerRegistration, getMapper, isNoReadErrorOnClose, publishConnectionCloseEvent, publishConnectionExceptionEvent, publishConnectionOpenEvent, publishEvent, registerTestListener, sendExceptionToListener, setNeedsTest, setNoReadErrorOnClose, setWrapped, setWrapper, toString

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.integration.ip.tcp.connection.TcpConnection

    shutdownInput, shutdownOutput

  • Constructor Details

    • TenantInterception

      public TenantInterception(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)

  • Method Details

    • onMessage

      public boolean onMessage(org.springframework.messaging.Message<?> message)
      Enrich the processing context of the incoming message with the information we get from the message.
      Specified by:
      onMessage in interface org.springframework.integration.ip.tcp.connection.TcpListener
      Overrides:
      onMessage in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport