eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-20 04:35:32 +00:00
Code Activity

Bug 4963: Fixed sending operations from a replica to the master

Browse Source
This commit is contained in:
Steffen Schaefer
2019-04-03 16:52:40 +02:00
parent cfdd62eafb
commit 5a51aef645
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sse.replication.interfaces/src/com/sap/sse/replication/OperationsToMasterSender.java
+6 -4
View File
@@ -5,12 +5,11 @@ import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.util.logging.Logger;
import com.sap.sse.common.WithID;
import com.sap.sse.util.HttpUrlConnectionHelper;
public interface OperationsToMasterSender<S, O extends OperationWithResult<S, ?>> extends OperationsToMasterSendingQueue, WithID {
final Logger logger = Logger.getLogger(OperationsToMasterSender.class.getName());
@@ -46,8 +45,11 @@ public interface OperationsToMasterSender<S, O extends OperationWithResult<S, ?>
// TODO bug4018: if sending the operation fails, e.g., because of an HTTP response code != 2xx, enqueue the operation for retry
addOperationSentToMasterForReplication(operationWithResultWithIdWrapper);
URL url = masterDescriptor.getSendReplicaInitiatedOperationToMasterURL(this.getId().toString());
final URLConnection connection = HttpUrlConnectionHelper.redirectConnectionWithBearerToken(url,
masterDescriptor.getBearerToken());
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
String optionalBearerToken = masterDescriptor.getBearerToken();
if (optionalBearerToken != null && !optionalBearerToken.isEmpty()) {
connection.setRequestProperty("Authorization", "Bearer " + optionalBearerToken);
}
connection.setDoOutput(true); // we want to post the serialized operation
logger.info("Sending operation "+operation+" to master "+masterDescriptor+"'s replicable with ID "+this+" for initial execution and replication");
connection.connect();