Spring Integration IP Extensions

org.springframework.integration.x.ip.websocket
Class WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor

java.lang.Object
  extended by org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
      extended by org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
          extended by org.springframework.integration.x.ip.websocket.WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor
All Implemented Interfaces:
java.lang.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
Enclosing class:
WebSocketTcpConnectionInterceptorFactory

public class WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor
extends org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport


Field Summary
 
Fields inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
logger
 
Constructor Summary
WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor()
           
 
Method Summary
 void close()
           
 boolean doOnMessage(org.springframework.integration.Message<?> message)
           
 java.util.Map<java.lang.String,java.lang.String> getAdditionalHeaders()
           
 boolean onMessage(org.springframework.integration.Message<?> message)
          When using NIO, we have to resequence the messages because frames may arrive out of order.
 void setTheConnection(org.springframework.integration.ip.tcp.connection.TcpConnectionSupport theConnection)
           
 
Methods inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
addNewConnection, getConnectionId, getDeserializer, getDeserializerStateKey, getHostAddress, getHostName, getListener, getPayload, getPort, getSender, getSerializer, getTheConnection, hasRealSender, incrementAndGetConnectionSequence, isOpen, isServer, isSingleUse, registerListener, registerSender, removeDeadConnection, run, send, setDeserializer, setMapper, setSerializer, setSingleUse
 
Methods inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
afterSend, closeConnection, getMapper, publishConnectionCloseEvent, publishConnectionExceptionEvent, publishConnectionOpenEvent, publishEvent
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor

public WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor()
Method Detail

onMessage

public boolean onMessage(org.springframework.integration.Message<?> message)
When using NIO, we have to resequence the messages because frames may arrive out of order. This is particularly an issue for some of the Autobahn tests where, for example, many pings are sent and the test expects the pongs to come back in the same order.

Specified by:
onMessage in interface org.springframework.integration.ip.tcp.connection.TcpListener
Overrides:
onMessage in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport

doOnMessage

public boolean doOnMessage(org.springframework.integration.Message<?> message)

close

public void close()
Specified by:
close in interface org.springframework.integration.ip.tcp.connection.TcpConnection
Overrides:
close in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport

getAdditionalHeaders

public java.util.Map<java.lang.String,java.lang.String> getAdditionalHeaders()

setTheConnection

public void setTheConnection(org.springframework.integration.ip.tcp.connection.TcpConnectionSupport theConnection)
Overrides:
setTheConnection in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport

Spring Integration IP Extensions