Java 类org.xbill.DNS.ResolverListener 实例源码

/**
 * Send a query using a ResolverListener. This kicks off the whole process.
 *
 * @param query
 * @param id
 * @param listener
 * @param endTime
 */
public void sendQuery(Message query, Object id, ResolverListener listener, long endTime) {
    this.listener = listener;
    this.id = id;
    this.query = query;
    this.endTime = endTime;
    startTimer();
    startConnect();
}

public ResolverListener getListener() {
    return listener;
}

public void setListener(ResolverListener listener) {
    this.listener = listener;
}

public ResponderThread(ResolverListener listener, Object id, Message response) {
    this.listener = listener;
    this.id = id;
    this.response = response;
}

public ResponderThread(ResolverListener listener, Object id, Exception e) {
    this.listener = listener;
    this.id = id;
    this.e = e;
}

public Object sendAsync(Message query, ResolverListener listener) {
    throw new UnsupportedOperationException("Asynchronous send is not supported by this resolver");
}

/**
 * Send a query using a ResolverListener. This kicks off the whole process.
 *
 * @param qData
 * @param id
 * @param listener
 * @param endTime
 */
public void sendQuery(QueryData qData, Object id, ResolverListener listener, long endTime) {
    qData.setListener(listener);
    qData.setId(id);
    qData.setEndTime(endTime);
    startConnect(qData);
}

/**
 * Not implemented.
 * 
 * @param query The query to send
 * @param listener The object containing the callbacks.
 * @return An identifier, which is also a parameter in the callback
 * @throws UnsupportedOperationException Always
 */
public Object sendAsync(Message query, ResolverListener listener) {
    throw new UnsupportedOperationException("Not implemented");
}