in modules/core/src/main/java/org/apache/sandesha2/storage/beans/SenderBean.java [335:386]
public boolean match(RMBean matchInfo) {
SenderBean bean = (SenderBean) matchInfo;
boolean match = true;
if(bean.getMessageID() != null && !bean.getMessageID().equals(this.getMessageID()))
match = false;
else if(bean.getMessageContextRefKey() != null && !bean.getMessageContextRefKey().equals(this.getMessageContextRefKey()))
match = false;
else if(bean.getInternalSequenceID() != null && !bean.getInternalSequenceID().equals(this.getInternalSequenceID()))
match = false;
else if(bean.getSequenceID() != null && !bean.getSequenceID().equals(this.getSequenceID()))
match = false;
else if(bean.getToAddress() != null && !bean.getToAddress().equals(this.getToAddress()))
match = false;
else if(bean.getInboundSequenceId() != null && !bean.getInboundSequenceId().equals(this.getInboundSequenceId()))
match = false;
else if((bean.flags & SEND_FLAG) != 0 && bean.isSend() != this.isSend())
match = false;
else if((bean.flags & SEND_COUNT_FLAG) != 0 && bean.getSentCount() != this.getSentCount())
match = false;
else if((bean.flags & MSG_NUMBER_FLAG) != 0 && bean.getMessageNumber() != this.getMessageNumber())
match = false;
else if((bean.flags & RESEND_FLAG) != 0 && bean.isReSend() != this.isReSend())
match = false;
// Time is special - we don't match beans that should be sent after the time in the selector
else if((bean.flags & TIME_TO_SEND_FLAG) != 0 && bean.getTimeToSend() < this.getTimeToSend())
match = false;
else if((bean.flags & MSG_TYPE_FLAG) != 0 && bean.getMessageType() != this.getMessageType())
match = false;
else if((bean.flags & LAST_MSG_FLAG) != 0 && bean.isLastMessage() != this.isLastMessage())
match = false;
else if((bean.flags & IN_MSG_NUM_FLAG) != 0 && bean.getInboundMessageNumber() != this.getInboundMessageNumber())
match = false;
else if((bean.flags & TRANSPORT_FLAG) != 0 && bean.isTransportAvailable() != this.isTransportAvailable())
match = false;
return match;
}