@@ -122,8 +122,7 @@ class ReplayQueueBrowser {
122
122
123
123
return messages . map ( ( msg , n ) => ( {
124
124
meta : msgMetaData [ n ] ,
125
- payload : msg . getBinaryAttachment ( ) . toString ( ) ,
126
- size : msg . getBinaryAttachment ( ) . length ,
125
+ payload : msg . getSdtContainer ( ) ?. getValue ( ) || msg . getBinaryAttachment ( ) . toString ( ) ,
127
126
headers : {
128
127
destination : msg . getDestination ( ) . getName ( ) ,
129
128
replicationGroupMsgId : msg . getReplicationGroupMessageId ( ) . toString ( ) ,
@@ -334,7 +333,7 @@ class ForwardQueueBrowser {
334
333
335
334
messages . forEach ( msg => {
336
335
const msgObj = {
337
- payload : msg . getBinaryAttachment ( ) . toString ( ) ,
336
+ payload : msg . getSdtContainer ( ) ?. getValue ( ) || msg . getBinaryAttachment ( ) . toString ( ) ,
338
337
headers : {
339
338
destination : msg . getDestination ( ) . getName ( ) ,
340
339
replicationGroupMsgId : msg . getReplicationGroupMessageId ( ) . toString ( ) ,
@@ -509,7 +508,7 @@ class ReverseQueueBrowser {
509
508
510
509
messages . forEach ( msg => {
511
510
const msgObj = {
512
- payload : msg . getBinaryAttachment ( ) . toString ( ) ,
511
+ payload : msg . getSdtContainer ( ) ?. getValue ( ) || msg . getBinaryAttachment ( ) . toString ( ) ,
513
512
headers : {
514
513
destination : msg . getDestination ( ) . getName ( ) ,
515
514
replicationGroupMsgId : msg . getReplicationGroupMessageId ( ) . toString ( ) ,
0 commit comments