0

我如何将JMS_IBM_MQMD_Format: MQHRF2更改为在 WebsphereMQ 消息JMS_IBM_MQMD_Format: MQSTR ?

我需要 JMS_IBM_MQMD_Format:MQSTR

我得到如下输出:

JMSMessage class: jms_text
  JMSType:          null
  JMSDeliveryMode:  2
  JMSExpiration:    0
  JMSPriority:      4
  JMSMessageID:     ID:010203040506070801020304050607080102030405060708
  JMSTimestamp:     1365655482749
  JMSCorrelationID: null
  JMSDestination:   queue:///MYQUEUE?mdMessageContext=1&mdWriteEnabled=true
  JMSReplyTo:       null
  JMSRedelivered:   false
    JMSXAppID: WebSphere MQ Client for Java
    JMSXDeliveryCount: 1
    JMSXUserID:             
    JMS_IBM_Character_Set: UTF-8
    JMS_IBM_Encoding: 273
    JMS_IBM_Format: MQSTR   
    JMS_IBM_MQMD_AccountingToken: 0000000000000000000000000000000000000000000000000000000000000000
    JMS_IBM_MQMD_ApplIdentityData:                                 
    JMS_IBM_MQMD_ApplOriginData:     
    JMS_IBM_MQMD_BackoutCount: 0
    JMS_IBM_MQMD_CodedCharSetId: 1208
    JMS_IBM_MQMD_CorrelId: 000000000000000000000000000000000000000000000000
    JMS_IBM_MQMD_Encoding: 273
    JMS_IBM_MQMD_Expiry: -1
    JMS_IBM_MQMD_Feedback: 0
    JMS_IBM_MQMD_Format: MQHRF2  
    JMS_IBM_MQMD_GroupId: 000000000000000000000000000000000000000000000000
    JMS_IBM_MQMD_MsgFlags: 0
    JMS_IBM_MQMD_MsgId: 010203040506070801020304050607080102030405060708
    JMS_IBM_MQMD_MsgSeqNumber: 1
    JMS_IBM_MQMD_MsgType: 8
    JMS_IBM_MQMD_Offset: 0
    JMS_IBM_MQMD_OriginalLength: -1
    JMS_IBM_MQMD_Persistence: 1
    JMS_IBM_MQMD_Priority: 4
    JMS_IBM_MQMD_PutApplName: WebSphere MQ Client for Java
    JMS_IBM_MQMD_PutApplType: 28
    JMS_IBM_MQMD_PutDate: 20130411
    JMS_IBM_MQMD_PutTime: 04444315
    JMS_IBM_MQMD_ReplyToQ:                                                 
    JMS_IBM_MQMD_ReplyToQMgr: MYQM                                            
    JMS_IBM_MQMD_Report: 0
    JMS_IBM_MQMD_UserIdentifier:             
    JMS_IBM_MsgType: 8
    JMS_IBM_PutApplType: 28
    JMS_IBM_PutDate: 20130411
    JMS_IBM_PutTime: 04444315

SimpleMQMDWrite:你今天的幸运数字是 733

4

2 回答 2

0
Destination producerDestination = producerSession.createQueue(
    messagingQueueDetail.getRequestQueueName()
);

((MQQueue) producerDestination).setTargetClient(JMSC.MQJMS_CLIENT_NONJMS_MQ);

// MessageProducer is used for sending messages
producer = producerSession.createProducer(producerDestination);
于 2013-04-11T07:34:10.960 回答
0

在您的MessageCreator实现(实现的类MessageCreator)中添加setJMSType带有值的 a "MQSTR"

public TextMessage createMessage(Session session) throws JMSException {
    TextMessage messageObject = session.createTextMessage();
    messageObject.setText(message);
    messageObject.setJMSType("MQSTR");
    return messageObject;
}
于 2019-06-21T18:59:19.223 回答