speed about jsmpp HOT 1 OPEN

final AtomicInteger counter = new AtomicInteger();

private SMPPSession session = null;

private String operator;
private String remoteIpAddress;
private Integer remotePort;
private String user;
private String password;
private BindParameter bindParam;

//Database query size
private int size;

//Sleep after each segment
private int segmentSleep=100;

//Sleep in loop
private int loopSleep=100;

//Operator thread
private int executorId;

//Prefix for response id to unique message id between operators
private String responsePrefix;

public AsyncDelivery(String configFileName)  
{
	
	
	if (this.setConfigValues(configFileName)==true)
	{
			this.bindParam = new BindParameter(BindType.BIND_TRX, this.user, this.password, "cp",TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.UNKNOWN, null);
			
			try
			{
				this.session = new SMPPSession(this.remoteIpAddress, this.remotePort, this.bindParam);
			}
			catch(Exception e)
			{
				System.out.println("Can't create session.");
				System.exit(0);
			}
		
	        this.session.setMessageReceiverListener(new MessageReceiverListener() 
	        {
	            public void onAcceptDeliverSm(DeliverSm deliverSm) throws ProcessRequestException 
	            {
	            	
	            	
	                if (MessageType.SMSC_DEL_RECEIPT.containedIn(deliverSm.getEsmClass())) 
	                {
	                    counter.incrementAndGet();
	                
	                    // delivery receipt
	                    try 
	                    {
	                        //DeliveryReceipt delReceipt = deliverSm.getShortMessageAsDeliveryReceipt();
	                        //long id = Long.parseLong(delReceipt.getId()) & 0xffffffff;
	                        //String messageId = Long.toString(id, 16).toUpperCase();
	                        //System.out.println("Receiving delivery receipt for message '" + messageId + "' : " + delReceipt);
	                    	
	                    	OptionalParameter.Receipted_message_id parameterId = (Receipted_message_id) deliverSm.getOptionalParameter(Tag.RECEIPTED_MESSAGE_ID);
	                    	OptionalParameter.Message_state parameterState = (Message_state) deliverSm.getOptionalParameter(Tag.MESSAGE_STATE);
	                    	
	                    	System.out.println("messageId: " + parameterId.getValueAsString());
	                    	System.out.println("messageState: " + parameterState.getMessageState().name());
	                    	
	                    } 
	                    catch (Exception e) 
	                    {
	                        System.err.println("Failed getting delivery receipt");
	                        e.printStackTrace();
	                    }
	                } 
	                else 
	                {
	                    // regular short message
	                    System.out.println("Receiving message : " + new String(deliverSm.getShortMessage()));
	                }
	            }
	            
	            public void onAcceptAlertNotification(AlertNotification alertNotification) 
	            {
	            }
	            
	            public DataSmResult onAcceptDataSm(DataSm dataSm, Session source)
	                    throws ProcessRequestException 
	            {
	                // TODO Auto-generated method stub
	                return null;
	            }
	        });
		
		
		
	}
	else
	{
		System.out.println("Nepavyko nustatyti parametrų iš config.txt failo!");
		System.exit(0);
	}
}


