tagging release 3.278

Author: dxcity

ReleaseNotes.txt

@@ -1,4 +1,8 @@
 
+QDS 3.278:
+
+* [QD-1157] New order source for BATS EU: CEUX
+
 QDS 3.277:
 
 * [QD-1171] Add order record for BITIP top20 book

auth/pom.xml

@@ -14,7 +14,7 @@
     <parent>
         <artifactId>QD</artifactId>
         <groupId>com.devexperts.qd</groupId>
-        <version>3.277</version>
+        <version>3.278</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

dxfeed-api/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.277</version>
+		<version>3.278</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>

dxfeed-api/src/main/java/com/dxfeed/event/market/OrderSource.java

@@ -120,6 +120,11 @@ public final class OrderSource extends IndexedEventSource {
 	 */
 	public static final OrderSource DEFAULT = new OrderSource(0, "DEFAULT", PUB_ORDER | PUB_SPREAD_ORDER);
 
+	// ======== BEGIN: Custom OrderSource definitions ========
+
+	// ATTENTION: Every time a custom OrderSource constant is added run com.dxfeed.api.codegen.ImplCodeGen
+	// and commit updated implementation classes.
+
 	/**
 	 * NASDAQ Total View.
 	 * {@link Order} events are {@link #isPublishable(Class) publishable} on this
@@ -204,6 +209,13 @@ public final class OrderSource extends IndexedEventSource {
 	 */
 	public static final OrderSource CHIX = new OrderSource("CHIX", PUB_ORDER);
 
+	/**
+	 * Bats Europe DXE Exchange.
+	 * {@link Order} events are {@link #isPublishable(Class) publishable} on this
+	 * source and the corresponding subscription can be observed via {@link DXPublisher}.
+	 */
+	public static final OrderSource CEUX = new OrderSource("CEUX", PUB_ORDER);
+
 	/**
 	 * Bats Europe TRF.
 	 * {@link Order} events are {@link #isPublishable(Class) publishable} on this
@@ -253,6 +265,11 @@ public final class OrderSource extends IndexedEventSource {
 	 */
 	public static final OrderSource CFE = new OrderSource("CFE", PUB_ORDER);
 
+	// ATTENTION: Every time a custom OrderSource constant is added run com.dxfeed.api.codegen.ImplCodeGen
+	// and commit updated implementation classes.
+
+	// ======== END: Custom OrderSource definitions ========
+
 	/**
 	 * Determines whether specified source identifier refers to special order source.
 	 * Special order sources are used for wrapping non-order events into order events.

dxfeed-bin/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.277</version>
+		<version>3.278</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>

dxfeed-codegen-verify/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.277</version>
+		<version>3.278</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 

dxfeed-codegen/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.277</version>
+		<version>3.278</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>

dxfeed-codegen/src/main/java/com/dxfeed/api/codegen/ImplCodeGen.java

@@ -18,7 +18,9 @@
 import com.dxfeed.event.candle.impl.CandleEventMapping;
 import com.dxfeed.event.market.MarketEventDelegateImpl;
 import com.dxfeed.event.market.Order;
+import com.dxfeed.event.market.OrderBase;
 import com.dxfeed.event.market.OrderBaseDelegateImpl;
+import com.dxfeed.event.market.OrderSource;
 import com.dxfeed.event.market.Profile;
 import com.dxfeed.event.market.Quote;
 import com.dxfeed.event.market.SpreadOrder;
@@ -36,6 +38,7 @@
 import com.dxfeed.event.option.Underlying;
 
 import java.io.IOException;
+import java.util.stream.Collectors;
 
 /**
  * Main class to generate all implementation-related code for dxFeed.
@@ -215,7 +218,7 @@ public void runForDxfeedImpl() throws IOException {
 			publishable();
 
 		ctx.delegate("Order", Order.class, "Order").
-			suffixes("|#NTV|#NFX|#ESPD|#XNFI|#DEA|#DEX|#BYX|#BZX|#IST|#BI20|#ISE|#BATE|#CHIX|#BXTR|#GLBX|#ERIS|#XEUR|#ICE|#CFE").
+			suffixes(getOrderSuffixes(Order.class)).
 			inheritDelegateFrom(ORDER_BASE_DELEGATE).
 			inheritMappingFrom(ORDER_BASE_MAPPING).
 			source("m.getRecordSource()").
@@ -234,7 +237,7 @@ public void runForDxfeedImpl() throws IOException {
 			map("Count", "Count", FieldType.INT_DECIMAL).onlySuffixes("com.dxfeed.event.order.impl.Order.suffixes.count", "").
 			map("Flags", "Flags", FieldType.FLAGS).
 			map("MarketMaker", "MMID", FieldType.SHORT_STRING).onlySuffixes(
-				"com.dxfeed.event.order.impl.Order.suffixes.mmid", "|#NTV|#BATE|#CHIX|#BXTR").
+				"com.dxfeed.event.order.impl.Order.suffixes.mmid", "|#NTV|#BATE|#CHIX|#CEUX|#BXTR").
 			injectPutEventCode(
 				"if (index < 0)",
 				"\tthrow new IllegalArgumentException(\"Invalid index to publish\");",
@@ -246,7 +249,7 @@ public void runForDxfeedImpl() throws IOException {
 			publishable();
 
 		ctx.delegate("SpreadOrder", SpreadOrder.class, "SpreadOrder").
-			suffixes("|#ISE").
+			suffixes(getOrderSuffixes(SpreadOrder.class)).
 			inheritDelegateFrom(ORDER_BASE_DELEGATE).
 			inheritMappingFrom(ORDER_BASE_MAPPING).
 			source("m.getRecordSource()").
@@ -484,4 +487,19 @@ public void runForDxfeedImpl() throws IOException {
 
 		ctx.generateSources();
 	}
+
+	/**
+	 * Get record suffixes for publishable order sources of specified type as a string delimited by '|' (pipe) symbol.
+	 *
+	 * @param eventType - eventType either <code>{@link Order}.<b>class</b></code>
+	 *                     or <code>{@link SpreadOrder}.<b>class</b></code>.
+	 * @return a list of publishable record suffixes delimited by '|' symbol.
+	 * @see OrderSource#publishable(Class)
+	 */
+	private String getOrderSuffixes(Class<? extends OrderBase> eventType) {
+		return OrderSource.publishable(eventType).stream().
+			filter(os -> !OrderSource.DEFAULT.equals(os) && !OrderSource.isSpecialSourceId(os.id())).
+			map(orderSource -> "|#" + orderSource.name()).
+			collect(Collectors.joining());
+	}
 }

