Topic Send and Topic Receive demo on JBoss Application Server

1 )Create a topic Add the following in the \deploy\messaging\destinations-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 javax.jms.*; import javax.rmi.PortableRemoteObject; public class TopicSend { // Defines the

Continue reading

JMS Based Webservice on Weblogic Server

By default, client applications use HTTP/S as the connection protocol when invoking a WebLogic Web Service. You can, however, configure a WebLogic Web Service so that client applications can also use JMS as the transport when invoking the Web Service.When a WebLogic Web Service is configured to use JMS as

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   import java.io.PrintStream; import javax.ejb.MessageDrivenBean; import javax.jms.*; import weblogic.ejb.GenericMessageDrivenBean; import javax.ejb.MessageDrivenBean;

Continue reading

Delete Messages From JMS Queue Using WLST

Connect to the server using WLST by entering the command java weblogic.WLST Enter the command connect() Enter the username, password, and the admin server url you want to connect to. Change the location to serverRuntime by entering the command serverRuntime(). Traverse to the below location: – cd(‘JMSRuntime’) – cd(‘AdminServer.jms’) –

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