package org.jboss.jms.serverless;
import org.jboss.logging.Logger;
import org.jgroups.Address;
import java.io.Serializable;
public class QueueReceiverAddress implements Serializable {
static final long serialVersionUID = 11480310721131223L;
private static final Logger log = Logger.getLogger(QueueReceiverAddress.class);
private Address addr;
private String sessionID;
private String queueReceiverID;
private boolean nextForDelivery;
public QueueReceiverAddress(Address addr, String sessionID, String queueReceiverID) {
if (addr == null) {
throw new NullPointerException("null address");
}
if (sessionID == null) {
throw new NullPointerException("null session ID");
}
if (queueReceiverID == null) {
throw new NullPointerException("null queue receiver ID");
}
this.addr = addr;
this.sessionID = sessionID;
this.queueReceiverID = queueReceiverID;
}
public Address getAddress() {
return addr;
}
public String getSessionID() {
return sessionID;
}
public String getReceiverID() {
return queueReceiverID;
}
public boolean isNextForDelivery() {
return nextForDelivery;
}
public void setNextForDelivery(boolean b) {
nextForDelivery = b;
}
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (!(o instanceof QueueReceiverAddress)) {
return false;
}
QueueReceiverAddress that = (QueueReceiverAddress)o;
return
(addr != null && addr.equals(that.addr)) &&
(sessionID != null && sessionID.equals(that.sessionID)) &&
(queueReceiverID != null && queueReceiverID.equals(that.queueReceiverID));
}
public int hashCode() {
return
(addr == null ? 0 : addr.hashCode()) +
(sessionID == null ? 0 : sessionID.hashCode()) +
(queueReceiverID == null ? 0 : queueReceiverID.hashCode());
}
public String toString() {
StringBuffer sb = new StringBuffer("QueueReceiverAddress[");
sb.append(addr);
sb.append("/sessionID=");
sb.append(sessionID);
sb.append("/receiverID=");
sb.append(queueReceiverID);
sb.append("]");
return sb.toString();
}
}