Tech Mastery: Deep Dives into AEM, Cloud Technologies, AI Innovations, and Advanced Marketing Strate: Disabling/Enabling the Oracle Service Bus Services from Java

Disabling/Enabling the Oracle Service Bus Services from Java

The status of the OSB services can be changed in different ways like through OSB console, through WLST script and through Java.

This post shows how to use the Java API to enable/disable the OSB Proxy/Business services.

Java Code:

package osbservicestatusupdate;

import com.bea.wli.config.Ref;

import com.bea.wli.sb.management.configuration.*;

import java.io.IOException;

import java.net.MalformedURLException;

import java.util.Hashtable;

import javax.management.*;

import javax.management.remote.*;

import javax.naming.Context;

import weblogic.management.jmx.MBeanServerInvocationHandler;

import weblogic.management.mbeanservers.domainruntime.DomainRuntimeServiceMBean;

public class OSBServiceStatusUpdate {

private static JMXConnector initConnection(String hostname, int port,String username, String password) throws IOException,MalformedURLException

{

JMXServiceURL serviceURL = new JMXServiceURL("t3", hostname, port,"/jndi/" + DomainRuntimeServiceMBean.MBEANSERVER_JNDI_NAME);

Hashtable<String, String> h = new Hashtable<String, String>();

h.put(Context.SECURITY_PRINCIPAL, username);

h.put(Context.SECURITY_CREDENTIALS, password);

h.put(JMXConnectorFactory.PROTOCOL_PROVIDER_PACKAGES, "weblogic.management.remote");

return JMXConnectorFactory.connect(serviceURL, h);

}

private static Ref constructRef(String refType,String serviceuri){

Ref ref = null;

String[] uriData = serviceuri.split("/");

ref = new Ref(refType,uriData);

return ref;

}

public static String changeProxyServiceStatus(String servicetype,boolean status,String serviceURI,String host,int port,String username,String password){

JMXConnector conn = null;

SessionManagementMBean sm = null;

String sessionName = "mysession";

String statusmsg="";

try{

conn = initConnection(host, port, username,password);

MBeanServerConnection mbconn = conn.getMBeanServerConnection();

DomainRuntimeServiceMBean domainService = (DomainRuntimeServiceMBean) MBeanServerInvocationHandler.

newProxyInstance(mbconn, new ObjectName(DomainRuntimeServiceMBean.OBJECT_NAME));

sm = (SessionManagementMBean) domainService.findService(SessionManagementMBean.NAME,SessionManagementMBean.TYPE, null);

sm.createSession(sessionName);

ALSBConfigurationMBean alsbSession = (ALSBConfigurationMBean) domainService.

findService(ALSBConfigurationMBean.NAME + "." + "mysession",ALSBConfigurationMBean.TYPE, null);

if(servicetype.equals("ProxyService")) {

Ref ref = constructRef("ProxyService",serviceURI);

ProxyServiceConfigurationMBean proxyConfigMBean = (ProxyServiceConfigurationMBean) domainService.

findService(ProxyServiceConfigurationMBean.NAME + "." + sessionName,ProxyServiceConfigurationMBean.TYPE, null);

if(status){

proxyConfigMBean.enableService(ref);

statusmsg="Enabled the Service : " + serviceURI;

}

else {

proxyConfigMBean.disableService(ref);

statusmsg="Disabled the Service : " + serviceURI;

}

}else if(servicetype.equals("BusinessService")) {

Ref ref = constructRef("BusinessService",serviceURI);

BusinessServiceConfigurationMBean businessConfigMBean = (BusinessServiceConfigurationMBean) domainService.

findService(BusinessServiceConfigurationMBean.NAME + "." + sessionName,BusinessServiceConfigurationMBean.TYPE, null);

if(status){

businessConfigMBean.enableService(ref);

statusmsg="Enabled the Service : " + serviceURI;

}

else {

businessConfigMBean.disableService(ref);

statusmsg="Disabled the Service : " + serviceURI;

}

sm.activateSession(sessionName, statusmsg);

conn.close();

}catch(Exception ex){

if(null != sm) {

try{

sm.discardSession(sessionName);

}catch(Exception e) {

System.out.println("able to discard the session");

}

statusmsg="Not able to perform the operation";

ex.printStackTrace();

}finally{

if(null != conn)

try{

conn.close();

}catch(Exception e) {

e.printStackTrace();

}

return statusmsg;

}

public static void main(String[] args) {

//changeProxyServiceStatus(servicetype, status, serviceURI, host, port, username, password)

System.out.println(changeProxyServiceStatus("BusinessService", false, "OSBServiceAPI/OSBServiceAPIBusiness", "localhost", 8000, "weblogic", "welcome1"));

}

The below specified jar files should be in the class path to execute this program.