Commiteb3809f

committed

fix(components): As2 note on stream closure design

1 parentdd49696 commiteb3809fCopy full SHA for eb3809f

File tree

-1

lines changed

components/camel-as2/camel-as2-api/src/main/java/org/apache/camel/component/as2/api
- AS2AsyncMDNServerConnection.java

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -150,7 +150,8 @@ public RequestHandlerThread(HttpService httpService, Socket inSocket) throws IOE`
`150`	`150`	`}`
`151`	`151`	`Http1Configcfg =Http1Config.custom().setBufferSize(DEFAULT_BUFFER_SIZE).build();`
`152`	`152`	`// parses the received AS2MessageEntity`
`153`		`-AS2BHttpServerConnectioninConn =newAS2BHttpServerConnection(cfg);`
	`153`	`+// NOTE: the connection will be closed after the execution of the process.`
	`154`	`+AS2BHttpServerConnectioninConn =newAS2BHttpServerConnection(cfg);// NOSONAR`
`154`	`155`	`inConn.bind(inSocket);`
`155`	`156`	`// TODO Update once baseline is Java 21`
`156`	`157`	`// setName(REQUEST_HANDLER_THREAD_NAME_PREFIX + threadId());`
`@@ -175,6 +176,7 @@ public void run() {`
`175`	`176`	`this.serverConnection.close();`
`176`	`177`	`}catch (finalIOExceptione) {`
`177`	`178`	`// ignore`
	`179`	`+LOG.warn("An exception happened while closing server connection: ignoring",e);`
`178`	`180`	`}`
`179`	`181`	`}`
`180`	`182`	`}`

Comments

(0)