Sahithi,
You may use the below code to generate counter . Reprocessing of same message is also taken care where counter doesn't get incremented.
And for avoiding issue with multi instance in PI/PO system i am using a common folder . You may change the folder if required but make sure it is common for all instance in your PI system.
1.Compile the below code in required JDK version and import into your namespace via Imported Archive.
2.Add this archive into your mapping and also add import statement.
3.Call it via UDF via 2 inputs : a.) Messsge ID b.)Some constant (Add your mapping name as constant)
In UDF call as :
return SetCounter.MsgID(msgid,Const);
Complete Code :
package com.sap.mapping.java;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.*;
public class SetCounter
{
public static void main(String[] args)
{
String msgID= "123456";
String Const= "Map2";
System.out.println(SetCounter.MsgID(msgID,Const));
}
public static String MsgID(String msgid,String Const)
{
String U_Counter="";
Properties properties = new Properties();
File propertiesfile = new File("D:/usr/sap/MsgId.txt");
try
{
propertiesfile.createNewFile();
properties.load(new FileInputStream(propertiesfile));
}
catch (IOException e)
{
e.printStackTrace();
return "Error:File not read";
}
String number = properties.getProperty(msgid);
if (number == null)
{
number = "0";
String counter = String.valueOf(Integer.parseInt(number) + 1);
properties.setProperty(msgid, counter);
U_Counter= getCounter(Const,"ADD");
}
U_Counter= getCounter(Const,"GET");
try
{
properties.store(new FileOutputStream(propertiesfile), null);
} catch (IOException e) {
return "Error:File not updated";
}
return U_Counter;
}
public static String getCounter(String Const , String opr)
{
String counter = "";
Properties properties = new Properties();
File propertiesfile = new File("D:/usr/sap/Counter.txt");
try
{
propertiesfile.createNewFile();
properties.load(new FileInputStream(propertiesfile));
}
catch (IOException e)
{
e.printStackTrace();
return "Error:File not read";
}
String number = properties.getProperty(Const);
if (number == null)
{
number = "0";
counter = String.valueOf(Integer.parseInt(number) + 1);
properties.setProperty(Const, counter);
}
else
{
if(opr.equalsIgnoreCase("ADD"))
{
counter = String.valueOf(Integer.parseInt(number) + 1);
properties.setProperty(Const, counter);
}
else
{
counter = number;
}
}
try
{
properties.store(new FileOutputStream(propertiesfile), null);
} catch (IOException e) {
return "Error:File not updated";
}
return counter;
}
}
Br,
Manoj
You must be a registered user to add a comment. If you've already registered, sign in. Otherwise, register and sign in.