EC02Builder.java
5.99 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
package af.message;
import java.util.ArrayList;
import af.instatnce.EC02Instance;
import af.instatnce.EQXRawInstance;
import af.interfaces.EQXMsg;
import ec02.af.abstracts.AbstractAF;
import ec02.af.data.EquinoxRawData;
import ec02.af.data.KeyObject;
public class EC02Builder {
private EC02Instance ec02Ins = null;
private AbstractAF abstractAF = null;
private EquinoxRawData eqxRawData =null;
private EC02MSGBuilder msgBuilder = null;
public void setEquinoxRawData(AbstractAF abstractAF, EC02Instance ec02Ins){
this.abstractAF = abstractAF;
this.ec02Ins = ec02Ins;
}
public void setEquinoxRawData(EquinoxRawData eqxRawData, AbstractAF abstractAF, EC02Instance ec02Ins){
this.eqxRawData = eqxRawData;
this.abstractAF = abstractAF;
this.ec02Ins = ec02Ins;
}
public ArrayList<EquinoxRawData> getHTTPRequest(ArrayList<EQXRawInstance> eqxRawList){
ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
for (int i = 0; i < eqxRawList.size(); i++) {
eqxRawList.get(i).setType(EQXMsg.REQUEST);
this.msgBuilder = new EC02MSGBuilder(eqxRawList.get(i));
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke() + i);
eqxRawDataList.add(this.msgBuilder.getHttpMessage());
}
String timeoutConf = this.abstractAF.getUtils().getHmWarmConfig().get("HTTP-timeout").get(0);
String timeout = (timeoutConf == null) ? this.ec02Ins.getAbstractAF().getUtils().getHmWarmConfig().get("Default-timeout").get(0) : timeoutConf;
this.ec02Ins.setTimeout(timeout);
return eqxRawDataList;
}
public EquinoxRawData getHTTPResponse(EQXRawInstance eqxRaw,String invoke){
eqxRaw.setType(EQXMsg.RESPONSE);
this.msgBuilder = new EC02MSGBuilder(eqxRaw);
this.msgBuilder.setInvoke(invoke);
return this.msgBuilder.getHttpMessage();
}
public ArrayList<EquinoxRawData> getLDAPRequest(ArrayList<EQXRawInstance> eqxRawList){
ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
for (int i = 0; i < eqxRawList.size(); i++) {
eqxRawList.get(i).setType(EQXMsg.REQUEST);
this.msgBuilder = new EC02MSGBuilder(eqxRawList.get(i));
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke() + i);
eqxRawDataList.add(this.msgBuilder.getLdapMessage());
}
String timeoutConf = this.abstractAF.getUtils().getHmWarmConfig().get("LDAP-timeout").get(0);
String timeout = (timeoutConf == null) ? this.ec02Ins.getAbstractAF().getUtils().getHmWarmConfig().get("Default-timeout").get(0) : timeoutConf;
this.ec02Ins.setTimeout(timeout);
return eqxRawDataList;
}
public EquinoxRawData getLDAPResponse(EQXRawInstance eqxRaw){
eqxRaw.setType(EQXMsg.RESPONSE);
this.msgBuilder = new EC02MSGBuilder(eqxRaw);
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke());
return this.msgBuilder.getLdapMessage();
}
public ArrayList<EquinoxRawData> getDiameterRequest(ArrayList<EQXRawInstance> eqxRawList){
ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
for (int i = 0; i < eqxRawList.size(); i++) {
eqxRawList.get(i).setType(EQXMsg.REQUEST);
this.msgBuilder = new EC02MSGBuilder(eqxRawList.get(i));
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke() + i);
eqxRawDataList.add(this.msgBuilder.getDiameterMessage());
}
String timeoutConf = this.abstractAF.getUtils().getHmWarmConfig().get("Diameter-timeout").get(0);
String timeout = (timeoutConf == null) ? this.ec02Ins.getAbstractAF().getUtils().getHmWarmConfig().get("Default-timeout").get(0) : timeoutConf;
this.ec02Ins.setTimeout(timeout);
return eqxRawDataList;
}
public EquinoxRawData getDiameterResponse(EQXRawInstance eqxRaw){
eqxRaw.setType(EQXMsg.RESPONSE);
this.msgBuilder = new EC02MSGBuilder(eqxRaw);
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke());
return this.msgBuilder.getDiameterMessage();
}
public ArrayList<EquinoxRawData> getSMPPRequest(ArrayList<EQXRawInstance> eqxRawList){
ArrayList<EquinoxRawData> eqxRawDataList = new ArrayList<EquinoxRawData>();
for (int i = 0; i < eqxRawList.size(); i++) {
eqxRawList.get(i).setType(EQXMsg.REQUEST);
this.msgBuilder = new EC02MSGBuilder(eqxRawList.get(i));
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke() + i);
eqxRawDataList.add(this.msgBuilder.getSMPPMessage());
}
String timeoutConf = this.abstractAF.getUtils().getHmWarmConfig().get("SMPP-timeout").get(0);
String timeout = (timeoutConf == null) ? this.ec02Ins.getAbstractAF().getUtils().getHmWarmConfig().get("Default-timeout").get(0) : timeoutConf;
this.ec02Ins.setTimeout(timeout);
return eqxRawDataList;
}
public EquinoxRawData getSMPPResponse(EQXRawInstance eqxRaw){
eqxRaw.setType(EQXMsg.RESPONSE);
this.msgBuilder = new EC02MSGBuilder(eqxRaw);
this.msgBuilder.setInvoke(this.ec02Ins.getAFInstance().getInvoke());
return this.msgBuilder.getSMPPMessage();
}
public void getE01Request(){
KeyObject keyobj = new KeyObject();
keyobj.setObjectType(this.ec02Ins.getE01Ins().getObjType());
ArrayList<String> keyList = this.ec02Ins.getE01Ins().getKey();
for (int i = 0; i < keyList.size(); i++) {
keyobj.setKey(String.valueOf(i), keyList.get(i));
}
if(this.ec02Ins.getE01Ins().getCmd().equals("search")){
this.abstractAF.getUtils().getGlobalData().search(keyobj);
}
else if(this.ec02Ins.getE01Ins().getCmd().equals("delete")){
this.abstractAF.getUtils().getGlobalData().delete(keyobj);
}
else if(this.ec02Ins.getE01Ins().getCmd().equals("add")){
this.abstractAF.getUtils().getGlobalData().add(keyobj, this.ec02Ins.getE01Ins().getData());
}
else if(this.ec02Ins.getE01Ins().getCmd().equals("replace")){
this.abstractAF.getUtils().getGlobalData().replace(keyobj, this.ec02Ins.getE01Ins().getData());
}
this.abstractAF.getUtils().getGlobalData().setMessageId(this.eqxRawData.getInvoke());
}
public EquinoxRawData getUpdateIns(){
this.msgBuilder = new EC02MSGBuilder();
this.ec02Ins.setTimeout(this.abstractAF.getUtils().getHmWarmConfig().get("Update-Instance-timeout").get(0));
return this.msgBuilder.getUpdateIns();
}
}