Skip to content

Commit 185a894

Browse files
authored
[notificationqueue] Pass token headers only if not empty (#405)
Otherwise it fails when using mtls certificates.
1 parent 6c8993e commit 185a894

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

java/com/engflow/notificationqueue/Client.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -84,12 +84,14 @@ public static void main(String[] args) throws Exception {
8484
}
8585
try {
8686
final Metadata header = new Metadata();
87-
Metadata.Key<String> methodKey =
88-
Metadata.Key.of("x-engflow-auth-method", Metadata.ASCII_STRING_MARSHALLER);
89-
header.put(methodKey, "jwt-v0");
90-
Metadata.Key<String> tokenKey =
91-
Metadata.Key.of("x-engflow-auth-token", Metadata.ASCII_STRING_MARSHALLER);
92-
header.put(tokenKey, clientOptions.getOption("token"));
87+
if (!Strings.isNullOrEmpty(clientOptions.getOption("token"))) {
88+
Metadata.Key<String> methodKey =
89+
Metadata.Key.of("x-engflow-auth-method", Metadata.ASCII_STRING_MARSHALLER);
90+
header.put(methodKey, "jwt-v0");
91+
Metadata.Key<String> tokenKey =
92+
Metadata.Key.of("x-engflow-auth-token", Metadata.ASCII_STRING_MARSHALLER);
93+
header.put(tokenKey, clientOptions.getOption("token"));
94+
}
9395
pull(channel, clientOptions.getOption("queue_name"), header, forwardChannel);
9496
} finally {
9597
if (channel != null) {

0 commit comments

Comments
 (0)