001
014
015 package com.liferay.portal.kernel.nio.intraband;
016
017
020 public class RecordDatagramReceiveHandler implements DatagramReceiveHandler {
021
022 public RecordDatagramReceiveHandler() {
023 this(true);
024 }
025
026 public RecordDatagramReceiveHandler(boolean throwException) {
027 _throwException = throwException;
028 }
029
030 public Datagram getReceiveDatagram() {
031 return _datagram;
032 }
033
034 @Override
035 public void receive(
036 RegistrationReference registrationReference, Datagram datagram) {
037
038 _datagram = datagram;
039
040 if (_throwException) {
041 throw new RuntimeException("RecordDatagramReceiveHandler");
042 }
043 }
044
045 private volatile Datagram _datagram;
046 private final boolean _throwException;
047
048 }