* @author michal.polkorab
*/
public class WaitForMessageEvent implements ClientEvent {
-
+
private static final Logger LOGGER = LoggerFactory.getLogger(WaitForMessageEvent.class);
private byte[] headerExpected;
private byte[] headerReceived;
* @param headerExpected header (first 8 bytes) of expected message
*/
public WaitForMessageEvent(byte[] headerExpected) {
- this.headerExpected = headerExpected;
+ this.headerExpected = new byte[headerExpected.length];
+ for (int i = 0; i < headerExpected.length; i++) {
+ this.headerExpected[i] = headerExpected[i];
+ }
}
@Override
return false;
}
if (!Arrays.equals(headerExpected, headerReceived)) {
- LOGGER.debug("expected msg: " + ByteBufUtils.bytesToHexString(headerExpected));
- LOGGER.debug("received msg: " + ByteBufUtils.bytesToHexString(headerReceived));
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("expected msg: {}", ByteBufUtils.bytesToHexString(headerExpected));
+ LOGGER.debug("received msg: {}", ByteBufUtils.bytesToHexString(headerReceived));
+ }
return false;
}
LOGGER.debug("Headers OK");
* @param headerReceived header (first 8 bytes) of expected message
*/
public void setHeaderReceived(byte[] headerReceived) {
- this.headerReceived = headerReceived;
+ this.headerReceived = new byte[headerReceived.length];
+ for (int i = 0; i < headerReceived.length; i++) {
+ this.headerReceived[i] = headerReceived[i];
+ }
}
-
-
}