public class MigrationServiceImpl.MigrationInvalidator extends AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
DISCRIMINATOR_SEP, discriminatorBytes, topic| Constructor and Description |
|---|
MigrationInvalidator() |
| Modifier and Type | Method and Description |
|---|---|
MigrationServiceImpl.MigrationInvalidation |
deserialize(InputStream in)
Deserializes an
InputStream into a message, or null. |
void |
receivedMessage(MigrationServiceImpl.MigrationInvalidation message)
Callback implementing the delivery of a message from another node.
|
close, initialize, scanDiscriminator, sendMessage, subscriberpublic MigrationInvalidator()
public MigrationServiceImpl.MigrationInvalidation deserialize(InputStream in) throws IOException
AbstractPubSubBrokerInputStream into a message, or null.deserialize in class AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>IOExceptionpublic void receivedMessage(MigrationServiceImpl.MigrationInvalidation message)
AbstractPubSubBrokerreceivedMessage in class AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>message - the received messageCopyright © 2018 Nuxeo. All rights reserved.