myJMSModule!MyJMSServer@MyManasgedServer_osb1@My.TOPIC.NAME
Вот мой код:
Код: Выделить всё
context = InitialContext(jndi_props)
connection_factory = context.lookup("my/connectionFactory")
connection = connection_factory.createConnection()
session = connection.createSession(False, javax.jms.Session.AUTO_ACKNOWLEDGE)
topic = session.createTopic("Where im having issues")
consumer = session.createConsumer(topic, selector)
connection.start()
try:
while True:
message = consumer.receiveNoWait()
if message is None:
break
if isinstance(message, JMSMessageInfo):
print("Removing message: %s " % message.getJMSMessageID())
session.deleteMessage(message) # Acknowledge the message to remove it
finally:
consumer.close()
session.close()
connection.close()
нужна помощь по этому вопросу или если вы знаете лучший способ удалить сообщения из темы, не потребляя их, это также будет очень полезно. Заранее спасибо
на сессии. CreateTopic — это то место, где возникают мои проблемы. Я пробовал такие форматы, как «My.TOPIC.NAME», «/My.TOPIC.NAME», «myJMSServer/My.TOPIC.NAME», «myJMSModule/My.TOPIC.NAME».
Подробнее здесь: https://stackoverflow.com/questions/790 ... -consuming