Real Experts

Jetty Obfuscation and Reverse Obfuscation

2019-02-07T19:49:00.001+05:30

Download Jetty : https://www.eclipse.org/jetty/download.html

For Obfuscation:
Run below command:

java -cp jetty-util-[VERSION_NUMBER].jar org.eclipse.jetty.util.security.Password [PASSWORD]

Example:
$ java -cp lib\jetty-util-9.4.6.v20170531.jar org.eclipse.jetty.util.security.Password SecretPassword123
2017-08-15 18:44:13.036:INFO::main: Logging initialized @148ms to org.eclipse.jetty.util.log.StdErrLog
SecretPassword123
OBF:1fof1j1u1igh1vgt1vn61y101sgo1v1p1ym71v2p1siu1y0q1vnw1vg11idp1iz01fmn
MD5:512d9845442e46f891bafc22f06b171e

For Reverse Obfuscation

Run below command:

java -cp jetty-util-[VERSION_NUMBER].jar org.eclipse.jetty.util.security.Password [OBF:PASSWORD]

Example::
$ java -cp lib\jetty-util-9.4.6.v20170531.jar org.eclipse.jetty.util.security.Password OBF:1fof1j1u1igh1vgt1vn61y101sgo1v1p1ym71v2p1siu1y0q1vnw1vg11idp1iz01fmn
2017-08-15 18:45:48.165:INFO::main: Logging initialized @134ms to org.eclipse.jetty.util.log.StdErrLog
SecretPassword123
OBF:1fof1j1u1igh1vgt1vn61y101sgo1v1p1ym71v2p1siu1y0q1vnw1vg11idp1iz01fmn
MD5:f8ad4d396e4cc2eb2955d3911eb14cb9

Setup Redis 3.2 server in cluster mode in Windows 7 64 bit

2018-06-12T15:35:00.004+05:30

Setup Redis 3.2 Cluster based server in windows

Steps:

Download Redis 3.2 Server windows from link: the MSOpenTech version
extract of install above downloaded one.
Create a folder redis3.2
go to folder redis3.2
create cluster node folders
eg: node1,node2, node3
copy the redis-server.exe and redis-cli.exe into redis3.2 folder from Downloaded Redis zip/installation
go to each node folder and create redis.conf file and add below content
1 2 3 4 5

port 6380 cluster-enabled yes cluster-config-file nodes.conf cluster-node-timeout 5000 appendonly yes
add the unique port number in each node for node1 6380 for node1 6381 for node1 6382
Now Run each node by going to each node folder with below command:
c:\node1>..\redis-server.exe redis.conf
c:\node2>..\redis-server.exe redis.conf
c:\node3>..\redis-server.exe redis.conf
After node started you will see below message
```
Redis 3.2.100 (00000000/0) 64 bit

Running in cluster mode
Port: 6380
PID: 7096
```
Now connect any node with redis-cli.exe
```
redis-cli.exe -h <ip or host> -p 6380
```

Run below command to make them join cluster:

CLUSTER MEET  6380
CLUSTER MEET  6381
CLUSTER MEET  6382

after run CLUSTER NODES you will see all nodes
sample output:
72b640cb92b054d51c89d0c28a016573e7ff3631 127.0.0.1:6380 myself,master
above first column is nodeid which is auto generated
Now all nodes are MASTER nodes
now change node1 as master and rest as slaves
connect to each node except master node via redis-cli and run below command
```
CLUSTER REPLICATE <master-node-id>
```
master-node-id is node id of node which you want as master.
Now you will see one master node and rest nodes are slaves
Now allocate the slots to the master node with below command
```
FOR /L %i IN (0,1,16383) DO ( redis-cli.exe -p **6380** CLUSTER ADDSLOTS %i )
```
6380 is port of master node

Now Redis 3.2 cluster server is ready!

You can also Download the following pre setup Redis 3.2 cluster based server:
click here

Help:

To connect Redis node with host/port via redis-cli interface use below command:
redis-cli -h hostname -p portnumber

Download Oracle 64 bit JDK 1.8 pre installed zip

2018-06-04T19:35:00.002+05:30

Click below to download the Oracle JDK 1.8 pre installed zip 64 bit (No installation required)

Click here Oracle JDK 1.8

after download, unzip the pack to a folder

set JAVA_HOME and PATH environment variables

Download Oracle 64 bit JDK 1.7 pre installed zip

2018-06-04T19:29:00.003+05:30

Click below to download the Oracle JDK 1.7 pre installed zip 64 bit (No installation required)

Click here Oracle JDK 1.7

after download, unzip the pack to a folder

set JAVA_HOME and PATH environment variables

Create Java Pre installed zip from Jdk executable

2018-05-28T11:01:00.001+05:30

Creating a pre installed JDK in Zip package, Follow these steps:

Download Latest Jdk executable from Oracle.com
extract all the files from jdk-8u172-windows-x64.exe into the directory( any destination dir)
Eg: C:\JDK
Execute the following commands in cmd.exe:
- cd C:\JDK\.rsrc\1033\JAVA_CAB10
- extrac32 111
Unpack C:\JDK\.rsrc\1033\JAVA_CAB10\tools.zip with 7-zip
Execute the following commands in cmd.exe:
- cd C:\JDK\.rsrc\1033\JAVA_CAB10\tools\
- for /r %x in (*.pack) do .\bin\unpack200 -r "%x" "%~dx%~px%~nx.jar" (this will convert all .pack files into .jar files)
Copy all contents of C:\JDK\.rsrc\1033\JAVA_CAB10\tools where you want your JDK to be

