tagging release 3.266

Author: dxcity

ReleaseNotes.txt

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

auth/pom.xml

@@ -19,7 +19,11 @@
 /**
  * The unique session, which determines the permissions of the user.
  * The session may be revoked.
- * <b>This class is thread-safe.</b>
+ *
+ * <p><b>Note</b> that AuhSession is closed when the underlying connection is closed,
+ * therefore unique session must be created for each connection.
+ *
+ * <p><b>This class is thread-safe.</b>
  **/
 public class AuthSession {
 	private Object subject;
@@ -83,7 +87,7 @@ public void setSubject(Object subject) {
 	 * Close this session for this closeReason.
 	 * @param closeReason the closing reason.
 	 */
-	protected void close(String closeReason) {
+	public final void close(String closeReason) {
 		Objects.requireNonNull(closeReason);
 		SessionCloseListener[] listeners;
 		synchronized (this) {
@@ -92,6 +96,11 @@ protected void close(String closeReason) {
 			this.closeReason = closeReason;
 			listeners = this.listeners.toArray(new SessionCloseListener[this.listeners.size()]);
 		}
+		try {
+			closeImpl(closeReason);
+		} catch (Throwable t) {
+			Logging.getLogging(getClass()).error("Unexpected error in closeImpl()", t);
+		}
 		for (SessionCloseListener listener : listeners)
 			try {
 				listener.close(this, closeReason);
@@ -100,6 +109,8 @@ protected void close(String closeReason) {
 			}
 	}
 
+	protected void closeImpl(String closeReason) {}
+
 	/**
 	 * Returns special session variables.
 	 * @return session variables.

auth/src/main/java/com/devexperts/auth/AuthSession.java

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.265</version>
+		<version>3.266</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.265</version>
+		<version>3.266</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>

dxfeed-bin/pom.xml

@@ -14,7 +14,7 @@
 	<parent>
 		<artifactId>QD</artifactId>
 		<groupId>com.devexperts.qd</groupId>
-		<version>3.265</version>
+		<version>3.266</version>
 	</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.265</version>
+		<version>3.266</version>
 		<relativePath>../pom.xml</relativePath>
 	</parent>
 	<modelVersion>4.0.0</modelVersion>

dxfeed-codegen/pom.xml

@@ -83,9 +83,15 @@ FactoryImplGen factory(String basePackageName) {
 	}
 
 	void generateSources() throws IOException {
+		System.out.println("Generating mappings");
+		for (MappingGen gen : mappingGens.values()) {
+			gen.generate();
+		}
+		System.out.println("Generating delegates");
 		for (DelegateGen gen : delegateGens.values()) {
 			gen.generate();
 		}
+		System.out.println("Generating factories");
 		for (FactoryImplGen gen : factoryGens.values()) {
 			gen.generate();
 		}

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

@@ -310,7 +310,6 @@ void generate() throws IOException {
 		if (source != null)
 			generateGetSource(cg);
 		env.writeSourceFile(className, cg.buildSource());
-		mappingGen.generate();
 	}
 
 	private void generateDelegateConstructorCode(ClassGen cg) {

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

@@ -47,10 +47,10 @@ public void writeSourceFile(ClassName className, List<String> sourceLines) throw
 		if (currentSourceLines == null || !currentSourceLines.equals(sourceLines)) {
 			if (config.isVerifyOnly())
 				throw new IOException("Generated file " + outputFile + " is not up-to-date");
-			System.out.println("Writing " + outputFile);
+			System.out.println("Writing    " + outputFile);
 			Files.write(outputFile, sourceLines);
 		} else {
-			System.out.println("Checked " + outputFile + " -- up-to-date.");
+			System.out.println("Checked ok " + outputFile);
 		}
 	}