Skip to content

Commit b1cc5f9

Browse files
committed
Fix javadoc
1 parent 5ddee1e commit b1cc5f9

2 files changed

Lines changed: 4 additions & 5 deletions

File tree

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -350,6 +350,7 @@
350350
import org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider;
351351
import org.apache.ignite.spi.collision.jobstealing.JobStealingRequest;
352352
import org.apache.ignite.spi.collision.jobstealing.JobStealingRequestSerializer;
353+
import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
353354
import org.apache.ignite.spi.communication.tcp.internal.TcpInverseConnectionResponseMessage;
354355
import org.apache.ignite.spi.communication.tcp.internal.TcpInverseConnectionResponseMessageSerializer;
355356
import org.apache.ignite.spi.communication.tcp.messages.HandshakeMessage;
@@ -481,7 +482,6 @@ public GridIoMessageFactory(Marshaller marsh, ClassLoader clsLdr) {
481482
factory.register(GridDhtPartitionExchangeId::new, new GridDhtPartitionExchangeIdSerializer());
482483
factory.register(GridCacheReturn::new, new GridCacheReturnSerializer());
483484
factory.register(GridCacheEntryInfo::new, new GridCacheEntryInfoSerializer());
484-
factory.register(CacheEntryInfoCollection::new, new CacheEntryInfoCollectionSerializer());
485485
factory.register(CacheInvokeDirectResult::new, new CacheInvokeDirectResultSerializer());
486486
factory.register(IgniteTxKey::new, new IgniteTxKeySerializer());
487487
factory.register(DataStreamerEntry::new, new DataStreamerEntrySerializer());
@@ -500,7 +500,6 @@ public GridIoMessageFactory(Marshaller marsh, ClassLoader clsLdr) {
500500
factory.register(GridCacheSqlQuery::new, new GridCacheSqlQuerySerializer());
501501
factory.register(IndexKeyDefinition::new, new IndexKeyDefinitionSerializer());
502502
factory.register(GridDhtPartitionSupplyMessage::new, new GridDhtPartitionSupplyMessageSerializer());
503-
factory.register(UUIDCollectionMessage::new, new UUIDCollectionMessageSerializer());
504503
factory.register(GridNearSingleGetRequest::new, new GridNearSingleGetRequestSerializer());
505504
factory.register(GridNearSingleGetResponse::new, new GridNearSingleGetResponseSerializer());
506505
factory.register(CacheContinuousQueryBatchAck::new, new CacheContinuousQueryBatchAckSerializer());

modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,15 +52,15 @@ public interface MessageFactory {
5252
public void register(short directType, Supplier<Message> supplier, MessageSerializer serializer) throws IgniteException;
5353

5454
/**
55-
* Register message factory using the direct type obtained from the serializer via {@link MessageSerializer#directType()}.
55+
* Register message factory using the direct type obtained from the message via {@link Message#directType()}.
5656
* This is a convenience method equivalent to {@link #register(short, Supplier, MessageSerializer)} where the direct
57-
* type is derived from the serializer itself.
57+
* type is derived from the message instance itself.
5858
*
5959
* <p>All messages must be registered during construction of class which implements this interface. Any invocation
6060
* of this method after initialization is done must throw {@link IllegalStateException} exception.
6161
*
6262
* @param supplier Message factory.
63-
* @param serializer Message serializer that also provides the direct type for registration.
63+
* @param serializer Message serializer.
6464
* @throws IgniteException In case of attempt to register message with direct type which is already registered.
6565
* @throws IllegalStateException On any invocation of this method when class which implements this interface
6666
* is already constructed.

0 commit comments

Comments
 (0)