final JobExecutor consumer = this.jobConsumerManager.getExecutor(job.getTopic());
boolean reassign = false;
String reassignTargetId = null;
if ( consumer == null && (!job.isBridgedEvent() || !this.jobConsumerManager.supportsBridgedEvents())) {
reassign = true;
<BUG>}
final QueueInfo queueInfo = queueConfigManager.getQueueInfo(job.getTopic());

final InternalQueueConfiguration config = queueInfo.queueConfiguration;</BUG>
if ( config.getType() == QueueConfiguration.Type.DROP ) {

final JobExecutor consumer = this.jobConsumerManager.getExecutor(job.getTopic());
boolean reassign = false;
String reassignTargetId = null;
if ( consumer == null && (!job.isBridgedEvent() || !this.jobConsumerManager.supportsBridgedEvents())) {
reassign = true;
}
final TopologyCapabilities caps = this.topologyCapabilities;
final QueueInfo queueInfo = caps != null ? caps.getQueueInfo(job.getTopic()) : null;
if ( queueInfo == null ) {
return; // TODO
}
final InternalQueueConfiguration config = queueInfo.queueConfiguration;
if ( config.getType() == QueueConfiguration.Type.DROP ) {
