WebSphere MQ V7.1 – Criando uma Queue utilizando arquivo

Depois de instalar o WebSphere MQ V7.1, vamos criar uma fila. Para executar comandos com o usuário mqm, vamos logar no sistema como root e depois como mqm:

[sfantin@hostsfantin ~]$ su -

[root@hostsfantin ~]# su - mqm

[mqm@hostsfantin ~]$

Depois de logar como mqm, vamos executar o comando que cria o Queue Manager:

[mqm@hostsfantin ~]$ crtmqm MyQM1

There are 89 days left in the trial period for this copy of WebSphere MQ. WebSphere MQ queue manager created. Directory ‘/var/mqm/qmgrs/MyQM1’ created. The queue manager is associated with installation ‘Installation1’. Creating or replacing default objects for queue manager ‘MyQM1’. Default objects statistics : 71 created. 0 replaced. 0 failed. Completing setup. Setup completed.

Vamos o iniciar o Queue Manager:
[mqm@hostsfantin ~]$ strmqm MyQM1

There are 89 days left in the trial period for this copy of WebSphere MQ. WebSphere MQ queue manager ‘MyQM1’ starting. The queue manager is associated with installation ‘Installation1’. 5 log records accessed on queue manager ‘MyQM1’ during the log replay phase. Log replay for queue manager ‘MyQM1’ complete. Transaction manager state recovered for queue manager ‘MyQM1’. WebSphere MQ queue manager ‘MyQM1’ started using V7.1.0.2.

Crie um arquivo como o nome de criaFila.mqsc contendo os seguintes comandos:
DEFINE QLOCAL(Q1)

SET AUTHREC PROFILE('Q1') OBJTYPE(QUEUE) PRINCIPAL('mqm') AUTHADD(PUT,GET)

SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('mqm') AUTHADD(CONNECT)

SET CHLAUTH(MY_CHANNEL) TYPE(ADDRESSMAP) ADDRESS('127.0.0.1') MCAUSER('mqm')

DEFINE LISTENER (MY_LISTENER) TRPTYPE (TCP) CONTROL (QMGR) PORT (1414)

START LISTENER (MY_LISTENER)
Para executar os comandos passando o arquivo como argumento:
[mqm@hostsfantin ~]$ runmqsc MyQM1 < criaFila.mqsc

5724-H72 (C) Copyright IBM Corp. 1994, 2011.  ALL RIGHTS RESERVED.
Starting MQSC for queue manager MyQM1.

1 : DEFINE QLOCAL(Q1)
AMQ8006: WebSphere MQ queue created.
:
2 : SET AUTHREC PROFILE(‘Q1’) OBJTYPE(QUEUE) PRINCIPAL(‘mqm’) AUTHADD(PUT,GET)
AMQ8862: WebSphere MQ authority record set.
:
3 : SET AUTHREC OBJTYPE(QMGR) PRINCIPAL(‘mqm’) AUTHADD(CONNECT)
AMQ8862: WebSphere MQ authority record set.
:
4 : SET CHLAUTH(MY_CHANNEL) TYPE(ADDRESSMAP) ADDRESS(‘127.0.0.1’) MCAUSER(‘mqm’)
AMQ8877: WebSphere MQ channel authentication record set.
:
5 : DEFINE LISTENER (MY_LISTENER) TRPTYPE (TCP) CONTROL (QMGR) PORT (1414)
AMQ8626: WebSphere MQ listener created.
:
6 : START LISTENER (MY_LISTENER)
AMQ8021: Request to start WebSphere MQ listener accepted.
:
6 MQSC commands read.
No commands have a syntax error.
All valid MQSC commands were processed.


WebSphere MQ V7.1 – Criando uma Queue

Depois de instalar o WebSphere MQ V7.1, vamos criar uma fila.

Para executar comandos com o usuário mqm, vamos logar no sistema como root e depois como mqm:

[sfantin@hostsfantin ~]$ su -
[root@hostsfantin ~]# su - mqm
[mqm@hostsfantin ~]$

Depois de logar como mqm, vamos executar o comando que cria o Queue Manager:
[mqm@hostsfantin ~]$ crtmqm MyQM

There are 89 days left in the trial period for this copy of WebSphere MQ.
WebSphere MQ queue manager created.
Directory ‘/var/mqm/qmgrs/MyQM’ created.
The queue manager is associated with installation ‘Installation1’.
Creating or replacing default objects for queue manager ‘MyQM’.
Default objects statistics : 71 created. 0 replaced. 0 failed.
Completing setup.
Setup completed.

Vamos o iniciar o Queue Manager:
[mqm@hostsfantin ~]$ strmqm MyQM

