@@ -50,14 +50,14 @@ public MdpTCPMessageRequester(String channelId, List<T> coreChannelListeners, Md
50
50
this .coreChannelListeners = coreChannelListeners ;
51
51
this .mdpMessageTypes = mdpMessageTypes ;
52
52
this .tcpChannel = tcpChannel ;
53
- logon = prepareLogonMessages (username , password );
54
- logout = prepareLogooutMessages ();
53
+ logon = preparePacketWithLogon (username , password );
54
+ logout = preparePacketWithLogout ();
55
55
mdpPacket .wrapFromBuffer (workBuffer );
56
56
}
57
57
58
58
@ Override
59
59
public synchronized boolean askForLostMessages (long beginSeqNo , long endSeqNo , TCPPacketListener tcpPacketListener ) {
60
- ByteBuffer request = prepareRequestMessages (channelId , beginSeqNo , endSeqNo , ++requestCounter );
60
+ ByteBuffer request = preparePacketWithRequest (channelId , beginSeqNo , endSeqNo , ++requestCounter );
61
61
boolean connected = tcpChannel .connect ();
62
62
if (connected ) {
63
63
try {
@@ -152,26 +152,26 @@ private boolean isPacketWithLogout(MdpPacket mdpPacket){
152
152
return firstMessage .getSchemaId () == LOGOUT_TEMPLATE_ID ;
153
153
}
154
154
155
- private ByteBuffer prepareLogonMessages (String username , String password ) {
155
+ private ByteBuffer preparePacketWithLogon (String username , String password ) {
156
156
String logonMessage = "35=A\u0001 553=" + username + "\u0001 554=" + password + "\u0001 " ;
157
157
logonMessage = "9=" + logonMessage .length () + "\u0001 " + logonMessage ;
158
158
String logonChecksum = calculateChecksum (logonMessage );
159
159
return ByteBuffer .wrap ((logonMessage + "10=" + logonChecksum + "\u0001 " ).getBytes ());
160
160
}
161
161
162
- private ByteBuffer prepareLogooutMessages () {
162
+ private ByteBuffer preparePacketWithLogout () {
163
163
String logoutMessage = "35=5\u0001 " ;
164
164
logoutMessage = "9=" + logoutMessage .length () + "\u0001 " + logoutMessage ;
165
- String logonChecksum = calculateChecksum (logoutMessage );
166
- return ByteBuffer .wrap ((logoutMessage + "10=" + logonChecksum + "\u0001 " ).getBytes ());
165
+ String logoutChecksum = calculateChecksum (logoutMessage );
166
+ return ByteBuffer .wrap ((logoutMessage + "10=" + logoutChecksum + "\u0001 " ).getBytes ());
167
167
}
168
168
169
- private ByteBuffer prepareRequestMessages (String channelId , long beginSeqNo , long endSeqNo , int mdReqId ) {
170
- String logonMessage = "35=V\u0001 " + "1180=" + channelId + "\u0001 262=" + channelId + "-" + mdReqId +
169
+ private ByteBuffer preparePacketWithRequest (String channelId , long beginSeqNo , long endSeqNo , int mdReqId ) {
170
+ String requestMessage = "35=V\u0001 " + "1180=" + channelId + "\u0001 262=" + channelId + "-" + mdReqId +
171
171
"\u0001 1182=" + beginSeqNo + "\u0001 1183=" + endSeqNo + "\u0001 " ;
172
- logonMessage = "9=" + logonMessage .length () + "\u0001 " + logonMessage ;
173
- String logonChecksum = calculateChecksum (logonMessage );
174
- return ByteBuffer .wrap ((logonMessage + "10=" + logonChecksum + "\u0001 " ).getBytes ());
172
+ requestMessage = "9=" + requestMessage .length () + "\u0001 " + requestMessage ;
173
+ String requestChecksum = calculateChecksum (requestMessage );
174
+ return ByteBuffer .wrap ((requestMessage + "10=" + requestChecksum + "\u0001 " ).getBytes ());
175
175
}
176
176
177
177
private String calculateChecksum (String message ) {
0 commit comments