Как вставить сжатое байтовое сообщение в IBM MQ, используя python?(Я пробовал PYMQI и Spring Python) - PullRequest
Новая
       33

Как вставить сжатое байтовое сообщение в IBM MQ, используя python?(Я пробовал PYMQI и Spring Python)

1 голос
/ 30 марта 2019

Я тестирую приложение, которое принимает сжатые сообщения через IBM MQ.Для этого мне нужно отправить сжатое (.zip) сообщение в IBM MQ с пользовательским свойством jms со значением Compressed = Y

. Я борюсь с двумя проблемами -

  1. Как загрузить .zipсообщение в _IBMMQ
  2. Установите для заголовка или свойства _jms значение Compressed = 'Y'

Я пытался через Python (1) pymqi- Мне удалось отправить строку черезMQ.Но до сих пор не удалось отправить ZIP-файл.

(2) Spring Python - с этим я смог установить для настраиваемого свойства значение Compressed Y, но снова застрял с загрузкой .zip в очередь. 

#PYMQI
import pymqi
queue_manager = 'QM1'
channel = 'DEV.APP.SVRCONN'
host = '127.0.0.1'
port = '1414'
queue_name = 'TEST.1'
message = 'Hello from Python!'
conn_info = '%s(%s)' % (host, port)
qmgr = pymqi.connect(queue_manager, channel, conn_info)
queue = pymqi.Queue(qmgr, queue_name)
queue.put(message)
queue.close()
qmgr.disconnect()


# Spring Python
from springpython.jms.core import TextMessage
msg = TextMessage("Hello!")
msg.Compressed = "Y"
print msg
from springpython.jms.core import JmsTemplate
from springpython.jms.factory import WebSphereMQConnectionFactory
qm_name = "QM.1"
channel = "SVRCONN1.1"
host = "192.168.1.121"
listener_port = "1434"
queue1 = "TEST.1"
factory = WebSphereMQConnectionFactory(qm_name, channel, host, 
listener_port)
jms_template = JmsTemplate(factory)
jms_template.send(msg, queue1)
factory.destroy()

#Above code is for reference only, I have taken them from their own websites.
...