Topic Send and Topic Receive demo on JBoss Application Server

1 )Create a topic Add the following in the deploymessagingdestinations-service.xml file   <mbean code="org.jboss.jms.server.destination.TopicService" name="jboss.messaging.destination:service=Topic,name=Topic1" xmbean-dd="xmdesc/Topic-xmbean.xml"> <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends> <depends>jboss.messaging:service=PostOffice</depends> </mbean> 2) Copy the TopicSend and TopicReceive programs to a folder. TopicSend import java.io.*; import java.util.*; import javax.transaction.*; import javax.naming.*; import

Continue reading

JBoss MDB

This post describes usage of Jboss JMS Feature using a Message Driven Bean (MDB) consumer. Note: In this article , we would be using the default JMS queue ‘/queue/DLQ’. 1. Create a Message Driven Bean with bean class TestMDB.java  

Continue reading

Create JMS Resources Using WLST

connect(’system’,’weblogic’, ‘t3://localhost:7001′) # Creating a JMS Server edit()startEdit()cd(‘/’)print ‘Creating JMS Server.’cmo.createJMSServer(‘JMSServer0′)cd(‘/JMSServers/JMSServer0′)cmo.addTarget(getMBean(‘/Servers/AdminServer’))activate() # Creating a Module startEdit()cd(‘/’)cmo.createJMSSystemResource(‘JMSSystemResource0′)cd(‘/JMSSystemResources/JMSSystemResource0′)cmo.addTarget(getMBean(‘/Servers/AdminServer’))cmo.createSubDeployment(’subdeployment0′)activate() # Creating Queue startEdit()print ‘Creating Queue & Topic ‘cd(‘/’)cd(‘/JMSSystemResources/JMSSystemResource0/JMSResource/JMSSystemResource0′)cmo.createQueue(‘Queue0′)cd(‘/JMSSystemResources/JMSSystemResource0/JMSResource/JMSSystemResource0/Queues/Queue0′)set(‘JNDIName’,’jms/Queue0′)set(‘SubDeploymentName’,’subdeployment0′)cd(‘/JMSSystemResources/JMSSystemResource0/SubDeployments/subdeployment0′)cmo.addTarget(getMBean(‘/JMSServers/JMSServer0′))activate() # Creating Topic startEdit()cd(‘/’)cd(‘/JMSSystemResources/JMSSystemResource0/JMSResource/JMSSystemResource0′)cmo.createTopic(‘Topic0′)cd(‘/JMSSystemResources/JMSSystemResource0/JMSResource/JMSSystemResource0/Topics/Topic0′)set(‘JNDIName’,’jms/Topic0′)set(‘SubDeploymentName’,’subdeployment0′)cd(‘/JMSSystemResources/JMSSystemResource0/SubDeployments/subdeployment0′)set(‘Targets’,jarray.array([ObjectName(‘com.bea:Name=JMSServer0,Type=JMSServer’)],ObjectName)) activate()

Continue reading