Configuring Database Stores for Tibco EMS

This section describes the steps required to configure and deploy database stores.

Step1: Enable the database store feature in the tibemsd.conf by setting the parameters:
              — dbstore_classpath
             — dbstore_driver_name
             — dbstore_driver_dialect
             — jre_library

Here I configured for MySql database...

dbstore_classpath : specify the path of jar files needed for db configuration.(In the below tibemsd.conf file i mentioned all the jar files which are needed )



dbstore_driver_name
                   dbstore_driver_name = name
             Specifies the name of the JDBC driver used by Hibernate.
For example:
• If you are using the MySQL InnoDB database server:
dbstore_driver_name=com.mysql.jdbc.Driver
• If you are using the Microsoft SQL Server:
dbstore_driver_name=
com.microsoft.sqlserver.jdbc.SQLServerDriver
• If you are using Oracle 10g:
dbstore_driver_name=oracle.jdbc.driver.OracleDriver
• If you are using IBM DB2 Server:
dbstore_driver_name=com.ibm.db2.jcc.DB2Driver

dbstore_driver_dialect
dbstore_driver_dialect = dialect
Specifies the Hibernate SQL dialect used to construct SQL commands.

then the configuration for tibemsd.conf file is look like below...

Server = EMS-SERVER-MSS-DB2
Listen = tcp://7123


########################################################################
use the following jar files what i mentioned in class_path,don't use any extra jar files,they lead to some more problems.
########################################################################

dbstore_classpath       =  <path>\hibernate3.jar;<path>\c3p0-0.9.1.jar;<path>\asm-attrs.jar;<path>\asm.jar;<path>\cglib-2.2.jar;<path>\commons-collections-2.1.1.jar;<path>\javassist.jar;<path>\commons-collections-3.1.jar;<path>\commons-logging-1.0.4.jar;<path>\dom4j-1.6.1.jar;<path>\ehcache-1.2.3.jar;<path>\slf4j-api-1.5.8.jar;<path>\apache-logging-log4j.jar;<path>\antlr-2.7.6.jar;<path>\jta-1.1.jar;<path>\slf4j-log4j12-1.5.8.jar;<path>\mysql-connector-java-5.1.15-bin.jar

dbstore_driver_name     = com.mysql.jdbc.Driver
dbstore_driver_dialect  = org.hibernate.dialect.MySQL5InnoDBDialect
jre_library             = "C:\Program Files\Java\jdk1.7.0_07\jre\bin\server\jvm.dll"

######################################################


stores    = C:\tibco\ems\7.0\bin\dbstore\stores.conf


 ####################################################

Step2:Configuration in stores.conf                        This section describes parameters configured for each database store in the stores.conf file. The stores.conf includes definitions for both database and file-based stores.

stores.conf file look like below...

[tibems]
type=dbstore
dbstore_driver_url=jdbc:mysql://localhost:3306/tibems
dbstore_driver_username=root
dbstore_driver_password=123456

 
Step3: EMS Schema Export Tool
                   Each database store that is configured for an EMS server includes a configuration parameter pointing to a database. The EMS Schema Export Tool creates and exports database tables for the database stores.

By using the below command you can export schema to Database...

CMD > java -jar c:\tibco\ems\7.0\bin\tibemsd_util.jar -tibemsdconf c:\tibco\ems\7.0\bin\dbstore\tibemsd.conf -createall -export 

Step4:Testing the Messages Availability in Database 

• Start the EMS Server what you configured.
• Connect to the server from administration tool.
• Create Queue with specifying store parameter.
• Example: create queue testqueue store=tibems(store what i mentioned in stores.conf file)
• Send the message to the Queue in persistant mode then the message is also available in ems_messages table.
•  
• Need any clarification contact me ...  
  

Implementing Webservice client using Java

1 . Open Eclipse .
2. Create a new Java project. Select "File -> New -> Java Project" from the toolbar, and the "New Java Project" wizard starts.
3. Give the project a name, and choose your preferences on Java version and project organization. In this example the project is called "Get Location demo Client", The default values are used for all other selections in this example.
4. Push "Finish" to continue and close the wizard. The project is created, and you can continue to start adding content to your project.
5. Select your project, push the right mouse button and then select "New -> Other" on the toolbar, to start the New wizard. 6. Select Web Service Client from the New menu, and push the "Next" button. The Web Service Client wizard starts. Here you choose the Web Service location (WSDL file) that we are creating a client for, and the type of client (Java proxy). 7. Push the "Browse" button and the Select Service Implementation wizard starts. 8. Type in the address to the WSDL file,  The tool validates the WSDL file, when the address is fully entered. The current version of WSDL file and validation tool shows a warning message. Push "OK" to return to the Web Service Client wizard.
9. Slide the slider down to only create a client, and push the "Finish" button. The tool creates the stubs and skeletons required to invoke the service.


10. After Clicking on finish you may find four interfaces generated in your workspace.
like below


The next step is to create the code that invokes the service.

10. Add a new Java class, containing a main method. Select your project, and then select "New -> Java" class on the toolbar, to start the New Java Class wizard.



Here actually my Processing Order interface implements one method placeOrder which accepts two arguements... and returns the response

I implement the client in the java class as follows...


import java.rmi.RemoteException;

import javax.xml.namespace.QName;
import javax.xml.rpc.ServiceException;
import javax.xml.ws.WebServiceRef;
@WebServiceRef(wsdlLocation="http://localhost:8086/Order_WS/services/ProcessingOrder?wsdl")
public class MyTestClient {
   
     //String url = "http://localhost:8086/Order_WS/services/ProcessingOrder?wsdl";
     QName qname = new QName("http://mss.org", "placeOrder");
     public static void main(String[] args) throws ServiceException, RemoteException {
         ProcessingOrderServiceLocator pol=new ProcessingOrderServiceLocator();
         ProcessingOrder po=(ProcessingOrder) pol.getPort(ProcessingOrder.class);
         int res=po.placeOrder("137","hiiiieeee");
       
         System.out.println(res);
       
    }
}

Run the MyTestClient class then you will get the response from the Webservice.