public interface Receptionist
The receptionist protocol is used by the processor to receive the point value change event notices.
Modifier and Type | Interface and Description |
---|---|
static class |
Receptionist.Abstract
Abstract receptionist.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the input Queue.
|
void |
commit()
Registers that the notices have been processed.
|
List<PointValue> |
fetchNotices(int limit,
long wait)
Fetches notices.
|
void |
open()
Opens the input Queue.
|
long |
receptionTime()
Returns and resets the reception time.
|
void |
rollback()
Forgets that the notices have been received.
|
boolean |
setUp(Metadata metadata)
Sets up access to the messaging system.
|
void |
tearDown()
Tears down what has been set up.
|
void close()
void commit() throws InterruptedException, ServiceNotAvailableException
InterruptedException
- When the service is stopped.ServiceNotAvailableException
- When the service is not available.@Nonnull @CheckReturnValue List<PointValue> fetchNotices(int limit, long wait) throws InterruptedException, ServiceNotAvailableException
limit
- The limit for the number of notices.wait
- Negative is forever, 0 is no wait, other is milliseconds.InterruptedException
- When the service is stopped.ServiceNotAvailableException
- When the service is not available.void open()
@CheckReturnValue long receptionTime()
void rollback() throws InterruptedException, ServiceNotAvailableException
InterruptedException
- When the service is stopped.ServiceNotAvailableException
- When the service is not available.@CheckReturnValue boolean setUp(Metadata metadata)
metadata
- The processor metadata.void tearDown()
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.