ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2024-12-18 20:47:57 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

ENT-9941: Moved new connector factory to node-api

Browse Source
This commit is contained in:
Shams Asari 2023-05-12 17:42:27 +01:00
parent 71a99c861a
commit 13ca00deea
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node-api/src/main/kotlin/net/corda/nodeapi/internal/ArtemisTcpTransport.kt
View File

@ -182,7 +182,7 @@ class ArtemisTcpTransport {
threadPoolName: String,
trace: Boolean): TransportConfiguration {
return createTransport(
"net.corda.node.services.messaging.NodeNettyConnectorFactory",
NodeNettyConnectorFactory::class.java.name,
hostAndPort,
protocols,
options,

4
node/src/main/kotlin/net/corda/node/services/messaging/NodeNettyConnectorFactory.kt → node-api/src/main/kotlin/net/corda/nodeapi/internal/NodeNettyConnectorFactory.kt
View File

@ -1,9 +1,8 @@
package net.corda.node.services.messaging
package net.corda.nodeapi.internal
import io.netty.channel.ChannelPipeline
import io.netty.handler.logging.LogLevel
import io.netty.handler.logging.LoggingHandler
import net.corda.nodeapi.internal.ArtemisTcpTransport
import org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQClientProtocolManager
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector
import org.apache.activemq.artemis.spi.core.remoting.BufferHandler
@ -15,7 +14,6 @@ import org.apache.activemq.artemis.utils.ConfigurationHelper
import java.util.concurrent.Executor
import java.util.concurrent.ScheduledExecutorService
@Suppress("unused")
class NodeNettyConnectorFactory : ConnectorFactory {
override fun createConnector(configuration: MutableMap<String, Any>?,
handler: BufferHandler?,