There are 89 days left in the trial period for this copy of WebSphere MQ.
WebSphere MQ queue manager ‘MyQM’ starting.
The queue manager is associated with installation ‘Installation1’.
5 log records accessed on queue manager ‘MyQM’ during the log replay phase.
Log replay for queue manager ‘MyQM’ complete.
Transaction manager state recovered for queue manager ‘MyQM’.
WebSphere MQ queue manager ‘MyQM’ started using V7.1.0.2.

[mqm@hostsfantin ~]$ runmqsc MyQM

5724-H72 (C) Copyright IBM Corp. 1994, 2011. ALL RIGHTS RESERVED.
Starting MQSC for queue manager MyQM.

Obs: ao executar o comando runmqsc, o prompt estará pronto para receber comandos.

Criando a fila Q1

DEFINE QLOCAL(Q1)

1 : DEFINE QLOCAL(Q1)
AMQ8006: WebSphere MQ queue created.

Para visualizar a fila no MQ Explorer, execute o seguinte comando:

[root@hostsfantin ~]# cd /opt/mqm/mqexplorer/eclipse/
[root@hostsfantin eclipse]# ./runwithtrace

mqexplorer

Alguns comandos adicionais para alterar a autenticação de canais e criação de listener:

SET AUTHREC PROFILE('Q1') OBJTYPE(QUEUE) PRINCIPAL('mqm') AUTHADD(PUT,GET)

2 : SET AUTHREC PROFILE(‘Q1’) OBJTYPE(QUEUE) PRINCIPAL(‘mqm’) AUTHADD(PUT,GET)
AMQ8862: WebSphere MQ authority record set.

SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('mqm') AUTHADD(CONNECT)

3 : SET AUTHREC OBJTYPE(QMGR) PRINCIPAL(‘mqm’) AUTHADD(CONNECT)
AMQ8862: WebSphere MQ authority record set.

SET CHLAUTH(Q_CHANNEL) TYPE(ADDRESSMAP) ADDRESS('127.0.0.1') MCAUSER('mqm')

4 : SET CHLAUTH(Q_CHANNEL) TYPE(ADDRESSMAP) ADDRESS(‘127.0.0.1’) MCAUSER(‘mqm’)
AMQ8877: WebSphere MQ channel authentication record set.

DEFINE LISTENER (Q_LISTENER) TRPTYPE (TCP) CONTROL (QMGR) PORT (1414)

5 : DEFINE LISTENER (Q_LISTENER) TRPTYPE (TCP) CONTROL (QMGR) PORT (1414)
AMQ8626: WebSphere MQ listener created.

START LISTENER (Q_LISTENER)

6 : START LISTENER (Q_LISTENER)
AMQ8021: Request to start WebSphere MQ listener accepted.

Enviando uma mensagem para a fila

Clique com direito em cima da fila e escolha a opção: Put Test Message…

putmessage

resultado


WebSphere MQ V7.1 no Fedora 18

IBM Websphere MQ é um provedor de middleware de mensageria baseado na especificação Java Message Service (JMS) e Message Queueing Interface (MQI), que permite que mensagens sejam transmitidas através de filas e tópicos.

mqexplorerCom JMS (e como tal, também com o IBM Websphere MQ) é possível processá-las de dois métodos básicos:

Filas: Uma mensagem pode ser enviada para uma fila de MQ e pode ser recebida por exatamente um consumidor. Se não houver nenhum consumidor disponível no momento em que a mensagem é enviada, ela será mantida até que o consumidor esteja disponível para processar a mensagem. Isto é também conhecido como um modelo point-to-point.

Tópicos: O Websphere MQ implementa a semântica de publish/subscribe. Quando você publicar uma mensagem, ela vai para todos os assinantes que estejam interessados e receberão uma cópia da mensagem. Somente assinantes que possuírem uma assinatura válida poderá receber uma cópia da mensagem.

Download

Download: WebSphere MQ V7.1.0 Trial

Obs: caso não tenha, é necessário efetuar cadastro antes de baixar a versão trial.

Pré-Instalação

Antes de instalar o WebSphere MQ 7.1 vamos criar o usuário adminstrador e o grupo:

groupadd mqm
useradd -m -g mqm mqm
su - mqm
exit

Obs: qualquer usuário pertencente ao grupo mqm poderá ser administrador do sistema

Instalação

Depois de baixar o arquivo, crie uma pasta em algum diretório temporário e descompacte o pacote MQ_7.1_TRIAL_FOR_LNX_ON_X86_32_ML.tar.gz:
su -
# mkdir /tmp/mq7

# tar -vzxf MQ_7.1_TRIAL_FOR_LNX_ON_X86_32_ML.tar.gz

Leia o resto deste post »