code: private void notifyReadySendListeners(BlockingQueue<Pair<SendListener, Conversation>> readySendCallbacks) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "notifyReadySendListeners", readySendCallbacks);
        try {
           for (Pair<SendListener, Conversation> callback : readySendCallbacks) {
              callback.left.dataSent(callback.right);
           }
        } catch (Throwable t) {
           FFDCFilter.processException
                   (t, "com.ibm.ws.sib.jfapchannel.impl.ConnectionWriteCompletedCallback", JFapChannelConstants.CONNWRITECOMPCALLBACK_COMPLETE_01, connection.getDiagnostics(true));
           if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
              SibTr.debug(tc, "exception invoking send listener data sent");
           if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) SibTr.exception(tc, t);
           connection.invalidate(true, t, "send listener threw exception");  // D224570
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "notifyReadySendListeners");
     }
docs: Call send listener callback for each entry in the given queue.
  Any exception thrown from a listener's callback will cause the connection to be invalidated.
  @param readySendCallbacks