properties);
properties.put(JobImpl.PROPERTY_RESOURCE_PATH, path);
return new JobImpl(jobTopic, jobName, jobId, properties);
}
public void reassign(final JobImpl job) {
<BUG>final QueueInfo queueInfo = queueConfigManager.getQueueInfo(job.getTopic());
final InternalQueueConfiguration config = queueInfo.queueConfiguration;</BUG>
if ( config.getType() == QueueConfiguration.Type.DROP ) {
if ( logger.isDebugEnabled() ) {
logger.debug("Dropping job due to configuration of queue {} : {}", queueInfo.queueName, Utility.toString(job));

properties);
properties.put(JobImpl.PROPERTY_RESOURCE_PATH, path);
return new JobImpl(jobTopic, jobName, jobId, properties);
}
public void reassign(final JobImpl job) {
final QueueInfo queueInfo = queueManager.getQueueInfo(job.getTopic());
final InternalQueueConfiguration config = queueInfo.queueConfiguration;
if ( config.getType() == QueueConfiguration.Type.DROP ) {
if ( logger.isDebugEnabled() ) {
logger.debug("Dropping job due to configuration of queue {} : {}", queueInfo.queueName, Utility.toString(job));
