bayeux.setJSONCommented(endpoint.isJsonCommented());
prodcon.setBayeux(bayeux);
}
}
public void disconnect(CometdProducerConsumer prodcon) throws Exception {
<BUG>CometdEndpoint endpoint = (CometdEndpoint) prodcon.getEndpoint();
String connectorKey = endpoint.getProtocol() + ":" + endpoint.getUri().getHost() + ":" + endpoint.getPort();</BUG>
synchronized (connectors) {
ConnectorRef connectorRef = connectors.get(connectorKey);
if (connectorRef != null) {

bayeux.setJSONCommented(endpoint.isJsonCommented());
prodcon.setBayeux(bayeux);
}
}
public void disconnect(CometdProducerConsumer prodcon) throws Exception {
CometdEndpoint endpoint = prodcon.getEndpoint();
String connectorKey = endpoint.getProtocol() + ":" + endpoint.getUri().getHost() + ":" + endpoint.getPort();
synchronized (connectors) {
ConnectorRef connectorRef = connectors.get(connectorKey);
if (connectorRef != null) {
