import io.vertx.core.AsyncResult;
import io.vertx.core.Vertx;
import io.vertx.core.eventbus.DeliveryOptions;
import io.vertx.core.eventbus.MessageConsumer;
import io.vertx.proton.ProtonHelper;
<BUG>import io.vertx.proton.ProtonLink;
import io.vertx.proton.ProtonSender;</BUG>
public class SinkBridgeEndpoint implements BridgeEndpoint {
private static final Logger LOG = LoggerFactory.getLogger(SinkBridgeEndpoint.class);
private static final String GROUP_ID_MATCH = "/group.id/";

import io.vertx.core.AsyncResult;
import io.vertx.core.Vertx;
import io.vertx.core.eventbus.DeliveryOptions;
import io.vertx.core.eventbus.MessageConsumer;
import io.vertx.proton.ProtonHelper;
import io.vertx.proton.ProtonLink;
import io.vertx.proton.ProtonQoS;
import io.vertx.proton.ProtonSender;
public class SinkBridgeEndpoint implements BridgeEndpoint {
private static final Logger LOG = LoggerFactory.getLogger(SinkBridgeEndpoint.class);
private static final String GROUP_ID_MATCH = "/group.id/";
