ServerInboundSequence seq = new ServerInboundSequence(acksTo, inboundId, outboundId, config);
synchronized (this) {
inboundMap.put(seq.getId(), seq);
if (inboundMap.size() == 1) {
reaper.start();
}
}
ServerOutboundSequence outbound =
(ServerOutboundSequence)seq.getOutboundSequence();
String id = outbound.getId();
if (id != null) {
outboundMap.put(id , outbound);
}
return seq;