dxfeed-impl/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.277</version>
+		<version>3.278</version>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>
 

dxfeed-impl/src/main/java/com/dxfeed/event/market/MarketFactoryImpl.java

@@ -193,7 +193,7 @@ public void buildScheme(SchemeBuilder builder) {
 		builder.addRequiredField("Profile", "Description", SerialFieldType.UTF_CHAR_ARRAY);
 		builder.addOptionalField("Profile", "StatusReason", SerialFieldType.UTF_CHAR_ARRAY, "Profile", "StatusReason", true);
 
-		for (String suffix : SystemProperties.getProperty("com.dxfeed.event.market.impl.Order.suffixes", "|#NTV|#NFX|#ESPD|#XNFI|#DEA|#DEX|#BYX|#BZX|#IST|#BI20|#ISE|#BATE|#CHIX|#BXTR|#GLBX|#ERIS|#XEUR|#ICE|#CFE").split("\\|")) {
+		for (String suffix : SystemProperties.getProperty("com.dxfeed.event.market.impl.Order.suffixes", "|#NTV|#NFX|#ESPD|#XNFI|#ICE|#ISE|#DEA|#DEX|#BYX|#BZX|#BATE|#CHIX|#CEUX|#BXTR|#IST|#BI20|#GLBX|#ERIS|#XEUR|#CFE").split("\\|")) {
 			String recordName = "Order" + suffix;
 			builder.addRequiredField(recordName, "Void", SerialFieldType.VOID, SchemeFieldTime.FIRST_TIME_INT_FIELD);
 			builder.addRequiredField(recordName, "Index", SerialFieldType.COMPACT_INT, SchemeFieldTime.SECOND_TIME_INT_FIELD);
@@ -205,7 +205,7 @@ public void buildScheme(SchemeBuilder builder) {
 			if (suffix.matches(SystemProperties.getProperty("com.dxfeed.event.order.impl.Order.suffixes.count", "")))
 				builder.addOptionalField(recordName, "Count", select(SerialFieldType.COMPACT_INT), "Order", "Count", true);
 			builder.addRequiredField(recordName, "Flags", SerialFieldType.COMPACT_INT);
-			if (suffix.matches(SystemProperties.getProperty("com.dxfeed.event.order.impl.Order.suffixes.mmid", "|#NTV|#BATE|#CHIX|#BXTR")))
+			if (suffix.matches(SystemProperties.getProperty("com.dxfeed.event.order.impl.Order.suffixes.mmid", "|#NTV|#BATE|#CHIX|#CEUX|#BXTR")))
 				builder.addOptionalField(recordName, "MMID", SerialFieldType.SHORT_STRING, "Order", "MarketMaker", true);
 		}