public synchronized void close() {
LOG.info("Closing session: {}", this);
if (this.state != State.Idle) {
- this.sendMessage(new NotifyBuilder().setErrorCode(BGPError.CEASE.getCode()).build());
+ this.sendMessage(new NotifyBuilder().setErrorCode(BGPError.CEASE.getCode()).setErrorSubcode((short)0).build());
this.channel.close();
this.state = State.Idle;
}
}
});
this.lastMessageSentAt = System.nanoTime();
- LOG.debug("Sent message: {} to peer {}", msg, this.bgpId);
} catch (final Exception e) {
LOG.warn("Message {} was not sent.", msg, e);
}