Skip to content

Commit addefff

Browse files
authored
Fix an issue of failing to recreate a requestresponse opener object in case of connection failures (#446)
1 parent 115f605 commit addefff

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

azure-eventhubs/src/main/java/com/microsoft/azure/eventhubs/impl/RequestResponseOpener.java

+2
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,8 @@ public void onError(Exception error) {
103103
eventDispatcher.deregisterForConnectionError(requestResponseChannel.getSendLink());
104104
eventDispatcher.deregisterForConnectionError(requestResponseChannel.getReceiveLink());
105105

106+
isOpened = false;
107+
106108
if (TRACE_LOGGER.isWarnEnabled()) {
107109
TRACE_LOGGER.warn(String.format(Locale.US, "requestResponseChannel.onClose error clientId[%s], session[%s], link[%s], endpoint[%s], error %s",
108110
clientId, sessionName, linkName, endpointAddress, error));

0 commit comments

Comments
 (0)