Enqueue/Dequeue scenario in MQ with OSB

By default there is no MQ Connection in OSB so in order to work with OSB and MQ you have to copy the com.ibm.mq.jar file to the BEA_HOME\user_projects\domains\\lib directory.

com.ibm.mq.jar can be found from websphere mq installation.

ONce the file is copied in to the location.

Start your OSB Server and log in to OSB console using the following url

http://host:port/sbconsole.

NOw once done create a new session



Once you have created a new session go to
project Explorer and enter your project name.

and say add sample as you can see in my case i have created a folder MqSample.



now go inside the folder that you have created and create a mq connection as shown below



Now provide the connection details

The default channel i am using is SYSTEM.DEF.SVRCONN and the channel 1414

OracleMQ is the name of my queueManager provide these information and save the changes




Now once activate it to take effect.




Now log in to your MQ and create two queue over there i have created two queue there

ARPIT_IN for input and ARPIT_OUT for output queue.Both are local queue only.



Now create a new proxy service in the MqSample Folder as shown below and give it some logical name.



It will be a messaging service as shown





Make request and response as text type



Now this step is important choose the protocol as MQ

Now in the URL

Format: mq://local-queue-name?conn=mq-connection-resource-ref


Local-queue-name will be ARPIT_IN

conn=MqSample/MqConnection

as MqSample is the folder name and MqConnection is the name of connection that i have created for connecting to MQ.



Now in the next page i will provide the message response url as

mq://ARPIT_OUT?conn=MqSample/MqConnection

the only change that i have done is ARPIT_OUT instead of ARPIT_IN queue.

ONce make these change just keep on saying next till you reach the following page.Verify the connection.Save it and then then activate the changes.




Now you have created a simple project to verify the MQ inbound outbound scenarion.
In this sample The process is polling in ARPIT_IN queue and as soon as data will be inserted into ARPIT_IN queue the Proxy service will take it and copy in ARPIT_OUT queue.

Now to verify this we will insert a message in ARPIT_IN queue





As you cann see the current queue depth in in and out queue is zero i will put a message in arpit_in queue and will check if it gets published to arpit_out queue.


Just put some message in arpit_in queue as below


but it will remain in input queue for a moment and will be copied to output queue immediately as shown.Now browse the message to verify the same message.



This is a sample test for mq scenario you can use this concept to create you own complex customized service.Please post me any issues