context.addComponent("my", new MyQueueComponent());
}
public void testQueueSize() throws Exception {
PollingConsumer consumer = context.getEndpoint(uri).createPollingConsumer();
consumer.start();
assertNotNull(consumer);
EventDrivenPollingConsumer edpc = assertIsInstanceOf(EventDrivenPollingConsumer.class, consumer);
assertEquals(0, edpc.getQueueSize());
assertEquals(10, edpc.getQueueCapacity());