|
Spring Integration IP Extensions | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.integration.ip.tcp.connection.TcpConnectionSupport
org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
org.springframework.integration.x.ip.websocket.WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor
public class WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor
| 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 |
|---|
public WebSocketTcpConnectionInterceptorFactory.WebSocketTcpConnectionInterceptor()
| Method Detail |
|---|
public boolean onMessage(org.springframework.integration.Message<?> message)
onMessage in interface org.springframework.integration.ip.tcp.connection.TcpListeneronMessage in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupportpublic boolean doOnMessage(org.springframework.integration.Message<?> message)
public void close()
close in interface org.springframework.integration.ip.tcp.connection.TcpConnectionclose in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupportpublic java.util.Map<java.lang.String,java.lang.String> getAdditionalHeaders()
public void setTheConnection(org.springframework.integration.ip.tcp.connection.TcpConnectionSupport theConnection)
setTheConnection in class org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorSupport
|
Spring Integration IP Extensions | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||