*/
package org.opendaylight.controller.cluster.access.concepts;
+import static org.junit.Assert.assertEquals;
+
import java.io.DataInput;
import java.io.IOException;
-import javax.annotation.Nonnull;
-import org.junit.Assert;
+import org.apache.commons.lang.SerializationUtils;
import org.opendaylight.controller.cluster.access.ABIVersion;
import org.opendaylight.yangtools.concepts.WritableIdentifier;
public class FailureEnvelopeTest extends AbstractEnvelopeTest<FailureEnvelope> {
-
@Override
- protected FailureEnvelope createEnvelope() {
- final RequestFailure<?, ?> message =
- new MockFailure(OBJECT, new RuntimeRequestException("msg", new RuntimeException()), 42);
- return new FailureEnvelope(message, 1L, 2L, 11L);
+ protected EnvelopeDetails<FailureEnvelope> createEnvelope() {
+ final var cause = new RuntimeRequestException("msg", new RuntimeException());
+ final int causeSize = SerializationUtils.serialize(cause).length;
+ return new EnvelopeDetails<>(new FailureEnvelope(new MockFailure(OBJECT, cause, 42), 1L, 2L, 11L),
+ causeSize + 485);
}
@Override
protected void doAdditionalAssertions(final FailureEnvelope envelope, final FailureEnvelope resolvedObject) {
- Assert.assertEquals(envelope.getExecutionTimeNanos(), resolvedObject.getExecutionTimeNanos());
- final RequestException expectedCause = envelope.getMessage().getCause();
- final RequestException actualCause = resolvedObject.getMessage().getCause();
- Assert.assertEquals(expectedCause.getMessage(), actualCause.getMessage());
- Assert.assertEquals(expectedCause.isRetriable(), actualCause.isRetriable());
+ assertEquals(envelope.getExecutionTimeNanos(), resolvedObject.getExecutionTimeNanos());
+ final var expectedCause = envelope.getMessage().getCause();
+ final var actualCause = resolvedObject.getMessage().getCause();
+ assertEquals(expectedCause.getMessage(), actualCause.getMessage());
+ assertEquals(expectedCause.isRetriable(), actualCause.isRetriable());
}
private static class MockRequestFailureProxy extends AbstractRequestFailureProxy<WritableIdentifier, MockFailure> {
+ @java.io.Serial
+ private static final long serialVersionUID = 5015515628523887221L;
@SuppressWarnings("checkstyle:RedundantModifier")
public MockRequestFailureProxy() {
super(mockFailure);
}
- @Nonnull
@Override
- protected MockFailure createFailure(@Nonnull final WritableIdentifier target, final long sequence,
- @Nonnull final RequestException failureCause) {
+ public MockFailure createFailure(final WritableIdentifier target, final long sequence,
+ final RequestException failureCause) {
return new MockFailure(target, failureCause, sequence);
}
- @Nonnull
@Override
- protected WritableIdentifier readTarget(@Nonnull final DataInput in) throws IOException {
+ public WritableIdentifier readTarget(final DataInput in) throws IOException {
return TransactionIdentifier.readFrom(in);
}
-
}
private static class MockFailure extends RequestFailure<WritableIdentifier, MockFailure> {
+ @java.io.Serial
private static final long serialVersionUID = 1L;
MockFailure(final WritableIdentifier target, final RequestException cause, final long sequence) {
protected MockFailure cloneAsVersion(final ABIVersion version) {
return this;
}
-
}
-
}