ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-18 02:39:51 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Remove debug logging left over from earlier AMQP development. (#2867)

Browse Source
This commit is contained in:
Matthew Nesbit 2018-05-03 13:44:05 +01:00 committed by GitHub
parent 20570d72cf
commit 0494e45037
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
node-api/src/main/kotlin/net/corda/nodeapi/internal/protonwrapper/engine/ConnectionStateMachine.kt
View File

@ -428,7 +428,6 @@ internal class ConnectionStateMachine(serverMode: Boolean,
} }
fun transportWriteMessage(msg: SendableMessageImpl) { fun transportWriteMessage(msg: SendableMessageImpl) {
log.debug { "Queue application message write uuid: ${msg.applicationProperties["_AMQ_DUPL_ID"]} ${javax.xml.bind.DatatypeConverter.printHexBinary(msg.payload)}" }
msg.buf = encodePayloadBytes(msg) msg.buf = encodePayloadBytes(msg)
val messageQueue = messageQueues.getOrPut(msg.topic, { LinkedList() }) val messageQueue = messageQueues.getOrPut(msg.topic, { LinkedList() })
messageQueue.offer(msg) messageQueue.offer(msg)

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

@ -103,7 +103,6 @@ internal class AMQPChannelHandler(private val serverMode: Boolean,
override fun channelRead(ctx: ChannelHandlerContext, msg: Any) { override fun channelRead(ctx: ChannelHandlerContext, msg: Any) {
try { try {
log.debug { "Received $msg" }
if (msg is ByteBuf) { if (msg is ByteBuf) {
eventProcessor!!.transportProcessInput(msg) eventProcessor!!.transportProcessInput(msg)
} }
@ -116,7 +115,6 @@ internal class AMQPChannelHandler(private val serverMode: Boolean,
override fun write(ctx: ChannelHandlerContext, msg: Any, promise: ChannelPromise) { override fun write(ctx: ChannelHandlerContext, msg: Any, promise: ChannelPromise) {
try { try {
try { try {
log.debug { "Sent $msg" }
when (msg) { when (msg) {
// Transfers application packet into the AMQP engine. // Transfers application packet into the AMQP engine.
is SendableMessageImpl -> { is SendableMessageImpl -> {