Connect Ldap using Java

2016-07-07T11:26:00.002+05:30

LDAP (Lightweight Directory Access Protocol) is a software protocol for enabling anyone to locate organizations, individuals, and other resources such as files and devices in a network, whether on the public Internet or on a corporate intranet. LDAP is a "lightweight" (smaller amount of code) version of Directory Access Protocol (DAP), which is part of X.500, a standard for directory services in a network.

Directory structure strings:
rdn	Relative Distinguished Name
dn	Distinguished Name
cn	Common Name
ou	Organizational Unit
dc	Domain Component
sn	SurName

As an example, the Entry look like was:

dn: cn=Joe Smith,ou=East,dc=MyDomain,dc=com
 cn: John Doe
 givenName: John
 sn: Doe
 telephoneNumber: +1 888 555 6789
 telephoneNumber: +1 888 555 1232
 mail: john@example.com
 manager: cn=Barbara Doe,dc=example,dc=com
 objectClass: inetOrgPerson
 objectClass: organizationalPerson
 objectClass: person
 objectClass: top

Above example, the Distinguished Name "cn=Joe Smith,ou=East,dc=MyDomain,dc=com" has four components. The first (lowest level) component of the Distinguished Name is the Relative Distinguished Name (RDN) of the object. In this case, the RDN is "cn=Joe Smith". The RDN of an object is the name of the object in its container. The remainder of the components are the Distinguished Name of the container, which is the parent of the object. In this case, the object "cn=Joe Smith" is in the container whose Distinguished Name is "ou=East,dc=MyDomain,dc=com". In this case, the parent container is an organizational unit. The parent of the "ou=East" organizational unit is the domain "MyDomain.com". This domain has domain components "dc=MyDomain" and "dc=com". The full DNS name of the domain is "dc=MyDomain,dc=com".
Container objects can be containers, organizational units, or domains. Container objects are objects that can "contain" other objects, such as user objects, group objects, and computer objects. Group objects are not containers. Groups can have members, but the members are not children of the group object.

Sample java program to connect ldap and search the directory:

import javax.naming.Context;
import javax.naming.directory.DirContext;
import javax.naming.directory.SearchResult;
import javax.naming.NamingEnumeration;
import javax.naming.directory.InitialDirContext;
import javax.naming.directory.Attributes;
import javax.naming.directory.BasicAttributes;
import javax.naming.directory.Attribute;

public class LdapTest 
{
  public static void main(String[] args)
  {
    Hashtable<String, String> env = new Hashtable<String, String>();
    env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.ldap.LdapCtxFactory");
    env.put(Context.PROVIDER_URL, "ldap://localhost:392"));
    env.put("com.sun.jndi.ldap.connect.pool", "true");
    env.put(Context.SECURITY_PRINCIPAL, "uid=admin,ou=system");
    env.put(Context.SECURITY_CREDENTIALS, "password");
    env.put(Context.SECURITY_AUTHENTICATION, "simple");
    env.put("com.sun.jndi.ldap.read.timeout", "50000");
    env.put("com.sun.jndi.ldap.connect.timeout", "50000");

    try 
    {
      DirContext ctx =  new InitialDirContext(env);
      Attributes matchAttrs = new BasicAttributes(true);
      matchAttrs.put(new BasicAttribute("inputAttributeName", "inputAttributeValue"));      
      NamingEnumeration<SearchResult> answer = ctx.search("baseDN",matchAttrs);
      while (answer.hasMore()) 
      {
        SearchResult sr = answer.next();
        NamingEnumeration<? extends Attribute> attributes = sr.getAttributes().getAll();
        while (attributes.hasMore()) 
        {
          Attribute anAttribute = attributes.next();
          String id = anAttribute.getID();
          String value = anAttribute.get().toString();
          System.out.println(id+" "+value);
        }
        attributes.close();
      }
      answer.close();
    } catch (NamingException e) {
        e.printStackTrace();
    } 
    finally 
    {
        if (ctx != null) 
        {
          try 
          {
              ctx.close();
          } catch (NamingException e) {
              e.printStackTrace();
          }
        }
    }
  }
}

Convert JKS into PEM using Keytool

2016-01-28T16:36:00.003+05:30

Below are the steps to convert the JKS keystore file into CRT / PEM files(certs/keys)

Generate PKCS12 file format with the Keystore jks file
keytool -importkeystore -srckeystore <keystore.jks> -destkeystore <keystore.p12> -deststoretype PKCS12 -srcalias <aliasName> -deststorepass <password> -destkeypass <password>In above keystore.jks is input Keystore file
keystore.p12 is the output PKCS12 file.
aliasName was the entry name in keystore file.
password is the password for the output file.
Example:
>keytool -importkeystore -srckeystore keystore.jks -destkeystore keystore.p12 -deststoretype PKCS12 -srcalias selfsigned -deststorepass password -destkeypass password Enter source keystore password:
Now convert the PKCS12 format into PEM format:

