problem in concurrent web services

Question

Hi All I have developed a web services. I am getting problem when two different user are trying to access web services concurrently. In web services two methods are there

setInputParameter

getUserService

suppose

          Time               User              Operation
          10:10 am           user1             setInputParameter
          10:15 am           user2             setInputParameter
          10:20 am           user1             getUserService

User1 is getting result according to the input parameter seted by user2 not by ( him own )

I am using axis2 1.4 ,eclipse ant build, My services are goes here

User class
service class
service.xml
build file
testclass

package com.jimmy.pojo;


public class User {
 private String firstName;
 private String lastName;
 private String[] addressCity;

 public String getFirstName() {
  return firstName;
 }

 public void setFirstName(String firstName) {
  this.firstName = firstName;
 }

 public String getLastName() {
  return lastName;
 }

 public void setLastName(String lastName) {
  this.lastName = lastName;
 }

 public String[] getAddressCity() {
  return addressCity;
 }

 public void setAddressCity(String[] addressCity) {
  this.addressCity = addressCity;
 }

}
[/code]


[code=java]package com.jimmy.service;

import com.jimmy.pojo.User;

public class UserService {
 private User user;

 public void setInputParameter(User userInput) {
  user = userInput;
 }

 public User getUserService() {
  user.setFirstName(user.getFirstName() + " changed ");
  if (user.getAddressCity() == null) {
   user.setAddressCity(new String[] { "New City Added" });
  } else {
   user.getAddressCity()[0] = "===========";
  }
  return user;
 }

}
[/code]


[code=java]
 
  My Web Service
    
 
  
  
 
 com.jimmy.service.UserService
 

[/code]




[code=java]

 
 
 
  
 
 
 
  
   
  
 
 
  
   
  
  
   
  
 
 
  
  
 
 
  
  
  
  
 
 
  
  
   
  
  
  
 


[/code]






[code=java]package com.jimmy.test;

import javax.xml.namespace.QName;

import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import com.jimmy.pojo.User;

public class MyWebServices {
 @SuppressWarnings("unchecked")
 public static void main(String[] args1) throws AxisFault {
  RPCServiceClient serviceClient = new RPCServiceClient();
  Options options = serviceClient.getOptions();
  EndpointReference targetEPR = new EndpointReference(
    "http://localhost:8080/axis2/services/MyWebServices");
  options.setTo(targetEPR);
  // Setting the Input Parameter
  QName opSetQName = new QName("http://service.jimmy.com",
    "setInputParameter");
  User user = new User();
  String[] cityList = new String[] { "Bangalore", "Mumbai" };
  /*       We need to set this for user 2 as user 2    */
  user.setFirstName("User 1  first name");
  user.setLastName("User 1 Last name");
  user.setAddressCity(cityList);
  Object[] opSetInptArgs = new Object[] { user };
  serviceClient.invokeRobust(opSetQName, opSetInptArgs);

  // Getting the weather
  QName opGetWeather = new QName("http://service.jimmy.com",
    "getUserService");

  Object[] opGetWeatherArgs = new Object[] {};
  Class[] returnTypes = new Class[] { User.class };

  Object[] response = serviceClient.invokeBlocking(opGetWeather,
    opGetWeatherArgs, returnTypes);

  System.out.println("Context :"+serviceClient.getServiceContext());

  User result = (User) response[0];

  if (result == null) {
   System.out.println("User is not initialized!");
   return;
  } else {
   System.out.println("*********printing result********");
   String[] list =result.getAddressCity();
   System.out.println(result.getFirstName());
   System.out.println(result.getLastName());
   for (int indx = 0; indx < list.length ; indx++) {
    String string = result.getAddressCity()[indx];
    System.out.println(string);
   }
  }

 }
}

problem in concurrent web services

Answers (1)

Related Questions