Searched refs:inboundEvents (Results 1 – 1 of 1) sorted by relevance
95 protected final LinkedBlockingQueue<String> inboundEvents = new LinkedBlockingQueue<String>(); field in TestStreamTracer.TestBaseStreamTracer168 inboundEvents.add("inboundMessage(" + seqNo + ")"); in inboundMessage()188 inboundEvents.add( in inboundMessageRead()205 return inboundEvents.poll(); in nextInboundEvent()