Generate certificate in pem format without private keys:
>openssl pkcs12 -in <keystore.p12> -nokeys -out <cert.pem>
in above keystore.p12 is the input file in PKCS12 format
cert.pem is the output file in PEM format.
example:
>openssl pkcs12 -in keystore.p12 -nokeys -out cert.pem Enter Import Password: MAC verified OK
Generate private key in pem format without certificate:
>openssl pkcs12 -in keystore.p12 -nodes -nocerts -out key.pem Enter Import Password: MAC verified OK

Additionally convert the keystore jks file into CRT format:
keytool -exportcert -file <keystore.crt> -keystore <keystore.jks> -alias <aliasName>
in above keystore.jks is the input Keystore jks file
aliasName is the entry name in the keystore file
keystore.crt is the output CRT file.
>keytool -exportcert -file keystore.crt -keystore keystore.jks -alias selfsigned Enter keystore password: Certificate stored in file <keystore.crt>

Spring Security with Md5 password encoder Authentication

2015-12-11T11:03:00.001+05:30

Spring Security to a web application with md5 password encoder

Required Maven Libraries:

<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-core</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-beans</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-context</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-web</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.security</groupId>
 <artifactId>spring-security-web</artifactId>
</dependency>
<dependency>
 <groupId>org.springframework.security</groupId>
 <artifactId>spring-security-config</artifactId>
</dependency>

Configuration files:

MD5 Password Encoder script(md5encoder.sh)

#!/bin/bash
##########################################################################
# Name  : MD5 Password Encoder for PRISM API 
##########################################################################
echo "Please enter password to be encoded:"
read md5pass
echo -n $md5pass | md5sum | awk '{print $1}'

User Profiles(profiles.properties)

1
2
3

# Basic Authentication credentials in APP
# Format  is <username> = <md5encodedpassword>,<userRole>,<isUserEnabled> 
candy=5f4dcc3b5aa765d61d8327deb882cf99,ROLE_USER,enabled

Spring context xml(security-app-context.xml)

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:security="http://www.springframework.org/schema/security"
 xmlns:context="http://www.springframework.org/schema/context"
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
           http://www.springframework.org/schema/security
           http://www.springframework.org/schema/security/spring-security-3.1.xsd">

 <security:http entry-point-ref="authenticationEntryPoint"
  use-expressions="true">
  <security:intercept-url pattern="/**"  access="hasAnyRole ( 'ROLE_USER')" />
   <security:logout invalidate-session="true" delete-cookies="JSESSIONID,SPRING_SECURITY_REMEMBER_ME_COOKIE" />
  <security:custom-filter ref="basicAuthenticationFilter" position="BASIC_AUTH_FILTER" />
 </security:http>
 
 <bean id="basicAuthenticationFilter"
  class="org.springframework.security.web.authentication.www.BasicAuthenticationFilter">
  <property name="authenticationManager" ref="authManager" />
  <property name="authenticationEntryPoint" ref="authenticationEntryPoint" />
 </bean>
 <bean id="authenticationEntryPoint"
  class="org.springframework.security.web.authentication.www.BasicAuthenticationEntryPoint">
  <property name="realmName" value="PRISM" />
 </bean>

 <bean id="md5encoder" class="org.springframework.security.authentication.encoding.Md5PasswordEncoder">
 </bean>
 <security:authentication-manager alias="authManager"> 
  <security:authentication-provider>
      <security:password-encoder ref="md5encoder" />
   <security:user-service id="userDetailsService" properties="file:{path}/profiles.properties"/>
  </security:authentication-provider>
 </security:authentication-manager>
</beans>

Web application xml(web.xml)

<context-param>  
 <param-name>contextConfigLocation</param-name>  
 <param-value>file:{path}/security-app-context.xml</param-value>
</context-param>
<!-- security start -->
<filter>
 <filter-name>springSecurityFilterChain</filter-name>
 <filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class>
