Questions tagged [spring-integration-ip]
31 questions
2
votes
1 answer
Spring Integration DSL Tcp: How to prevent excessive logging of Connection refused on the client side
I made both client and server able to wait for each other to connect, so they can be started independently in any order.
The solution described here does exactly that, out of the box, BUT client side keeps printing massive stack traces into our…
Espinosa
- 2,491
- 24
- 28
1
vote
1 answer
How to force TcpNetClientConnectionFactory to open a connection without sending a message?
I have a task to create a Spring-integration TCP client which should connect to a server and receive messages from it:
The server is responsible for sending "heartbeat" and data messages and doesn't expect any incoming messages from the client,…
Sergey
- 13
- 4
1
vote
2 answers
With TCP FailOverConnectionFactory is there a way to do custom health check and on failure fallback to failover?
I have a Tcp FailOverConnectionFactory supplied with two AbstarctClientConnectionFactory. Each AbstarctClientConnectionFactory will connect to different servers.
And Using TcpOutboundGateway for message exchange. Now i want to switch between the…
Manivelpvn
- 13
- 2
1
vote
1 answer
How to get reply in dynamic-tcp-client
I want to use dynamic-tcp-client
in my project as a dynamic-tcp-client. I want to get reply in this client,so I changed the interface ,add a retrun String.
@MessagingGateway()
public interface ToTCP {
@Gateway(requestChannel = "toTcp.input")
…
jsdsh
- 31
- 7
1
vote
1 answer
spring integration tcp client send simple message
I've been developing a project using spring framework 4. I'm trying to create a simple TCP client via spring-integration-ip library. I've adjusted all configurations:
applicationContext.xml
...
Dariush Jafari
- 5,223
- 7
- 42
- 71
0
votes
1 answer
TCP Connection getting closed after 300 seconds of idleness
I have implemented TCPClient for stream-oriented sockets which rely on the TCP/IP protocol. I have used Spring Integration.
My expectation was to create pool of 9 connections. Traffic would be handled by these 9 TCP connections only. But I realized…
lavin249
- 25
- 6
0
votes
1 answer
Is it correct way to log the open connections using CachingClientConnectionFactory
I am implementing TCP Client. I am using CachingClientConnectionFactory to create pool of 10 TCP Connections using TcpNetClientConnectionFactory. I am aiming to print connection ids of open-connections. I came across…
lavin249
- 25
- 6
0
votes
1 answer
Send unsolicited message to Spring TcpInboundGateway
I'm writing an IntegrationFlow using TcpInboundGateway. When the client connects and builds a connection to the server (inbound gateway), is there a way to send 'server initiated message' to that connection? I already know how to send 'reply' for…
Jay Han
- 5
- 3
0
votes
1 answer
How to handle socket open/close/error events using spring boot integration ip
I'm using spring boot and integration libraries in order to use a custom TCP/IP protocol in my application.
Here the configuration:
@EnableIntegration
@Configuration
class TcpServerConfiguration {
@Value("\${tcp.server.port}")
lateinit var…
Romain-p
- 518
- 2
- 9
- 26
0
votes
1 answer
Spring Integration : Failed to send reply after netcat's command
My use case :
Client netcat to send tcp socket to the server
echo -n "coincoincoin" | nc -v host port
Server tcp with Spring Integration receive the request from client
Sever receiving the request with TcpInboundGateway, process
Server send…
bacalum
- 1
- 1
0
votes
0 answers
spring boot integration ip (tcp) force flush in order to respond
I am now making TCP socket server using Spring boot integration ip.
public AbstractServerConnectionFactory serverConnectionFactory() {
TcpNioServerConnectionFactory serverConnectionFactory = new TcpNioServerConnectionFactory(port);
…
pincoin
- 665
- 5
- 19
0
votes
1 answer
SpringBoot IntegrationFlow Tcp.inboundGateway how to send client message on connect
I need send to client message on connect!
org.springframework.integration
spring-integration-ip
version 5.5.14
@Bean
public IntegrationFlow server() {
return IntegrationFlows.from(
Tcp.inboundGateway(
…
Dmitry Evgrafoov
- 13
- 1
- 2
0
votes
1 answer
Why do requests interfere with one another requests and slow performance with Spring Integration during load testing?
What I am doing? I'm connecting to a remote server using TLSv1.2 and sending a max of 300 bytes of data and receive a response back also of the same size.
What is expected to deliver? During load testing we are expected to deliver 1000TPS.
Use at…
Zahid Khan
- 2,130
- 2
- 18
- 31
0
votes
0 answers
how to create a client/server which receive more than 2048 Characters using spring ip integration TCP
How to create a client/server which receive more than 2048 Characters using spring ip integration TCP?
kasse kasse
- 1
- 1
0
votes
1 answer
How to set SO_REUSEADDR in a TCP Outbound Adapter?
I have several TCP/IP Outbound Adapters to send Messages to connecting clients. The TCP/IP protocol of communication requires the socket flags to be set: TCP_NODELAY, SO_REUSEADDR, and SO_KEEPALIVE.
@Override
public void start(String…
JBStonehenge
- 192
- 3
- 15