Java 类com.rabbitmq.client.ConfirmListener 实例源码

private void handleAdd(String methodName, Object arg) {
  if ("addConfirmListener".equals(methodName))
    confirmListeners.add((ConfirmListener) arg);
  else if ("addFlowListener".equals(methodName))
    flowListeners.add((FlowListener) arg);
  else if ("addReturnListener".equals(methodName))
    returnListeners.add((ReturnListener) arg);
}

private void handleRemove(String methodName, Object arg) {
  if ("removeConfirmListener".equals(methodName))
    confirmListeners.remove((ConfirmListener) arg);
  else if ("removeFlowListener".equals(methodName))
    flowListeners.remove((FlowListener) arg);
  else if ("removeReturnListener".equals(methodName))
    returnListeners.remove((ReturnListener) arg);
}

@Override
public void addConfirmListener(ConfirmListener listener) {
  channel.addConfirmListener(listener);
}

@Override
public ConfirmListener addConfirmListener(ConfirmCallback confirmCallback,
    ConfirmCallback confirmCallback1) {
  return channel.addConfirmListener(confirmCallback, confirmCallback1);
}

@Override
public boolean removeConfirmListener(ConfirmListener listener) {
  return channel.removeConfirmListener(listener);
}

@Override
public void addConfirmListener(ConfirmListener confirmListener) {
    delegate.addConfirmListener(confirmListener);
}

/**
 * Add a {@link ConfirmListener}.
 * @param listener the listener to add
 */
void addConfirmListener(ConfirmListener listener);

/**
 * Add a {@link ConfirmListener}.
 * @param listener the listener to add
 */
void addConfirmListener(ConfirmListener listener);

/**
 * Remove a {@link ConfirmListener}.
 * @param listener the listener to remove
 * @return <code><b>true</b></code> if the listener was found and removed,
 * <code><b>false</b></code> otherwise
 */
boolean removeConfirmListener(ConfirmListener listener);