</filter>
<filter-mapping>
 <filter-name>springSecurityFilterChain</filter-name>
 <url-pattern>/*</url-pattern>
</filter-mapping>
<!-- security end -->

Read Keystore jks file by using Java KeyTool

2015-11-03T17:31:00.001+05:30

Below command to read the jks file and display the certificates it contains:

>keytool -list -keystore keystore.jks
Enter keystore password:
Keystore type: JKS
Keystore provider: SUN
Your keystore contains 2 entries
activation, Mar 13, 2013, trustedCertEntry, Certificate fingerprint (SHA1): 85:4B:73:CE:00:86:D6:1B:FE:95:17:3D:BB:E6:BE:02:BB:78:A4:2F
selfsigned, Mar 13, 2013, PrivateKeyEntry, Certificate fingerprint (SHA1): C5:0A:C4:AB:DA:80:03:F7:59:C7:D9:02:C5:D7:9A:97:08:7B:83:A0

Above data says, it has 2 certificate entries,
first one is alias name is "activation"
2nd one is alias name is "selfsigned"

Now we can export the above two entries into Certificates in CRT files as below

>keytool -exportcert -file keystore.crt -keystore keystore.jks -alias activation
Enter keystore password:
Certificate stored in file <keystore.crt>
>keytool -exportcert -file keystore1.crt -keystore keystore.jks -alias selfsigned
Enter keystore password:
Certificate stored in file <keystore1.crt>

Certificates Manipulation with Open SSL

2015-11-02T12:09:00.002+05:30

Download Open ssl binaries for windows here: Windows Openssl.

Before Going to certificates we will go through the some talks below:

To Generate Certificate we need Private key, this key will be generated by RSA algorithm
RSA is a cryptosystem for private-key encryption, and is widely used for securing sensitive data over internet.
RSA stands for Rivest-Shamir-Adleman were the 3 persons last names who described the RSA algorithm.

.PEM Defined in RFC's 1421 through 1424, this is a container format that may include just the public certificate (such as with Apache installs, and CA certificate files /etc/ssl/certs), or may include an entire certificate chain including public key, private key, and root certificates. Confusingly, it may also encode a CSR (e.g. as used here) as the PKCS10 format can be translated into PEM. The name is from Privacy Enhanced Mail (PEM), a failed method for secure email but the container format it used lives on, and is a base64 translation of the x509 ASN.1 keys.
Normally it contains the chain of certificates.
.key This is a PEM formatted file containing just the private-key of a specific certificate
CSR is Certificate Signing Request, basically this is the input file for generate Certificates(.CRT)
CRT is Certificate, which content not fully encoded certificate, it was same like .crt .cert, .cer
.pkcs12 .pfx .p12 Originally defined by RSA in the Public-Key Cryptography Standards, the "12" variant was enhanced by Microsoft. This is a passworded container format that contains both public and private certificate pairs. Unlike .pem files, this container is fully encrypted.

Steps to Generate Certificate

Generate a private key using RSA
>openssl genrsa -out root_ca.key 4096
Loading 'screen' into random state - done
Generating RSA private key, 4096 bit long modulus
....................................................
...................++
e is 65537 (0x10001)

If you want to password-protect this key, add option -des3.
Generate Root CA certificate by any one of following ways:

Generate new root CA Certificate(.crt) directly by above private key
The -x509 option is used for a self-signed certificate. 1826 days gives us a cert valid for 5 years.
>openssl req -new -x509 -days 1826 -key root_ca.key -out root_ca.crt -sha256
Loading 'screen' into random state - done
You are about to be asked to enter information that will be incorporated
into your certificate request.
What you are about to enter is what is called a Distinguished Name or a DN.
There are quite a few fields but you can leave some blank
For some fields there will be a default value,
If you enter '.', the field will be left blank.
-----
Country Name (2 letter code) [AU]:IN
State or Province Name (full name) [Some-State]:TAMILNADU
Locality Name (eg, city) []:MADRAS
Organization Name (eg, company) [Internet Widgits Pty Ltd]:HCL
Organizational Unit Name (eg, section) []:BROSS
Common Name (e.g. server FQDN or YOUR name) []:RAJA
Email Address []:RAJA@ERICSSON.COM
Generate new root CA Certificate(.crt) using CSR(.csr)

Generate CSR
>openssl req -new -x509 -days 1826 -key root_ca.key -out root_ca.csr -sha256
Loading 'screen' into random state - done
You are about to be asked to enter information that will be incorporated
into your certificate request.
What you are about to enter is what is called a Distinguished Name or a DN.
There are quite a few fields but you can leave some blank
For some fields there will be a default value,
If you enter '.', the field will be left blank.
-----
Country Name (2 letter code) [AU]:IN
State or Province Name (full name) [Some-State]:TAMILNADU
Locality Name (eg, city) []:MADRAS
Organization Name (eg, company) [Internet Widgits Pty Ltd]:ERICSSON
Organizational Unit Name (eg, section) []:CSI
Common Name (e.g. server FQDN or YOUR name) []:SAISUDHAKAR
Email Address []:ABC@DEF.COM
Generate CRT by input the CSR
>openssl x509 -days 3600 -in root_ca.csr -signkey root_ca.key -out root_csr_ca.crt
Loading 'screen' into random state - done
Getting Private key

Create a Subordinate CA to used to under above Root CA

First Generate Key:
>openssl genrsa -out sub_ca.key 4096
..................................++
..............................++
e is 65537 (0x10001)
request a certificate for this subordinate CA:
>openssl req -new -key sub_ca.key -out sub_ca.csr
Loading 'screen' into random state - done
You are about to be asked to enter information that will be incorporated
into your certificate request.
What you are about to enter is what is called a Distinguished Name or a DN.
There are quite a few fields but you can leave some blank
For some fields there will be a default value,
If you enter '.', the field will be left blank.
-----
Country Name (2 letter code) [AU]:IN
State or Province Name (full name) [Some-State]:TAMILNADU
Locality Name (eg, city) []:MADRAS
Organization Name (eg, company) [Internet Widgits Pty Ltd]:HCL
Organizational Unit Name (eg, section) []:BROSS
Common Name (e.g. server FQDN or YOUR name) []:JEAN
Email Address []:JEAN@HCL.COM

Please enter the following 'extra' attributes
to be sent with your certificate request
A challenge password []:password
An optional company name []:IBM
process the request for the subordinate CA certificate and get it signed by the root CA.
>openssl x509 -req -days 730 -in sub_ca.csr -CA root_ca.crt -CAkey root_ca.key -set_serial 01 -out sub_ca.crt
Loading 'screen' into random state - done
Signature ok
subject=/C=IN/ST=TAMILNADU/L=MADRAS/O=HCL/OU=BROSS/CN=JEAN/emailAddress=JEAN@HCL.COM
Getting CA Private Key
The cert will be valid for 2 years (730 days) and I decided to choose my own serial number 01 for this cert (-set_serial 01). For the root CA, I let OpenSSL generate a random serial number.
Like above we can create multiple sub ordinate CA under Root CA.

To package the keys and certs(root CA and all subordinate CA) in a PKCS12 file
>openssl pkcs12 -export -out sub_ca.p12 -inkey sub_ca.key -in sub_ca.crt -chain -CAfile root_ca.crt
Loading 'screen' into random state - done
Enter Export Password:
Verifying - Enter Export Password:
To view CSR contains
If it is self-signed(root) CSR
>openssl x509 -text -noout -in root_ca.csr
If it is not self-signed CA
>openssl req -text -noout -in sub_ca.csr
To view CRT contains
>openssl x509 -text -noout -in root_ca.crt

Merge Objects using Reflection API

2015-08-13T16:18:00.002+05:30

Merging the two objects using Reflection API

For example the class Animal has objects Tiger, Lion, following is show how to merge these objects using Reflection API

class Animal
{
private name;
private age;
private weight;

..setter/getters

}

Main class

Class Main {
public static void main(String[] args)
{
    Animal tiger = new Animal();
    tiger.setName("Tiger");
    tiger.setAge("20");
    tiger.setWeight("80");
    Animal lion = new Animal();
    lion.setName("Lion");
    lion.setAge("25");
    lion.setWeight("120");
  
    merge(tiger,lion);
    
    sysout.println(tiger);
}

public static void merge(Object obj, Object update) {
       
        if (!obj.getClass().isAssignableFrom(update.getClass())) {
            return;
        }

        Method[] methods = obj.getClass().getMethods();

        for (Method fromMethod : methods) {
            if (fromMethod.getDeclaringClass().equals(obj.getClass())
                    && fromMethod.getName().startsWith("get")) {

                String fromName = fromMethod.getName();
                String toName = fromName.replace("get", "set");

                try {
                    Method toMetod = obj.getClass().getMethod(toName,
                            fromMethod.getReturnType());
                    Object value = fromMethod.invoke(update, (Object[]) null);
                    if (value != null) {
                        toMetod.invoke(obj, value);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

Output:
[Lion, 25, 120]
Tiger objects properties were overriden by Lion object properties.

Post Json message to JMS Queue of Hornet Queue on JBoss

2015-06-30T15:49:00.001+05:30

Here we do Posting the Json string contained JMS text message into a JMS HornetQ on Jboss server.
Here we are using Clustered based JMS setup on Jboss.

Test data contains the below json texts in *.json files.
For example TC1.json file contains below texts:

{
   "ID":"clkeidkerk948fjfmfkk49k",
   "name":"Purushottam",
   "value":"20000010"
}

Below are the steps:

import java.io.File;
import java.io.IOException;
import java.util.Iterator;

import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.commons.io.FileUtils;
import org.hornetq.api.core.DiscoveryGroupConfiguration;
import org.hornetq.api.core.UDPBroadcastGroupConfiguration;
import org.hornetq.api.jms.HornetQJMSClient;
import org.hornetq.api.jms.JMSFactoryType;
import org.hornetq.jms.client.HornetQConnectionFactory;

public class PostQueue {


    public static QueueConnection connection = null;

    public PostQueue() {
    }

    private void initJMSLister() {
 
 try {
     String discoveryGroupName = "dg-group1";
     String groupAddress = "231.7.7.7";
     int groupPort = 9876;
     int localPort = -1;
     String localBindAddress = "142.133.174.76";
     long refreshWaitTimeout = 1000;
     long initialWaitTimeout = 5000;

above is the starting the code .

Step2:

     UDPBroadcastGroupConfiguration udpConfig = new UDPBroadcastGroupConfiguration(groupAddress, groupPort, localBindAddress, localPort);
     System.out.println("udpConfig=\n" + udpConfig);
     DiscoveryGroupConfiguration groupConfiguration = new DiscoveryGroupConfiguration(discoveryGroupName, refreshWaitTimeout, initialWaitTimeout,udpConfig);
  System.out.println("groupConfiguration=\n" + groupConfiguration);
     HornetQConnectionFactory jmsConnectionFactory = HornetQJMSClient.createConnectionFactoryWithHA(groupConfiguration,JMSFactoryType.CF);
  System.out.println("jmsConnectionFactory=\n" + jmsConnectionFactory);
  
     String queueName = "QueueName1";
     final Queue queue = HornetQJMSClient.createQueue(queueName);
     connection = jmsConnectionFactory.createQueueConnection("testuser", "testuser@1");
  System.out.println("connection=\n" + connection);
     final QueueSession session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
     QueueReceiver receiver = session.createReceiver(queue);
     receiver.setMessageListener(new MessageListener() {
          @Override
          public void onMessage(Message message) {
            
            System.out.println("Message received.");
            TextMessage eventMessage = (TextMessage) message;
            String jsonEventMessage = null;
            try {
              jsonEventMessage = eventMessage.getText();
              
              System.out.println("Message Id: "+jsonEventMessage);
            }catch(Exception e){e.printStackTrace();}
            
          }
        });
     connection.start();

Step3: This part will explained in 3 sections as shown below:
Listener part:

     System.out.println(" Event Queue Listerner Started");
     new Thread() {
  public void run() {
      System.out.println(" Event Queue Sender Started");
      try {
      javax.jms.QueueSender sender1 = session.createSender(queue);
   
            String[] ext = {"json"};
            Iterator<File> it = FileUtils.iterateFiles(new File("/opt/jboss/testjms/testdata"), ext, true);
            while(it.hasNext()){
              File test = (File)it.next();
              String tmp = FileUtils.readFileToString(test, "UTF-8");
              System.out.println(test.getName()+"\n"+tmp);
              
              TextMessage tm = session.createTextMessage(tmp);
              sender1.send(tm);
              
              System.out.println("msg. "+test.getName() + " sent.");
              Thread.sleep(1000);
            }
          } catch (Exception e1) {
            e1.printStackTrace();
          }
  }

     }.start();

Shutdown hook for JMS connection:

     Runtime.getRuntime().addShutdownHook(new Thread() {
      @Override
      public void run() {   
   if(connection!=null)
    try {
        connection.close();
        System.out.println("connection closed");
    } catch (JMSException e) {
        e.printStackTrace();
    }
      }
     });

 } catch (Exception ee) {
     ee.printStackTrace();
 }
    }

Main method:

public static void main(String[] args) {

 try {
     PostQueue ab = new PostQueue();
     ab.initJMSLister();
 } catch (Exception ex) {
     ex.printStackTrace();
 }
    }
}

Spring JMS Complete Series

2015-06-16T16:59:00.003+05:30

Part 1 Step1 : Build a Maven WebApp Project Step 2: Add the below dependencies:

<dependency>
     <groupId>org.springframework</groupId>
 <artifactId>spring-core</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-beans</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-context</artifactId>
</dependency>

<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-web</artifactId>
</dependency>

Generate Serializable classes from XSD schema

2015-06-03T13:12:00.002+05:30

Below is the code snippet to generate the serializable classes from Xsd schema xml:

Part 1: this section is normal to xsd file.

1
2
3

<?xml version="1.0" encoding="utf-8"?>
<xsd:schema targetNamespace="http://www.apertio.com/webservice/TmoUsEIRSoap/v1"
    xmlns:typens="http://www.apertio.com/webservice/TmoUsEIRSoap/v1"

Part 2: Below section is the required attributes/values to generate the serializable classes for xsd.

xmlns:jaxb="http://java.sun.com/xml/ns/jaxb"
    xmlns:xjc="http://java.sun.com/xml/ns/jaxb/xjc"
    jaxb:extensionBindingPrefixes="xjc"
    jaxb:version="1.0" >

Part 3:Below section is the required xml tags to generate the serializable classes for xsd.

<xsd:annotation>
   <xsd:appinfo>
      <jaxb:globalBindings generateIsSetMethod="false">
         <xjc:serializable uid="1"/>
      </jaxb:globalBindings>
   </xsd:appinfo>
</xsd:annotation>

Part 4: Finally this section is normal to xsd file which contains the xsd elements.

<xsd:element name="QueryReq">
        <xsd:complexType>
          <xsd:sequence>
            <xsd:element type="xsd:integer" minOccurs="1" maxOccurs="1" name="tranId" />
            <xsd:element type="xsd:integer" minOccurs="1" maxOccurs="1" name="reqId" />
            <xsd:element type="xsd:integer" minOccurs="0" maxOccurs="1" name="version" />
            <xsd:element type="xsd:string" minOccurs="0" maxOccurs="1" name="capability" />
          </xsd:sequence>
        </xsd:complexType>
      </xsd:element>
    </xsd:schema>

Ajax Implementation

2011-01-23T23:44:00.001+05:30

Ajax (shorthand for Asynchronous JavaScript and XML) is a group of interrelated web development methods used on the client-side to create interactive web applications. With Ajax, web applications can retrieve data from the server asynchronously in the background without interfering with the display and behavior of the existing page. Data is usually retrieved using the XMLHttpRequest object. Despite the name, the use of XML is not needed, and the requests need not be asynchronous.

Implementation:
Step 1 Jsp part : wrote the following code in JSP where Ajax calls made

above was in <script></script> only.

in the body section

Step 2: Java Part:

xxxAction.java

..,,,,,
And forward mapping to NULL.

Sorting the objects using collections

2011-01-10T23:24:00.000+05:30

We can implement using two following ways:

Way 1:
Step 1:
the object which supposed to sort in collection needs to be implements Comparable interface
For Ex: Object TestPOJO needs to be sort so that class looks like below:

public class TestPOJO implements Comparable
{
int id;
String code;
TestPOJO(int a, String b){
this.id=a;
this.code=b;
}
………..
Getters/setters…
}
Step 2: below this for Ascending order
Override the compareTo method
public int compareTo(Object obj)
{
int retVal = 0;
TestPOJO testPojo1 = (TestPOJO)obj;
if(testPojo1!=null )
{
if((testPojo1!= null) && (this.getCode() != null))
{
retVal = this.getCode().compareTo(testPojo1.getCode());
}
}
return retVal;
}
Step 3:
The Main Class where you are sorting the list of objects:
List testPOJOList = new ArrayList();
TestPOJO obj1 = new TestPOJO(1,”SBI”);
TestPOJO obj2 = new TestPOJO(1,”ABN AMRO”);
TestPOJO obj3 = new TestPOJO(1,”ANB”);
TestPOJO obj4 = new TestPOJO(1,”KVB”);
TestPOJO obj5 = new TestPOJO(1,”SYN”);
TestPOJO obj6 = new TestPOJO(1,”SCB”);

testPOJOList.add(obj1);
testPOJOList.add(obj2);
testPOJOList.add(obj3);
testPOJOList.add(obj4);
testPOJOList.add(obj5);
testPOJOList.add(obj6);

if((testPOJOList!= null) && (testPOJOList.size() > 0))
{
Collections.sort(testPOJOList);
}

Way2:
Using anonymous class
For this way of implementation as in above step1, step 2: not required here.

For Ex: Object TestPOJO needs to be sort so that class looks like below:
No need to implement comparable interface here.
public class TestPOJO
{
int id;
String code;
TestPOJO(int a, String b){
this.id=a;
this.code=b;
}
………..
Getters/setters…
}
Here we need to pass the Comparator object to the Collections.sort method and override the compare(obj,obj) method like below:
Collections.sort(testPOJOList, new Comparator()
{
public int compare(Object o1, Object o2)
{
TestPOJO test1 = (TestPOJO) o1;
TestPOJO test2 = (TestPOJO) o2;

String d1 = (String) test1.getCode(); /////// line A
String d2 = (String) test2.getCode; /////// line B
return d1.compareTo(d2); ///////////// line C
}
}
);
In above way also we can use the first way:
Just replace the line A, Line B, Line c with below line
return test1.compareTo(test2);
And TestPOJO class should be implements Comparable interface and must override the compareTo(object) method.

Production Issue search enhancement

2010-12-21T23:44:00.002+05:30

Issue history:

added username to all custom search api’s queries. We must ignore username from search results.

Changes done on common file’s method which all custom search api’s being used.

Issue raised: some custom search api’s missed out with out adding username.

Impact: required values also missed from search results of the custom search apis which doesn’t have username.

Severity: High

Priority: Top

Solution Approach:

While adding username to query keep alias name to the username.

SELECT ‘LOGGED_USERNAME’ PROD_USER, …..FROM … WHERE….

Changes were required in common file.While ignoring the username from the results checking the username included or not [resultSetMetaData.getColumName(i) ==’PROD_USER_ID’]. If not included keep the old code which populating search result. If included customize the search by ignoring username from the results.

Getting OC4J Admin Console to work in OC4J 9 0 4

2010-12-21T23:37:00.000+05:30

What you say? There's no management console with OC4J 9.0.4 standalone. Well yes, officially you are 100% correct. There is no supported management console for the 9.0.4 release.

But ....

With a little bit of configuration, you can get the prototype admin console we've been using to test out a few things on the server side, up and running for OC4J 9.0.4 standalone. It's basically the same thing as the OC4J Admin Console that's configured out of the box in the OC4J 10.0.3 Developer Preview we have available now on OTN.

Just to make it clear -- this is completely unsupported -- there's a chance that it may do something strange to your configuration which you may need to recover from.

But for those of you who want to do deployments, web application binding, configurations of datasources and user provisioning, it gives you a simple browser based interface to work with.

To get it running do the following:

1. Edit j2ee/home/config/application.xml and add the following lines:
<web-module id="admin_web" path="../../home/applications/admin_web.war"/>
<ejb-module id="admin_ejb" path="../../home/applications/admin_ejb.jar"/>

This adds the OC4J Admin Console apps to the default application.

2. Edit j2ee/home/config/http-web-site.xml and add the following line:
<web-app application="default" name="admin_web" root="/adminoc4j" />

This binds the web module to the root path of /adminoc4j.

When you save these files, OC4J should detect the config file changes and auto-deploy the admin* applications.

Once the deployment has completed, you should be able to access the OC4J Admin Console using a URL of the form

http://localhost:8888/adminoc4j

The server side foundation layed by this work in the OC4J 9.0.4 release went on to become the JSR77/88 and JMX functional areas in the OC4J 10.0.3 release.

Enter the user Credentials(from j2ee/home/config/jazn-data.xml) and click OK.

<jazn-data>

<jazn-realm>
<realm>
<name>jazn.com</name>
<users>
<user>
<name>anonymous</name>
<description>The default guest/anonymous user</description>
</user>
<user>
<name>admin</name>
<display-name>OC4J Administrator</display-name>
<description>OC4J Administrator</description>
<credentials>!password</credentials>
</user>
</users>
<roles>
<role>
<name>administrators</name>
<display-name>Realm Admin Role</display-name>
<description>Administrative role for this realm.</description>
<members>
<member>
<type>user</type>
<name>admin</name>
</member>
</role>
</roles>
</realm>
</jazn-realm>
</jazn-data>

Sorting the the List of Objects using Collections

2010-12-21T23:11:00.001+05:30

A List l may be sorted as follows.

Collections.sort(l);

If the List consists of String elements, it will be sorted into alphabetical order. If it consists of Date elements, it will be sorted into chronological order. How does this happen? String and Date both implement the Comparable interface. Comparable implementations provide a natural ordering for a class, which allows objects of that class to be sorted automatically.

Way 1:

Step 1:

the object which supposed to sort in collection needs to be implements Comparable interface

For Ex: Object TestPOJO needs to be sort so that class looks like below:

public class TestPOJO implements Comparable
{
 int id;
 String code;
 TestPOJO(int a, String b){
this.id=a;
this.code=b;
}
 ………..
 Getters/setters…
}

Step 2: below this for Ascending order

Override the compareTo method

public int compareTo(Object obj)
{
    int retVal = 0;
    TestPOJO testPojo1 = (TestPOJO)obj;
    if(testPojo1!=null )
    {
      if((testPojo1!= null) && (this.getCode() != null))
      {
         retVal = this.getCode().compareTo(testPojo1.getCode());
      }
    }
    return retVal;
 }

Step 3:

The Main Class where you are sorting the list of objects:

List testPOJOList = new ArrayList();
TestPOJO obj1 = new TestPOJO(1,”SBI”);
TestPOJO obj2 = new TestPOJO(1,”ABN AMRO”);
TestPOJO obj3 = new TestPOJO(1,”ANB”);
TestPOJO obj4 = new TestPOJO(1,”KVB”);
TestPOJO obj5 = new TestPOJO(1,”SYN”);
TestPOJO obj6 = new TestPOJO(1,”SCB”);

testPOJOList.add(obj1);
testPOJOList.add(obj2);
testPOJOList.add(obj3);
testPOJOList.add(obj4);
testPOJOList.add(obj5);
testPOJOList.add(obj6);

if((testPOJOList!= null) && (testPOJOList.size() > 0))
{        
    Collections.sort(testPOJOList);
}

Way2:
Using anonymous inner-class

For this way of implementation as in above step1, step 2: not required here.

For Ex: Object TestPOJO needs to be sort so that class looks like below:

No need to implement comparable interface here.

public class TestPOJO 
{
int id;
String code;
TestPOJO(int a, String b){
this.id=a;
this.code=b;
}
………..
Getters/setters…
}

Here we need to pass the Comparator object to the Collections.sort method and override the compare(obj,obj) method like below:

Collections.sort(testPOJOList, new Comparator() 
{
public int compare(Object o1, Object o2) 
{
TestPOJO test1 = (TestPOJO) o1;
TestPOJO test2 = (TestPOJO) o2;

String d1 = (String) test1.getCode(); /////// line A
String d2 = (String) test2.getCode;   /////// line B
return d1.compareTo(d2);        ///////////// line C
}
}
);

In above way also we can use the first way:

Just replace the line A, Line B, Line c with below line

return test1.compareTo(test2);

And TestPOJO class should be implements Comparable interface and must override the compareTo(object) method.

The compare method compares its two arguments, returning a negative integer, 0, or a positive integer depending on whether the first argument is less than, equal to, or greater than the second. If either of the arguments has an inappropriate type for the Comparator, the compare method throws a ClassCastException.

If you try to sort a list, the elements of which do not implement Comparable, Collections.sort(list) will throw a ClassCastException. Similarly, Collections.sort(list, comparator) will throw a ClassCastException if you try to sort a list whose elements cannot be compared to one another using the comparator. Elements that can be compared to one another are called mutually comparable. Although elements of different types may be mutually comparable, none of the classes listed here permit interclass comparison.
This is all you really need to know about the Comparable interface if you just want to sort lists of comparable elements or to create sorted collections of them. The next section will be of interest to you if you want to implement your own Comparable type.

How to redirect the IO Streams

2010-12-21T02:10:00.003+05:30

In Java IO streams are flows of data you can either read from, or write to. Streams are typically connected to a data source, or data destination, like a file, network connection etc.

A stream has no concept of an index of the read or written data, like an array does. Nor can you typically move forth and back in a stream, like you can in an array, or in a file using RandomAccessFile. A stream is just a continuous flow of data.

In Java IO streams are typically byte based. This means that you can either read bytes from, or write bytes to a stream. If you need to read / write characters (like Latin1 or UNICODE characters), you should use a Reader or Writer.

OutputStream

The class java.io.OutputStream is the base class of all Java IO output streams. If you are writing a component that needs to write output to a stream, try to make sure that component depends on an OutputStream and not one of its subclasses.

System.out is a static variable of the System class that holds a reference to a PrintStream used to channel output to the host system's console. System.err is also a PrintStream and System.in is an InputStream. When the Java runtime system starts up it automatically hooks-up these object references to the host system's output, error and input streams.

The PrintStream and InputStream types used to interface with the host system are not subclasses of the System class, they are a subclasses of the java.io.OutputStream and InputStream hierarchy. Notably the PrintStream class never throws IOException, though you can use the checkError() method to discover any problems.

The common technique of making print calls with System.out.println() gives the impression that println() may be a method of the System class but it is not, it is a method of the PrintStream class.

To Disable the System.out.println writes in console while in production environments:

the following will disable the error/exception prints in console:

To Enable the System.out.println writes in console while in development environments: