Skip to content

Commit ad60ef7

Browse files
authored
Minor bug fix (#89)
* Fixing javadoc generation errors * Adding dependency to use SLF4J logging instead of java util logging. * More SLF4J migration * Changed all java util logging statements to slf4j. * Checking in the POM that goes with the release to maven reposisory. * Removed unused imports * Instrumented all code with SLF4J logging. * Fixing some log statements * Moving request-response link creation to message factory so we don't create multiple links to the same entity. * Updaing third party notice to include SLF4J license. * Updating distributed POM * Renaming setContent method to setBody. * Fixing a typo in log statement. * Handling the special case of 0 timeout for receives. If there are no prefetched messages, receive call returns immediately with already prefetched messages. * Correcting a log statement * Added javadoc comments for rules package. * Adding javadoc comments. Work in progress. * More javadoc comments added. * Fixing a minor bug in sender and receiver creation. Closes the messaging factory if sender or receiver creation fails. * Fixing the issue of not renewing CBS tokens. Also a concurrency fix. * Fixing a bug in session receiver to not repeatedly attempt accepting the same session on lock lost. * Added some java docs.. And changed default prefetch count, based on receive mode. * Fixing a thread unending wait bug in request-response link. * Fixing AuthorizationFailed exceptions that pop when the conncetion is recreated. * Minor tweaks * Another minor fix
1 parent 6dfd93d commit ad60ef7

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

azure-servicebus/src/main/java/com/microsoft/azure/servicebus/primitives/RequestResponseLink.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,11 @@ public CompletableFuture<Message> requestAysnc(Message requestMessage, Duration
223223
{
224224
this.recreateInternalLinks().handleAsync((v, recreationEx) ->
225225
{
226-
this.closeAsync();
226+
if(recreationEx != null)
227+
{
228+
this.closeAsync();
229+
}
230+
227231
return null;
228232
});
229233
}

0 commit comments

Comments
 (0)