Package org.nuxeo.runtime.migration
Class MigrationServiceImpl.MigrationInvalidator
- java.lang.Object
-
- org.nuxeo.runtime.pubsub.AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
-
- org.nuxeo.runtime.migration.MigrationServiceImpl.MigrationInvalidator
-
- Enclosing class:
- MigrationServiceImpl
public class MigrationServiceImpl.MigrationInvalidator extends AbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
-
-
Field Summary
-
Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
DISCRIMINATOR_SEP, discriminatorBytes, topic
-
-
Constructor Summary
Constructors Constructor Description MigrationInvalidator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MigrationServiceImpl.MigrationInvalidation
deserialize(InputStream in)
Deserializes anInputStream
into a message, ornull
.void
receivedMessage(MigrationServiceImpl.MigrationInvalidation message)
Callback implementing the delivery of a message from another node.-
Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubBroker
close, initialize, scanDiscriminator, sendMessage, subscriber
-
-
-
-
Method Detail
-
deserialize
public MigrationServiceImpl.MigrationInvalidation deserialize(InputStream in) throws IOException
Description copied from class:AbstractPubSubBroker
Deserializes anInputStream
into a message, ornull
.- Specified by:
deserialize
in classAbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
- Throws:
IOException
-
receivedMessage
public void receivedMessage(MigrationServiceImpl.MigrationInvalidation message)
Description copied from class:AbstractPubSubBroker
Callback implementing the delivery of a message from another node.- Specified by:
receivedMessage
in classAbstractPubSubBroker<MigrationServiceImpl.MigrationInvalidation>
- Parameters:
message
- the received message
-
-