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 »

WLDF generating JMS Message notifications

This post describes a simple usage of how we can leverage the WLDF functionality with JMS feature. This post would show how WLDF can generate notifications in the form of JMS messages and sends it to message Queue which can be consumed by the JMS consumer. Before starting the configuration

Continue reading »

JBoss JMS using HornetQ

JBoss JMS feature using HornetQ

Continue reading »

WebLogic JMS feature using Topic

WebLogic JMS feature using Topic

Continue reading »

WebLogic JMS (Point to Point) feature using a Queue

The article shows a simple usage of WebLogic JMS feature using a Queue.

Continue reading »

Large Message Processing Issues In JMS Transactions

When there is a distributed transaction involved in message processing, it is very important that all the resources involved in the transaction are reachable without any latency. When this is not the case and there is an issue with the communication between the resources, there can be issues of message

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 »