.as(WebArchive.class);
}
@Inject @DispatchToQueue
private Event<TriggerMetricCollection> triggerMetricCollection;
@Resource(mappedName = "java:/queue/TriggerMetricCollectionQueue")
<BUG>private Queue triggerMetricCollectionQueue;
@Test(timeout = 5000)</BUG>
public void testDeduplication() throws InterruptedException {
<BUG>String uuid = UUID.randomUUID().toString();

TriggerMetricCollection msg = new TriggerMetricCollection(uuid);

final String msgSelector = String.format("_HQ_DUPL_ID = '%s'", uuid);</BUG>
triggerMetricCollection.fire(msg);

.as(WebArchive.class);
}
@Inject @DispatchToQueue
private Event<TriggerMetricCollection> triggerMetricCollection;
@Resource(mappedName = "java:/queue/TriggerMetricCollectionQueue")
private Queue triggerMetricCollectionQueue;
private static final ConcurrentLinkedQueue<TriggerMetricCollection> receivedTriggers = new ConcurrentLinkedQueue<TriggerMetricCollection>();
private static final CountDownLatch firstMessageLatch = new CountDownLatch(1);
private static String messageId;
@Test(timeout = 5000)
public void testDeduplication() throws InterruptedException {
messageId = UUID.randomUUID().toString();
TriggerMetricCollection msg = new TriggerMetricCollection(messageId);
