Skip to content

Commit 48401c2

Browse files
aefermianopcdv
authored andcommitted
Changing BusinessRejectReason in BusinessMessageReject for BinaryEntryPoint protocol (artiofix#478)
1 parent 147520b commit 48401c2

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Diff for: artio-binary-entrypoint-impl/src/main/java/uk/co/real_logic/artio/binary_entrypoint/InternalBinaryEntryPointConnection.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ class InternalBinaryEntryPointConnection
5858
extends InternalFixPConnection implements BinaryEntryPointConnection
5959
{
6060
private static final UnsafeBuffer EMPTY_BUFFER = new UnsafeBuffer(new byte[0]);
61-
private static final int THROTTLE_REASON = 99;
61+
private static final int THROTTLE_REASON = 33000;
6262

6363
private final BinaryEntryPointProxy proxy;
6464
private final long maxFixPKeepaliveTimeoutInMs;

Diff for: artio-binary-entrypoint-system-tests/src/test/java/uk/co/real_logic/artio/system_tests/BinaryEntryPointClient.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -676,6 +676,6 @@ public void readBusinessReject(final long refSeqNum, final long rejectRefID)
676676
assertEquals(refSeqNum, businessReject.refSeqNum());
677677
assertEquals(MessageType.NewOrderSingle, businessReject.refMsgType());
678678
assertEquals(rejectRefID, businessReject.businessRejectRefID());
679-
assertEquals(99, businessReject.businessRejectReason());
679+
assertEquals(33000, businessReject.businessRejectReason());
680680
}
681681
}

0 commit comments

Comments
 (0)