public class TestConnectorQueueHandler extends Object
Constructor and Description |
---|
TestConnectorQueueHandler(Registry registry) |
Modifier and Type | Method and Description |
---|---|
CoreEvent |
read(String queueName)
Reads an event from a given queue waiting if necessary until an element becomes available.
|
CoreEvent |
read(String queueName,
long timeout)
Reads an event from a given queue waiting up to the specified wait time if necessary for an element to become available.
|
void |
write(String queueName,
CoreEvent event)
Writes a event to a given queue waiting if necessary for space to become available
|
public TestConnectorQueueHandler(Registry registry)
public void write(String queueName, CoreEvent event)
queueName
- event
- public CoreEvent read(String queueName)
queueName
- CoreEvent
read from the queueCopyright © 2018. All rights reserved.