public static void main(String[] args) 
{
    //Log activation
    //BasicConfigurator.configure();
	
	final AsyncDelivery main = new AsyncDelivery("config_bite.txt");
	
    // Now we will send 50 message asynchronously with max outstanding messages 10.
    ExecutorService execService = Executors.newFixedThreadPool(6);
    
    // requesting delivery report
    final RegisteredDelivery registeredDelivery = new RegisteredDelivery();
    registeredDelivery.setSMSCDeliveryReceipt(SMSCDeliveryReceipt.SUCCESS_FAILURE);
    
    final int maxMessage = 10;
    
    for (int i = 0; i < maxMessage; i++) 
    {
        
        execService.execute(new Runnable() 
        {
            public void run() 
            {
                try 
                {
                    String messageId = main.session.submitShortMessage("CMT", TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.UNKNOWN, "NKC", TypeOfNumber.INTERNATIONAL, NumberingPlanIndicator.UNKNOWN, "37067425942", new ESMClass(), (byte)0, (byte)1,  timeFormatter.format(new Date()), null, registeredDelivery, (byte)0, DataCodings.ZERO, (byte)0, ("jSMPP "+new Date().getTime()).getBytes());
                    System.out.println("Message submitted, message_id is " + messageId);
                } 
                catch (PDUException e) 
                {
                    System.err.println("Invalid PDU parameter");
                    e.printStackTrace();
                    main.counter.incrementAndGet();
                } 
                catch (ResponseTimeoutException e) 
                {
                    System.err.println("Response timeout");
                    e.printStackTrace();
                    main.counter.incrementAndGet();
                } 
                catch (InvalidResponseException e) 
                {
                    // Invalid response
                    System.err.println("Receive invalid respose");
                    e.printStackTrace();
                    main.counter.incrementAndGet();
                } 
                catch (NegativeResponseException e) 
                {
                    // Receiving negative response (non-zero command_status)
                    System.err.println("Receive negative response");
                    e.printStackTrace();
                    main.counter.incrementAndGet();
                } 
                catch (IOException e) 
                {
                    System.err.println("IO error occur");
                    e.printStackTrace();
                    main.counter.incrementAndGet();
                }
            }
        });
    }
    
    while (/*main.counter.get() != maxMessage*/1==1) 
    {
        try { Thread.sleep(100); } catch (InterruptedException e) { }
    }
    
    //main.session.unbindAndClose();
    //execService.shutdown();
    
}


public boolean setConfigValues(String configFileName)
{
	//Skaitom failą config.txt ir nustatymome parametrus
	boolean ret=true;
	
	try 
	{
		
	      File myObj = new File(configFileName);
	      Scanner myReader = new Scanner(myObj);
	    
	      while (myReader.hasNextLine()) 
	      {
	        String line = myReader.nextLine();
	        System.out.println(line);
	        
	        String[] params = line.split(":");
	        
			if (params[0].equals("remoteIpAddress")) 
			{
				this.remoteIpAddress=params[1];
			}
			else if (params[0].equals("remotePort")) 
			{
				this.remotePort = Integer.parseInt(params[1]);
			}
			else if (params[0].equals("user"))
			{
				this.user=params[1];
			}
			else if (params[0].equals("password"))
			{
				this.password=params[1];
			}
			else if (params[0].equals("log_folder"))
			{
				db.PrintLog.logFolder=params[1];
			}
			else if (params[0].equals("operator"))
			{
				this.operator=params[1];
			}
			else if (params[0].equals("size"))
			{
				this.size=Integer.parseInt(params[1]);
			}
			else if (params[0].equals("executor_id"))
			{
				this.executorId=Integer.parseInt(params[1]);
				System.out.println("executorId: " + this.executorId);
			}
			else if (params[0].equals("segment_sleep"))
			{
				this.segmentSleep=Integer.parseInt(params[1]);
				System.out.println("segmentSleep: " + this.segmentSleep);
			}
			else if (params[0].equals("loop_sleep"))
			{
				this.loopSleep=Integer.parseInt(params[1]);
				System.out.println("loopSleep: " + this.loopSleep);
			}
			else if (params[0].equals("response_prefix"))
			{
				this.responsePrefix=params[1];
				System.out.println("response_prefix: " + this.responsePrefix);
			}
			
	      }

	      myReader.close();
	      
	      if (this.remoteIpAddress==null || this.remoteIpAddress.isEmpty()) ret=false;
	      if (this.remotePort==null) ret=false;
	      if (this.user==null || this.user.isEmpty()) ret=false;
	      if (this.password==null || this.password.isEmpty()) ret=false;
	} 
	catch (FileNotFoundException e) 
	{
	     System.out.println(e.toString());
	     ret = false;
	}
	
	return ret;
}