Los nodos de WebSphere MQ Everyplace dan soporte a un subconjunto limitado de las prestaciones de publicación/suscripción del WebSphere Business Integration Event Broker.
Como ocurre con todos los mensajes destinados a una cola puente que se dirigen al WebSphere Business Integration Event Broker, debe especificarse un tipo de mensaje. Para un mensaje de publicación, éste es MQeMbMsgObject.TYPE_PUB.
Los nombres de campos disponibles son los siguientes:
try { System.out.println("Local QM Name: " + myQM.getName()); MQeMsgObject mqeMsg = new MQeMsgObject(); mqeMsg.putInt(MQeMbMsgObject.TYPE_OF_MSG, MQeMbMsgObject.TYPE_PUB); mqeMsg.putAscii(MQeMbMsgObject.TOPIC, "Weather"); mqeMsg.putArrayOfByte(MQeMbMsgObject.MESSAGE, asciiToByte("Hello"); mqeMsg.putBoolean(MQeMbMsgObject.RETAINED, true); System.out.println("..Put message to QM/queue: " + destQueueManager + "/" + destBridgeQueue); myQM.putMessage(destQueueManager, destBridgeQueue, mqeMsg, null, 0); System.out.println("Finished"); } catch (Exception e) { e.printStackTrace(); System.out.println("Failed! " + e); }
El tipo de mensaje que debe especificarse para un mensaje de suscripción es MQeMbMsgObject.TYPE_SUB. Los nombres de campos disponibles son los siguientes:
try { System.out.println("Local QM Name: " + myQM.getName()); MQeMsgObject mqeMsg = new MQeMsgObject(); mqeMsg.putInt(MQeMbMsgObject.TYPE_OF_MSG, MQeArgoLaunch.TYPE_SUB); mqeMsg.putAsciiArray(MQeMbMsgObject.TOPIC, new String[] {"Topic1", "Topic2", "Topic3"}); mqeMsg.putAscii(MQeMbMsgObject.MQ_DestQueueName, "Inbox"); mqeMsg.putAscii(MQeMbMsgObject.MQ_DestQueueMgr, "ServerQM1"); System.out.println("..Put message to QM/queue: " + destQueueManager + "/" + destBridgeQueue); myQM.putMessage(destQueueManager, destBridgeQueue, mqeMsg, null, 0); System.out.println("Finished"); } catch (Exception e) { e.printStackTrace(); System.out.println("Failed! " + e); }
El tipo de mensaje que debe especificarse para un mensaje de anulación de suscripción es MQeMbMsgObject.TYPE_UNSUB. Los nombres de campos disponibles son los siguientes:
try { System.out.println("Local QM Name: " + myQM.getName()); MQeMsgObject mqeMsg = new MQeMsgObject(); mqeMsg.putInt(MQeMbMsgObject.TYPE_OF_MSG, MQeArgoLaunch.TYPE_UNSUB); mqeMsg.putAsciiArray(MQeMbMsgObject.TOPIC, new String[] {"Topic1", "Topic2", "Topic3"}); mqeMsg.putAscii(MQeMbMsgObject.MQ_DestQueueName, "Inbox"); mqeMsg.putAscii(MQeMbMsgObject.MQ_DestQueueMgr, "ServerQM1"); System.out.println("..Put message to QM/queue: " + destQueueManager + "/" + destBridgeQueue); myQM.putMessage(destQueueManager, destBridgeQueue, mqeMsg, null, 0 ); System.out.println("Finished"); } catch (Exception e) { e.printStackTrace(); System.out.println("Failed! " + e); }WebSphere MQ Everyplace actualmente no da soporte a ninguna de las características adicionales no descritas aquí. No se da soporta a mensajes soportados en WebSphere MQ, como por ejemplo solicitar actualización.
Conceptos relacionados
WebSphere MQ Mobile Transport
Mensajes de WebSphere MQ Everyplace
Referencia relacionada
WebSphere MQ Mobile Transport
Métodos de punta a punta de WebSphere MQ Everyplace
Avisos |
Marcas registradas |
Descargas |
Biblioteca |
Soporte |
Información de retorno (feedback)
![]() ![]() |
ac10180_ |