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, subscriber
public MigrationInvalidator()
public MigrationServiceImpl.MigrationInvalidation deserialize(InputStream in) throws IOException
AbstractPubSubBroker
InputStream
into a message, or null
.deserialize
in class AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
IOException
public void receivedMessage(MigrationServiceImpl.MigrationInvalidation message)
AbstractPubSubBroker
receivedMessage
in class AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
message
- the received messageCopyright © 2018 Nuxeo. All rights reserved.