HSEARCH-1296 Workaround for dispatcher speed problem (JGRP-1617)

hibernate-search-engine/src/main/java/org/hibernate/search/backend/impl/jgroups/AutoNodeSelector.java

@@ -81,7 +81,7 @@ else if ( members.size() == 2 ) {
 
 	@Override
 	public Message createMessage(byte[] data) {
-		return new Message( masterAddress, localAddress, data );
+		return new Message( null, localAddress, data );
 	}
 
 }

hibernate-search-engine/src/main/java/org/hibernate/search/backend/impl/jgroups/JGroupsBackendQueueProcessor.java

@@ -99,6 +99,7 @@ public void initialize(Properties props, WorkerBuildContext context, DirectoryBa
 		final boolean sync = BackendFactory.isConfiguredAsSync( props );
 		final boolean block = ConfigurationParseHelper.getBooleanValue( props, BLOCK_WAITING_ACK, sync );
 
+		log.jgroupsBlockWaitingForAck( indexName, block );
 		jgroupsProcessor = new JGroupsBackendQueueTask( this, indexManager, masterNodeSelector, block );
 		luceneBackendQueueProcessor = new LuceneBackendQueueProcessor();
 		luceneBackendQueueProcessor.initialize( props, context, indexManager );

hibernate-search-engine/src/main/java/org/hibernate/search/util/logging/impl/Log.java

@@ -675,4 +675,16 @@ public interface Log extends BasicLogger {
 			" The FieldBridge must be a TwoWayFieldBridge or you have to enable the ignoreFieldBridge option when defining a Query" )
 	SearchException fieldBridgeNotTwoWay(Class<? extends FieldBridge> bridgeClass, String fieldName, XClass beanXClass);
 
+	@LogMessage(level = Level.DEBUG)
+	@Message(id = 170, value = "Starting JGroups channel using configuration '%1$s'")
+	void startingJGroupsChannel(Object cfg);
+
+	@LogMessage(level = Level.DEBUG)
+	@Message(id = 171, value = "Using JGroups channel having configuration '%1$s'")
+	void jgroupsFullConfiguration(String printProtocolSpecAsXML);
+
+	@LogMessage(level = Level.DEBUG)
+	@Message(id = 172, value = "JGroups backend configured for index '%1$s' using block_for_ack '%2$s'")
+	void jgroupsBlockWaitingForAck(String indexName, boolean block);
+
 }